Java三大器之监听器（Listener）的工作原理和代码演示

课程地址：Java三大器之监听器（Listener）的工作原理和代码演示

   现在来说说Servlet的监听器Listener，它是实现了javax.servlet.ServletContextListener 接口的服务器端程序，它也是随web应用的启动

而启动，只初始化一次，随web应用的停止而销毁。主要作用是：做一些初始化的内容添加工作、设置一些基本的内容、比如一些参数或者是一些

固定的对象等等。首先来看一下ServletContextListener接口的源代码：

1.  public abstract interface ServletContextListener extends EventListener{  
2.  public abstract void contextInitialized(ServletContextEvent paramServletContextEvent);  
3.  public abstract void contextDestroyed(ServletContextEvent paramServletContextEvent);  
4.  }

下面利用监听器对数据库连接池DataSource的初始化演示它的使用：ListenerTest.java

1.  import javax.servlet.ServletContext;     
2.  import javax.servlet.ServletContextEvent;     
3.  import javax.servlet.ServletContextListener;     
4.  import org.apache.commons.dbcp.BasicDataSource;         
5.  /** 
6.  * 现在来说说Servlet的监听器Listener，它是实现了javax.servlet.ServletContextListener 接口的 
7.  * 服务器端程序，它也是随web应用的启动而启动，只初始化一次，随web应用的停止而销毁。主要作用是：做一些初始化 
8.  * 的内容添加工作、设置一些基本的内容、比如一些参数或者是一些固定的对象等等。 
9.  *  
10.  * 示例代码：使用监听器对数据库连接池DataSource进行初始化 
11.  */   
12.  public class ListenerTest implements ServletContextListener{       
13.  // 应用监听器的销毁方法     
14.  public void contextDestroyed(ServletContextEvent servletContextEvent) {     
15.  ServletContext servletContext = servletContextEvent.getServletContext();  
16.  // 在整个web应用销毁之前调用，将所有应用空间所设置的内容清空  
17.  servletContext.removeAttribute("dataSource");  
18.  System.out.println("销毁工作完成...");    
19.  }     
20.  // 应用监听器的初始化方法     
21.  public void contextInitialized(ServletContextEvent servletContextEvent) {     
22.  // 通过这个事件可以获取整个应用的空间     
23.  // 在整个web应用下面启动的时候做一些初始化的内容添加工作     
24.  ServletContext servletContext = servletContextEvent.getServletContext();    
25.  // 设置一些基本的内容；比如一些参数或者是一些固定的对象     
26.  // 创建DataSource对象，连接池技术 dbcp     
27.  BasicDataSource basicDataSource = new BasicDataSource();   
28.  basicDataSource.setDriverClassName("com.jdbc.Driver");   
29.  basicDataSource.setUrl("jdbc:mysqlocalhost:3306/");   
30.  basicDataSource.setUsername("root");     
31.  basicDataSource.setPassword("root");     
32.  basicDataSource.setMaxActive(10);//最大连接数     
33.  basicDataSource.setMaxIdle(5);//最大管理数     
34.  //bds.setMaxWait(maxWait); 最大等待时间     
35.  // 把 DataSource 放入ServletContext空间中，     
36.  // 供整个web应用的使用(获取数据库连接)  
37.  servletContext.setAttribute("dataSource", basicDataSource);     
38.  System.out.println("应用监听器初始化工作完成...");     
39.  System.out.println("已经创建DataSource...");    
40.  }     
41.  }

web.xml中配置如下，很简单：

1.  <!-- 配置应用监听器  -->     
2.  <listener>     
3.  <listener-class>com.ycq.ListenerTest</listener-class>     
4.  </listener>

这样配置好了之后，以后在web应用中就可以通过ServletContext取得BasicDataSource对象，从而获取与数据库的连接，提高性能，方便使用。

示例代码二：

1.  import java.io.File;  
2.  import javax.servlet.ServletContextEvent;  
3.  import javax.servlet.ServletContextListener;  
4.  import com.i2f.fsp.deploy.TransactionDeployer;  
5.  /** 
6.  * 监听器随着项目的启动而启动 
7.  * 
8.  */  
9.  public class ListenerTest2 implements ServletContextListener{  
10.  // 销毁监听器   
11.  public void contextDestroyed(ServletContextEvent servletContextEvent) {  
12.  System.out.println("date20161020095500 :" + servletContextEvent.getServletContext());  
13.  }  
14.  public void contextInitialized(ServletContextEvent servletContextEvent) {  
15.  try{  
16.  // 获取项目跟路径  
17.  String basePath = servletContextEvent.getServletContext().getRealPath("/");  
18.  // D:\apache-tomcat-6.0.41\webapps\i2money\ 绝对路径  
19.  System.out.println("basePath20161020094700 :" + basePath);  
20.  if (!(basePath.endsWith(File.separator))){  
21.  basePath = basePath + File.separator;  
22.  }  
23.  basePath = basePath + "WEB-INF" + File.separator + "classes" + File.separator;  
24.  new TransactionDeployer(basePath).deploy();  
25.  // D:\apache-tomcat-6.0.41\webapps\i2money\WEB-INF\classes\  
26.  System.out.println("basePath20161020094701 :" + basePath);  
27.  }  
28.  catch (Exception e){  
29.  e.printStackTrace();  
30.  System.exit(-1);  
31.  }  
32.  }  
33.  }

示例代码三：

1.  import javax.servlet.http.HttpSession;  
2.  import javax.servlet.http.HttpSessionEvent;  
3.  import javax.servlet.http.HttpSessionListener;  
4.  import org.apache.commons.logging.Log;  
5.  import org.apache.commons.logging.LogFactory;  
6.  import org.springframework.context.ApplicationContext;  
7.  import org.springframework.web.context.support.WebApplicationContextUtils;  
8.  public class UserLogoutListener implements HttpSessionListener{  
9.  protected final Log log = LogFactory.getLog(super.getClass());  
10.  public void sessionCreated(HttpSessionEvent event){  
11.  this.log.error("session created. id = " + event.getSession().getId());  
12.  }  
13.  public void sessionDestroyed(HttpSessionEvent event){  
14.  this.log.error("session destroyed.id = " + event.getSession().getId());  
15.  HttpSession session = event.getSession();  
16.  ApplicationContext context = WebApplicationContextUtils.getWebApplicationContext(session.getServletContext());  
17.  OnlineUserMonitorClient client = (OnlineUserMonitorClient)context.getBean("onlineUserMonitorClient");  
18.  client.afterSessionDestroyed(session);  
19.  }  
20.  }

监听器在实际项目中的应用，监听器在java web中应用的较多，比如：统计当前在线人数、自定义session扫描器。
--------------------- 应用一：统计当前在线人数 ---------------------

1.  import javax.servlet.ServletContext;  
2.  import javax.servlet.http.HttpSessionEvent;  
3.  import javax.servlet.http.HttpSessionListener;  
4.  /** 
5.  * @description HttpSessionListener监听器实现统计网站在线人数的功能 
6.  */  
7.  public class SessionListener implements HttpSessionListener{  

9.  public static int TOTAL_ONLINE_USERS = 0;  
10.  public void sessionCreated(HttpSessionEvent httpSessionEvent) {  
11.  ServletContext servletContext = httpSessionEvent.getSession().getServletContext();  
12.  TOTAL_ONLINE_USERS = (Integer) servletContext.getAttribute("TOTAL_ONLINE_USERS");  
13.  // 如果用户退出，TOTAL_ONLINE_USERS自减1  
14.  if(TOTAL_ONLINE_USERS == 0){  
15.  servletContext.setAttribute("TOTAL_ONLINE_USERS", 1);  
16.  }  
17.  else{  
18.  TOTAL_ONLINE_USERS--;  
19.  servletContext.setAttribute("TOTAL_ONLINE_USERS", TOTAL_ONLINE_USERS);  
20.  }  
21.  }  

23.  public void sessionDestroyed(HttpSessionEvent httpSessionEvent) {  
24.  ServletContext servletContext = httpSessionEvent.getSession().getServletContext();  
25.  TOTAL_ONLINE_USERS = (Integer) servletContext.getAttribute("TOTAL_ONLINE_USERS");  
26.  // 如果用户登录，TOTAL_ONLINE_USERS自增1  
27.  if(TOTAL_ONLINE_USERS == 0){  
28.  servletContext.setAttribute("TOTAL_ONLINE_USERS", 1);  
29.  }  
30.  else{  
31.  TOTAL_ONLINE_USERS++;  
32.  servletContext.setAttribute("TOTAL_ONLINE_USERS", TOTAL_ONLINE_USERS);  
33.  }  
34.  }  
35.  }

--------------------- 应用二：自定义session扫描器 ---------------------

1.  import java.util.LinkedList;  
2.  import java.util.List;  
3.  import java.util.Timer;  
4.  import javax.servlet.ServletContextEvent;  
5.  import javax.servlet.ServletContextListener;  
6.  import javax.servlet.http.HttpSession;  
7.  import javax.servlet.http.HttpSessionEvent;  
8.  import javax.servlet.http.HttpSessionListener;  
9.  import jeus.util.concurrent50.Collections;  
10.  /** 
11.  * @description 当网站用户量增加时，session占用的内存会越来越大，这时session的管理，将会是一项很大的 
12.  * 系统开销，为了高效的管理session，我们可以写一个监听器，定期清理掉过期的session 
13.  */  
14.  public class SessionScanerListener implements HttpSessionListener,ServletContextListener{  
15.  // 创建一个线程安全的集合，用来存储session  
16.  @SuppressWarnings("unchecked")  
17.  List<HttpSession> sessionList = Collections.synchronizedList(new LinkedList<HttpSession>());  
18.  private Object lock = new Object();  

20.  public void sessionCreated(HttpSessionEvent httpSessionEvent) {  
21.  System.out.println("session 创建成功...");  
22.  HttpSession httpSession = httpSessionEvent.getSession();  
23.  synchronized (lock){  
24.  sessionList.add(httpSession);  
25.  }  
26.  }  

28.  public void sessionDestroyed(HttpSessionEvent httpSessionEvent) {  
29.  System.out.println("session 销毁成功...");  
30.  }  
31.  // web应用关闭时触发contextDestroyed事件  
32.  public void contextDestroyed(ServletContextEvent servletContextEvent) {  
33.  System.out.println("web应用关闭...");  
34.  }  

36.  // web应用启动时触发contextInitialized事件  
37.  public void contextInitialized(ServletContextEvent servletContextEvent) {  
38.  System.out.println("web应用初始化...");  
39.  // 创建定时器  
40.  Timer timer = new Timer();  
41.  // 每隔30秒就定时执行任务  
42.  timer.schedule(new MyTask(sessionList,lock), 0, 1000*30);  
43.  }  
44.  }  
1.  import java.util.List;  
2.  import java.util.ListIterator;  
3.  import java.util.TimerTask;  
4.  import javax.servlet.http.HttpSession;  
5.  /** 
6.  * 定时器，定义定时任务的具体内容 
7.  */  
8.  public class MyTask extends TimerTask{  
9.  private List<HttpSession> list;  
10.  // 存储传递过来的锁  
11.  private Object lock;  
12.  // 构造方法  
13.  MyTask(List<HttpSession> list, Object lock){  
14.  this.list = list;  
15.  this.lock = lock;  
16.  }  
17.  @Override  
18.  public void run() {  
19.  // 考虑到多线程的情况，这里必须要同步  
20.  synchronized (lock){  
21.  System.out.println("定时器开始执行...");  
22.  ListIterator<HttpSession> listIterator = list.listIterator();  
23.  while(listIterator.hasNext()){  
24.  HttpSession httpSession = listIterator.next();  
25.  // httpSession.getLastAccessedTime() = session的最后访问时间  
26.  if(System.currentTimeMillis() - httpSession.getLastAccessedTime() > 1000*30){  
27.  // 手动销毁session  
28.  httpSession.invalidate();  
29.  // 从集合中移除已经被销毁的session  
30.  listIterator.remove();  
31.  }  
32.  }  
33.  }  
34.  }  
35.  }
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 214,100评论 6赞 493
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 91,308评论 3赞 388
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 159,718评论 0赞 349
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 57,275评论 1赞 287
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 66,376评论 6赞 386
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 50,454评论 1赞 292
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,464评论 3赞 412
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 38,248评论 0赞 269
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 44,686评论 1赞 306
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,974评论 2赞 328
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,150评论 1赞 342
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 34,817评论 4赞 337
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 40,484评论 3赞 322
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,140评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,374评论 1赞 267
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 47,012评论 2赞 365
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 44,041评论 2赞 351

推荐阅读更多精彩内容

  • Spring boot参考指南
    Spring Boot 参考指南 介绍 转载自:https://www.gitbook.com/book/qbgb...
    毛宇鹏阅读 46,796评论 6赞 342
  • Java Web 之 Listener
    本文包括：1、Listener简介2、Servlet监听器3、监听三个域对象创建和销毁的事件监听器4、监听三个域对...
    廖少少阅读 6,057评论 6赞 28
  • Spring Cloud
    Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智...
    卡卡罗2017阅读 134,644评论 18赞 139
  • Java后台面试 常见问题
    从三月份找实习到现在，面了一些公司，挂了不少，但最终还是拿到小米、百度、阿里、京东、新浪、CVTE、乐视家的研发岗...
    时芥蓝阅读 42,222评论 11赞 349
  • 你空掉的钱包，是梦想的坟墓
    前几年网络上到处都是鸡汤，看朋友圈都是别人转发的各种励志鸡汤文，一读便热血沸腾，激情四溅。 好像这个世界里，没有梦...
    梅安文阅读 428评论 0赞 1