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

    现在来说说Servlet的监听器Listener，它是实现了javax.servlet.ServletContextListener 接口的服务器端程序，它也是随web应用的启动
而启动，只初始化一次，随web应用的停止而销毁。主要作用是：做一些初始化的内容添加工作、设置一些基本的内容、比如一些参数或者是一些

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

 

view plain copy print?

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

public abstract interface ServletContextListener extends EventListener{
    public abstract void contextInitialized(ServletContextEvent paramServletContextEvent);
    public abstract void contextDestroyed(ServletContextEvent paramServletContextEvent);
}

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

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. }  

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

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

 

 

view plain copy print?

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

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

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

 

示例代码二：

 

view plain copy print?

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. }  

import java.io.File;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import com.i2f.fsp.deploy.TransactionDeployer;
/**
 * 监听器随着项目的启动而启动
 *
 */
public class ListenerTest2 implements ServletContextListener{
    // 销毁监听器 
    public void contextDestroyed(ServletContextEvent servletContextEvent) {
        System.out.println("date20161020095500 :" + servletContextEvent.getServletContext());
    }
    public void contextInitialized(ServletContextEvent servletContextEvent) {
        try{
            // 获取项目跟路径
            String basePath = servletContextEvent.getServletContext().getRealPath("/");
            // D:\apache-tomcat-6.0.41\webapps\i2money\ 绝对路径
            System.out.println("basePath20161020094700 :" + basePath);
            if (!(basePath.endsWith(File.separator))){
                basePath = basePath + File.separator;
            }
            basePath = basePath + "WEB-INF" + File.separator + "classes" + File.separator;
            new TransactionDeployer(basePath).deploy();
            // D:\apache-tomcat-6.0.41\webapps\i2money\WEB-INF\classes\
            System.out.println("basePath20161020094701 :" + basePath);
        }
        catch (Exception e){
            e.printStackTrace();
            System.exit(-1);
        }
    }
}

示例代码三：

 

 

view plain copy print?

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. }  

import javax.servlet.http.HttpSession;
import javax.servlet.http.HttpSessionEvent;
import javax.servlet.http.HttpSessionListener;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.web.context.support.WebApplicationContextUtils;
public class UserLogoutListener implements HttpSessionListener{
    protected final Log log = LogFactory.getLog(super.getClass());
    public void sessionCreated(HttpSessionEvent event){
        this.log.error("session created. id = " + event.getSession().getId());
    }
    public void sessionDestroyed(HttpSessionEvent event){
        this.log.error("session destroyed.id = " + event.getSession().getId());
        HttpSession session = event.getSession();
        ApplicationContext context = WebApplicationContextUtils.getWebApplicationContext(session.getServletContext());
        OnlineUserMonitorClient client = (OnlineUserMonitorClient)context.getBean("onlineUserMonitorClient");
        client.afterSessionDestroyed(session);
    }
}

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

 

 

view plain copy print?

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{  
8.   
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.     }  
22.   
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. }  

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

    public static int TOTAL_ONLINE_USERS = 0;
    public void sessionCreated(HttpSessionEvent httpSessionEvent) {
        ServletContext servletContext = httpSessionEvent.getSession().getServletContext();
        TOTAL_ONLINE_USERS = (Integer) servletContext.getAttribute("TOTAL_ONLINE_USERS");
        // 如果用户退出，TOTAL_ONLINE_USERS自减1
        if(TOTAL_ONLINE_USERS == 0){
            servletContext.setAttribute("TOTAL_ONLINE_USERS", 1);
        }
        else{
            TOTAL_ONLINE_USERS--;
            servletContext.setAttribute("TOTAL_ONLINE_USERS", TOTAL_ONLINE_USERS);
        }
    }

    public void sessionDestroyed(HttpSessionEvent httpSessionEvent) {
        ServletContext servletContext = httpSessionEvent.getSession().getServletContext();
        TOTAL_ONLINE_USERS = (Integer) servletContext.getAttribute("TOTAL_ONLINE_USERS");
        // 如果用户登录，TOTAL_ONLINE_USERS自增1
        if(TOTAL_ONLINE_USERS == 0){
            servletContext.setAttribute("TOTAL_ONLINE_USERS", 1);
        }
        else{
            TOTAL_ONLINE_USERS++;
            servletContext.setAttribute("TOTAL_ONLINE_USERS", TOTAL_ONLINE_USERS);
        }
    }
}

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

 

 

view plain copy print?

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();  
19.       
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.     }  
27.   
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.     }  
35.   
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. }  

import java.util.LinkedList;
import java.util.List;
import java.util.Timer;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.http.HttpSession;
import javax.servlet.http.HttpSessionEvent;
import javax.servlet.http.HttpSessionListener;
import jeus.util.concurrent50.Collections;
/**
 * @description 当网站用户量增加时，session占用的内存会越来越大，这时session的管理，将会是一项很大的
 * 系统开销，为了高效的管理session，我们可以写一个监听器，定期清理掉过期的session
 */
public class SessionScanerListener implements HttpSessionListener,ServletContextListener{
    // 创建一个线程安全的集合，用来存储session
    @SuppressWarnings("unchecked")
    List<HttpSession> sessionList = Collections.synchronizedList(new LinkedList<HttpSession>());
    private Object lock = new Object();
    
    public void sessionCreated(HttpSessionEvent httpSessionEvent) {
        System.out.println("session 创建成功...");
        HttpSession httpSession = httpSessionEvent.getSession();
        synchronized (lock){
            sessionList.add(httpSession);
        }
    }

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

    // web应用启动时触发contextInitialized事件
    public void contextInitialized(ServletContextEvent servletContextEvent) {
        System.out.println("web应用初始化...");
        // 创建定时器
        Timer timer = new Timer();
        // 每隔30秒就定时执行任务
        timer.schedule(new MyTask(sessionList,lock), 0, 1000*30);
    }
}

view plain copy print?

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. }  

import java.util.List;
import java.util.ListIterator;
import java.util.TimerTask;
import javax.servlet.http.HttpSession;
/**
 * 定时器，定义定时任务的具体内容
 */
public class MyTask extends TimerTask{
    private List<HttpSession> list;
    // 存储传递过来的锁
    private Object lock;
    // 构造方法
    MyTask(List<HttpSession> list, Object lock){
        this.list = list;
        this.lock = lock;
    }
    @Override
    public void run() {
        // 考虑到多线程的情况，这里必须要同步
        synchronized (lock){
            System.out.println("定时器开始执行...");
            ListIterator<HttpSession> listIterator = list.listIterator();
            while(listIterator.hasNext()){
                HttpSession httpSession = listIterator.next();
                // httpSession.getLastAccessedTime() = session的最后访问时间
                if(System.currentTimeMillis() - httpSession.getLastAccessedTime() > 1000*30){
                    // 手动销毁session
                    httpSession.invalidate();
                    // 从集合中移除已经被销毁的session
                    listIterator.remove();
                }
            }
        }
    }
}