首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Spring的三大器之监听器

Spring的三大器之监听器

作者头像
一觉睡到小时候
发布2019-07-04 16:42:33
4.3K0
发布2019-07-04 16:42:33
举报
文章被收录于专栏:国产程序员国产程序员

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

按监听的对象划分,可以分为

· ServletContext对象监听器

· HttpSession对象监听器

· ServletRequest对象监听器

按监听的事件划分

· 对象自身的创建和销毁的监听器

· 对象中属性的创建和消除的监听器

· session中的某个对象的状态变化的监听器

首先来看一下ServletContextListener接口的源代码:

public abstractinterface ServletContextListenerextends EventListener{ public abstract void contextInitialized(ServletContextEventparamServletContextEvent); public abstract void contextDestroyed(ServletContextEventparamServletContextEvent); }

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

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中配置如下,很简单:

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

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

示例代码二:

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);
        }
    }
}  

示例代码三:

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扫描器。 --------------------- 应用一:统计当前在线人数---------------------

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++;              
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--;
        servletContext.setAttribute("TOTAL_ONLINE_USERS", TOTAL_ONLINE_USERS);
        }
    }
}  

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

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);
    }
}  
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();
                }
            }
        }
    }
}  

原文地址:https://blog.csdn.net/reggergdsg/article/details/52891311

本文参与 腾讯云自媒体分享计划,分享自微信公众号。
原始发表:2018-06-19,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 国产程序员 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
数据库
云数据库为企业提供了完善的关系型数据库、非关系型数据库、分析型数据库和数据库生态工具。您可以通过产品选择和组合搭建,轻松实现高可靠、高可用性、高性能等数据库需求。云数据库服务也可大幅减少您的运维工作量,更专注于业务发展,让企业一站式享受数据上云及分布式架构的技术红利!
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档