思享工具箱

12、JavaEE--Listener监听器

摘要：
侦听器侦听器基本侦听器简介侦听器是一个专门用于侦听和处理其他对象上的事件或状态更改的对象。此程序专门用于侦听另一个Java对象的方法调用或属性更改。由于资源利用或负载平衡原因（通过对象序列化），会话对象必须临时存储在硬盘或其他内存中时，硬盘或内存上的会话对象重新加载JVM时采取的操作称为激活。
监听器Listener

监听器基础

监听器介绍

监听器是一个专门用于对其他对象身上发生的事件或状态改变进行监听和相应处理的对象，当被监视的对象发生情况时，立即采取相应的行动。监听器其实就是一个实现特定接口

的普通java程序，这个程序专门用于监听另一个java对象的方法调用或属性改变，当被监听对象发生上述事件后，监听器某个方法立即被执行。

12、JavaEE--Listener监听器第1张

Servlet规范中的八大监听器如下：

名称描述
ServletContextListener在Container加载Web应用程序时（例如启动 Container之后），会呼叫contextInitialized()，而当容器移除Web应用程序时，会呼叫contextDestroyed ()方法。
HttpSessionListener在session （HttpSession）对象建立或被消灭时，会分别呼叫这两个方法。
HttpSessionActivationListenerctivate与Passivate是用于置换对象的动作，当session对象为了资源利用或负载平衡等原因而必须暂时储存至硬盘或其它储存器时（透 过对象序列化），所作的动作称之为Passivate，而硬盘或储存器上的session对象重新加载JVM时所采的动作称之为Activate，所以容 易理解的，sessionDidActivate()与 sessionWillPassivate()分别于Activeate后与将Passivate前呼叫。
ServletRequestListener在request（HttpServletRequest）对象建立或被消灭时，会分别呼叫这两个方法。
ServletContextAttributeListener若有对象加入为application（ServletContext）对象的属性，则会呼叫attributeAdded()，同理在置换属性与移除属性时，会分别呼叫attributeReplaced()、attributeRemoved()。
HttpSessionAttributeListener有对象加入为session（HttpSession）对象的属性，则会呼叫attributeAdded()，同理在置换属性与移除属性时，会分别呼叫attributeReplaced()、 attributeRemoved()。
ServletRequestAttributeListener若有对象加入为request（HttpServletRequest）对象的属性，则会呼叫attributeAdded()，同理在置换属性与移除属性时，会分别呼叫attributeReplaced()、 attributeRemoved()。
HttpSessionBindingListener实现HttpSessionBindingListener接 口的类别，其实例如果被加入至session（HttpSession）对象的属性中，则会呼叫 valueBound()，如果被从session（HttpSession）对象的属性中移除，则会呼叫valueUnbound()，实现 HttpSessionBindingListener接口的类别不需在web.xml中设定。

实现上面这几个接口的类别，除了HttpSessionBindingListener外,必须在web.xml中向容器注册，容器才会在对应的事件发生时呼叫对应的类别，如：

<listener>
    <description>XXX监听器</description>
    <listener-class>com.legend.listener.XXXListener</listener-class>
</listener>
  • 监听window窗口事件
public class Demo1 {
    /**
     *java的事件监听机制
     *1、事件监听涉及到三个组件：事件源、事件对象、事件监听器
     *2、当事件源上发生某一个动作时，它会调用事件监听器的一个方法，并在调用该方法时把事件对象传递进去，
     *    开发人员在监听器中通过事件对象，就可以拿到事件源，从而对事件源进行操作。
     */
    public static void main(String[] args) {
        
        Frame f = new Frame();
        f.setSize(400, 400);
        f.setVisible(true);
        
        //注册事件监听器
        f.addWindowListener(new WindowListener(){
            public void windowActivated(WindowEvent e) { }
            public void windowClosed(WindowEvent e) { }
            /**
             * 当window窗体关闭时就会WindowListener这个监听器监听到，
             * 监听器就会调用windowClosing方法处理window窗体关闭时的动作
             */
            public void windowClosing(WindowEvent e) {
                //通过事件对象e来获取事件源对象
                Frame f = (Frame) e.getSource();
                System.out.println(f+"窗体正在关闭");
                f.dispose();
            }
            public void windowDeactivated(WindowEvent e) { }
            public void windowDeiconified(WindowEvent e) { }
            public void windowIconified(WindowEvent e) { }
            public void windowOpened(WindowEvent e) { }
        });
    }
}

  • 设计一个可以被别的对象监听的对象

    我们平时做开发的时候，我们是写监听器去监听其他对象，那么我们如果想设计一个对象，让这个对象可以被别的对象监听又该怎么做呢，可以按照严格的事件处理模型来设计一

个对象，这个对象就可以被别的对象监听，事件处理模型涉及到三个组件：事件源、事件对象、事件监听器。

下面我们来按照事件处理模型来设计一个Person对象，具体代码如下：

public class Person {
    private PersonListener mListener;
    public void eat() {
        if (mListener != null) {
            mListener.doeat(new Event(this));
        }
    }
    public void run() {
        if (mListener != null) {
            mListener.dorun(new Event(this));
        }
    }
    public void registListener(PersonListener listener) {
        this.mListener = listener;
    }
    public interface PersonListener {
        // 监听Person对象eat(吃)这个行为动作
        void doeat(Event e);
        // 监听Person对象run(跑)这个行为动作
        void dorun(Event e);
    }
    class Event {
        private Person mPerson;
        public Event(Person person) {
            mPerson = person;
        }
        public Person getPerson() {
            return mPerson;
        }
        public void setPerson(Person person) {
            mPerson = person;
        }
    }
}

经过这样的设计之后，Peron类的对象就是可以被其他对象监听了。测试代码如下：

public class PersonTest {
    public static void main(String[] args) {
        Person person = new Person();
        person.registListener(new Person.PersonListener() {
            @Override
            public void doeat(Person.Event e) {
                Person p = e.getPerson();
                System.out.println(e + "在吃东西");
            }
            @Override
            public void dorun(Person.Event e) {
                Person p = e.getPerson();
                System.out.println(p + "在跑步");
            }
        });
        person.eat();
        person.run();
    }
}

运行结果：

com.legend.listener.Person$Event@1b6d3586在吃东西
com.legend.listener.Person@4554617c在跑步

JavaWeb监听器

JavaWeb中的监听器是Servlet规范中定义的一种特殊类，它用于监听web应用程序中的ServletContext, HttpSession和 ServletRequest等域对象的创建与销毁事件，

以及监听这些域对象中的属性发生修改的事件。

在Servlet规范中定义了多种类型的监听器，它们用于监听的事件源分别为ServletContext，HttpSession和ServletRequest这三个域对象

Servlet规范针对这三个对象上的操作，又把多种类型的监听器划分为三种类型：

监听域对象自身的创建和销毁的事件监听器。
监听域对象中的属性的增加和删除的事件监听器。
监听绑定到HttpSession域中的某个对象的状态的事件监听器

  • 监听ServletContext域对象的创建和销毁

    ServletContextListener接口用于监听ServletContext对象的创建和销毁事件。实现了ServletContextListener接口的类都可以对ServletContext对象的创建和销毁进行监听。

当ServletContext对象被创建时，激发contextInitialized (ServletContextEvent sce)方法。
当ServletContext对象被销毁时，激发contextDestroyed(ServletContextEvent sce)方法。

ServletContext域对象创建和销毁时机：

创建：服务器启动针对每一个Web应用创建ServletContext
销毁：服务器关闭前先关闭代表每一个web应用的ServletContext

范例：编写一个MyServletContextListener类，实现ServletContextListener接口，监听ServletContext对象的创建和销毁

1、编写监听器，代码如下所示：

// MyServletContextListener类实现了ServletContextListener接口，
// 因此可以对ServletContext对象的创建和销毁这两个动作进行监听。
public class MyServletContextListener implements ServletContextListener {
    @Override
    public void contextInitialized(ServletContextEvent servletContextEvent) {
        System.out.println("ServletContext对象创建");
    }
    @Override
    public void contextDestroyed(ServletContextEvent servletContextEvent) {
        System.out.println("ServletContext对象销毁");
    }
}

2、在web.xml文件中注册监听器

<listener>
    <description>ServletContextListener监听器</description>
    <listener-class>com.legend.listener.MyServletContextListener</listener-class>
</listener>

经过这两个步骤，我们就完成了监听器的编写和注册，Web服务器在启动时，就会自动把在web.xml中配置的监听器注册到ServletContext对象上，这样开发好的

MyServletContextListener监听器就可以对ServletContext对象进行监听了。

  • 监听HttpSession域对象的创建和销毁

    HttpSessionListener 接口用于监听HttpSession对象的创建和销毁

创建一个Session时，激发sessionCreated (HttpSessionEvent se) 方法
销毁一个Session时，激发sessionDestroyed (HttpSessionEvent se) 方法。

范例：编写一个MyHttpSessionListener类，实现HttpSessionListener接口，监听HttpSession对象的创建和销毁

1、编写监听器，代码如下：

public class MyHttpSessionListener implements HttpSessionListener {
    @Override
    public void sessionCreated(HttpSessionEvent httpSessionEvent) {
        System.out.println(httpSessionEvent.getSession() + "创建了！！");
        System.out.println("创建好的HttpSession的id是：" + httpSessionEvent.getSession().getId());
    }
    /**
     *  HttpSession的销毁时机需要在web.xml中进行配置，如下：
     *<session-config>
     *      <session-timeout>1</session-timeout>
     * </session-config>
     * 这样配置就表示session在1分钟之后就被销毁
     */
    @Override
    public void sessionDestroyed(HttpSessionEvent httpSessionEvent) {
        System.out.println("session销毁了！！");
    }
}

2、在web.xml文件中注册监听器

<listener>
    <description>HttpSessionListener监听器</description>
    <listener-class>com.legend.listener.MyHttpSessionListener</listener-class>
</listener>
<!--配置HttpSession的销毁时机-->
<session-config>
    <session-timeout>1</session-timeout>
</session-config>

当我们访问jsp页面时，HttpSession对象就会创建，我们可以写一个jsp页面观察HttpSession对象创建的过程。

<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<html>
    <head>
        <title>HttpSessionListener监听器监听HttpSession对象的创建</title>
    </head>
    <body>
        访问JSP页面，HttpSession就创建了，创建好的Session的Id是：
        ${pageContext.session.id}
    </body>
</html>

输出结果：

访问JSP页面，HttpSession就创建了，创建好的Session的Id是： C37790FDA59BE34E76F219D25725F447

  • 监听ServletRequest域对象的创建和销毁

    ServletRequestListener接口用于监听ServletRequest 对象的创建和销毁

Request对象被创建时，监听器的requestInitialized(ServletRequestEvent sre)方法将会被调用
Request对象被销毁时，监听器的requestDestroyed(ServletRequestEvent sre)方法将会被调用

范例：编写一个MyServletRequestListener类，实现ServletRequestListener接口，监听ServletRequest对象的创建和销毁

1、编写监听器，代码如下：

public class MyServletRequestListener implements ServletRequestListener {
    @Override
    public void requestDestroyed(ServletRequestEvent sre) {
        System.out.println(sre.getServletRequest() + "销毁了！！");
        
    }
    @Override
    public void requestInitialized(ServletRequestEvent sre) {
        System.out.println(sre.getServletRequest() + "创建了！！");
    }
}

2、在web.xml文件中注册监听器

<!--注册针对ServletRequest对象进行监听的监听器-->
<listener>
     <description>ServletRequestListener监听器</description>
     <listener-class>me.gacl.web.listener.MyServletRequestListener</listener-class>
</listener>

域对象属性监听

域对象中属性的变更的事件监听器就是用来监听 ServletContext, HttpSession, HttpServletRequest 这三个对象中的属性变更信息事件的监听器。

这三个监听器接口分别是ServletContextAttributeListener, HttpSessionAttributeListener 和ServletRequestAttributeListener，这三个接口中都定义了三个方

法来处理被监听对象中的属性的增加，删除和替换的事件，同一个事件在这三个接口中对应的方法名称完全相同，只是接受的参数类型不同。

  • attributeAdded方法

    当向被监听对象中增加一个属性时，web容器就调用事件监听器的attributeAdded方法进行响应，这个方法接收一个事件类型的参数，监听器可以通过这个参数

来获得正在增加属性的域对象和被保存到域中的属性对象
各个域属性监听器中的完整语法定义为：

public void attributeAdded(ServletContextAttributeEvent scae)
public void attributeReplaced(HttpSessionBindingEvent hsbe)
public void attributeRmoved(ServletRequestAttributeEvent srae)

  • attributeRemoved方法

    当删除被监听对象中的一个属性时，web容器调用事件监听器的attributeRemoved方法进行响应各个域属性监听器中的完整语法定义为：

public void attributeRemoved(ServletContextAttributeEvent scae)
public void attributeRemoved (HttpSessionBindingEvent hsbe)
public void attributeRemoved (ServletRequestAttributeEvent srae)

  • attributeReplaced方法

    当监听器的域对象中的某个属性被替换时，web容器调用事件监听器的attributeReplaced方法进行响应，各个域属性监听器中的完整语法定义为：

public void attributeReplaced(ServletContextAttributeEvent scae)
public void attributeReplaced (HttpSessionBindingEvent hsbe)
public void attributeReplaced (ServletRequestAttributeEvent srae)

  • ServletContextAttributeListener监听器范例

    编写ServletContextAttributeListener监听器监听ServletContext域对象的属性值变化情况，代码如下：

public class MyServletContextAttributeListener implements
        ServletContextAttributeListener {
    @Override
    public void attributeAdded(ServletContextAttributeEvent servletContextAttributeEvent) {
        String str = MessageFormat.format("ServletContext域对象中添加属性：{0}, 属性值是：{1}"
        , servletContextAttributeEvent.getName(), servletContextAttributeEvent.getValue());
        System.out.println(str);
    }
    @Override
    public void attributeRemoved(ServletContextAttributeEvent servletContextAttributeEvent) {
        String str = MessageFormat.format("ServletContext域对象中删除属性：{0}， 属性值是：{1}",
                servletContextAttributeEvent.getName(), servletContextAttributeEvent.getValue());
        System.out.println(str);
    }
    @Override
    public void attributeReplaced(ServletContextAttributeEvent servletContextAttributeEvent) {
        String str = MessageFormat.format("ServletContext域对象中替换了属性：{0}的值",
                servletContextAttributeEvent.getName());
        System.out.println(str);
    }
}

在web.xml文件中注册监听器

<listener>
    <description>MyServletContextAttributeListener监听器</description>
    <listener-class>com.legend.listener.MyServletContextAttributeListener</listener-class>
</listener>

编写ServletContextAttributeListenerTest.jsp测试页面

<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<html>
    <head>
        <title>ServletContextAttributeListener监听器测试</title>
    </head>
    <body>
        <%
            // 往application域对象添加属性
            application.setAttribute("name", "legend");
            // 替换application对象中name属性值
            application.setAttribute("name", "vincent");
            // 移除application域对象中name属性
            application.removeAttribute("name");
        %>
    </body>
</html>

输出结果：

ServletContext域对象中添加属性：name, 属性值是：legend
ServletContext域对象中替换了属性：name的值
ServletContext域对象中删除属性：name， 属性值是：vincent

从运行结果中可以看到，ServletContextListener监听器成功监听到了ServletContext域对象(application)中的属性值的变化情况。

  • ServletRequestAttributeListener和HttpSessionAttributeListener监听器范例

    编写监听器监听HttpSession和HttpServletRequest域对象的属性值变化情况，代码如下：

public class MyRequestAndSessionAttributeListener implements
        HttpSessionAttributeListener, ServletRequestAttributeListener {
    @Override
    public void attributeAdded(HttpSessionBindingEvent httpSessionBindingEvent) {
        String str = MessageFormat.format("ServletRequest域对象中添加了属性{0}, 属性值是：{1}",
                httpSessionBindingEvent.getName(), httpSessionBindingEvent.getValue());
        System.out.println(str);
    }
    @Override
    public void attributeRemoved(HttpSessionBindingEvent httpSessionBindingEvent) {
        String str = MessageFormat.format("ServletRequest域对象中删除属性{0}, 属性值是：{1}",
                httpSessionBindingEvent.getName(), httpSessionBindingEvent.getValue());
        System.out.println(str);
    }
    @Override
    public void attributeReplaced(HttpSessionBindingEvent httpSessionBindingEvent) {
        String str = MessageFormat.format("ServletRequest域对象替换属性{0}的值",
                httpSessionBindingEvent.getName());
        System.out.println(str);
    }
    @Override
    public void attributeAdded(ServletRequestAttributeEvent servletRequestAttributeEvent) {
        String str = MessageFormat.format("HttpSession域对象中添加了属性{0}, 属性值是：{1}",
                servletRequestAttributeEvent.getName(), servletRequestAttributeEvent.getValue());
        System.out.println(str);
    }
    @Override
    public void attributeRemoved(ServletRequestAttributeEvent servletRequestAttributeEvent) {
        String str = MessageFormat.format("HttpSession域对象中添加了属性{0}, 属性值是：{1}",
                servletRequestAttributeEvent.getName(), servletRequestAttributeEvent.getValue());
        System.out.println(str);
    }
    @Override
    public void attributeReplaced(ServletRequestAttributeEvent servletRequestAttributeEvent) {
        String str = MessageFormat.format("HttpSession域对象替换属性{0}的值",
                servletRequestAttributeEvent.getName());
        System.out.println(str);
    }
}

在web.xml文件中注册监听器

<listener>
    <description>MyRequestAndSessionAttributeListener监听器</description>
    <listener-class>com.legend.listener.MyRequestAndSessionAttributeListener</listener-class>
</listener>

编写RequestAndSessionAttributeListenerTest.jsp测试页面

<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<html>
    <head>
        <title>Title</title>
    </head>
    <body>
        <%
            // 往session域对象中添加属性
            session.setAttribute("name", "legend");
            // 替换session域对象中的属性
            session.setAttribute("name", "vincent");
            // 移除session域对象中的属性
            session.removeAttribute("name");
            // 往request域对象中添加属性
            request.setAttribute("name", "legend");
            // 替换request域对象中的属性
            request.setAttribute("name", "vincent");
            // 移除request域对象中的属性
            request.removeAttribute("name");
        %>
    </body>
</html>

运行结果：

ServletRequest域对象中添加了属性name, 属性值是：legend
ServletRequest域对象替换属性name的值
ServletRequest域对象中删除属性name, 属性值是：vincent
HttpSession域对象中添加了属性name, 属性值是：legend
HttpSession域对象替换属性name的值
HttpSession域对象中添加了属性name, 属性值是：vincent

从结果中可以看到，HttpSessionAttributeListener和ServletRequestAttributeListener成功监听到HttpSession域对象和HttpServletRequest域对象的属性值变化情况。

Session绑定事件监听

保存在Session域中的对象可以有多种状态：

绑定(session.setAttribute("bean",Object))到Session中；
从 Session域中解除(session.removeAttribute("bean"))绑定；
随Session对象持久化到一个存储设备中；随Session对象从一个存储设备中恢复

Servlet 规范中定义了两个特殊的监听器接口"HttpSessionBindingListener和HttpSessionActivationListener"来帮助JavaBean 对象了解自己在Session域中的这些状态：

实现这两个接口的类不需要 web.xml 文件中进行注册。

  • HttpSessionBindingListener接口

    实现了HttpSessionBindingListener接口的JavaBean对象可以感知自己被绑定到Session中和 Session中删除的事件

当对象被绑定到HttpSession对象中时，web服务器调用该对象的void valueBound(HttpSessionBindingEvent event)方法
当对象从HttpSession对象中解除绑定时，web服务器调用该对象的void valueUnbound(HttpSessionBindingEvent event)方法

范例：

public class JavaBeanDemo1 implements HttpSessionBindingListener {
    private String name;
    @Override
    public void valueBound(HttpSessionBindingEvent httpSessionBindingEvent) {
        System.out.println(name + "被加到session中了");
    }
    @Override
    public void valueUnbound(HttpSessionBindingEvent httpSessionBindingEvent) {
        System.out.println(name + "被session移除了");
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public JavaBeanDemo1(String name) {
        this.name = name;
    }
}

上述的JavaBeanDemo1这个javabean实现了HttpSessionBindingListener接口，那么这个JavaBean对象可以感知自己被绑定到Session中和从Session中删除的这两个操作，

测试代码如下：

<%@ page contentType="text/html;charset=UTF-8" language="java" %>
<%@page import="com.legend.listener.JavaBeanDemo1" %>
<html>
    <head>
        <title>Title</title>
    </head>
    <body>
        <%
            // 将javabean对象绑定到session中
            session.setAttribute("bean", new JavaBeanDemo1("legend"));
            // 从session中删除javabean对象
            session.removeAttribute("bean");
        %>
    </body>
</html>

输出结果：

legend被加到session中了
legend被session移除了

  • HttpSessionActivationListener接口

    实现了HttpSessionActivationListener接口的JavaBean对象可以感知自己被活化(反序列化)和钝化(序列化)的事件

当绑定到HttpSession对象中的javabean对象将要随HttpSession对象被钝化(序列化)之前，web服务器调用该
javabean对象的void sessionWillPassivate(HttpSessionEvent event) 方法。这样javabean对象就可以知道
自己将要和HttpSession对象一起被序列化(钝化)到硬盘中.
当绑定到HttpSession对象中的javabean对象将要随HttpSession对象被活化(反序列化)之后，web服务器调用
该javabean对象的void sessionDidActive(HttpSessionEvent event)方法。这样javabean对象就可以知道自己
将要和 HttpSession对象一起被反序列化(活化)回到内存中

范例：

public class JavaBeanDemo2 implements HttpSessionActivationListener {
    private static final long serialVersionUID = 7589841135210272124L;
    private String name;
    @Override
    public void sessionWillPassivate(HttpSessionEvent httpSessionEvent) {
        System.out.println(name + "和session一起被序列化(钝化)到硬盘了，session的id是："
                + httpSessionEvent.getSession().getId());
    }
    @Override
    public void sessionDidActivate(HttpSessionEvent httpSessionEvent) {
        System.out.println(name+"和session一起从硬盘反序列化(活化)回到内存了，session的id是："
                + httpSessionEvent.getSession().getId());
    }
    public JavaBeanDemo2(String name) {
        this.name = name;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
}

为了观察绑定到HttpSession对象中的javabean对象随HttpSession对象一起被钝化到硬盘上和从硬盘上重新活化回到内存中的的过程，我们需要借助tomcat服务器帮助

我们完成HttpSession对象的钝化和活化过程，具体做法如下：

在WebRootMETA-INF文件夹下创建一个context.xml文件，如下所示：

<Context>
    <Manager className="org.apache.catalina.session.PersistentManager" maxIdleSwap="1">
    <Store className="org.apache.catalina.session.FileStore" directory="gacl"/>
    </Manager>
</Context>

在context.xml文件文件中配置了1分钟之后就将HttpSession对象钝化到本地硬盘的一个文件夹中。

jsp测试代码如下：

<%@ page language="java" pageEncoding="UTF-8"%>
<%@page import="com.legend.listener.JavaBeanDemo2"%>
<!DOCTYPE HTML>
<html>
  <head>
    <title></title>
  </head>
  
  <body>
      访问JSP页面，HttpSession就创建了，创建好的Session的Id是：${pageContext.session.id}<hr/>
   <% 
        session.setAttribute("bean",new JavaBeanDemo2("legend"));
    %>
  </body>
</html>

访问这个jsp页面，服务器就会马上创建一个HttpSession对象，然后将实现了HttpSessionActivationListener接口的JavaBean对象绑定到session对象中，这个jsp页面在

等待1分钟之后没有人再次访问，那么服务器就会自动将这个HttpSession对象钝化(序列化)到硬盘上

当再次访问这个Jsp页面时，服务器又会自动将已经钝化(序列化)到硬盘上HttpSession对象重新活化(反序列化)回到内存中。

Listener常见应用

统计在线人数

在JavaWeb应用开发中，有时候我们需要统计当前在线的用户数，此时就可以使用监听器技术来实现这个功能了。

public class OnLineCountListener implements HttpSessionListener {
    @Override
    public void sessionCreated(HttpSessionEvent httpSessionEvent) {
        ServletContext context =
                httpSessionEvent.getSession().getServletContext();
        Integer onLineCount = (Integer) context.getAttribute("onLineCount");
        if (onLineCount == null) {
            context.setAttribute("onLineCount", 1);
        }else {
            onLineCount++;
            context.setAttribute("onLineCount", onLineCount);
        }
    }
    @Override
    public void sessionDestroyed(HttpSessionEvent httpSessionEvent) {
        ServletContext context = httpSessionEvent.getSession().getServletContext();
        Integer onLineCount = (Integer) context.getAttribute("onLineCount");
        if (onLineCount == null) {
            context.setAttribute("onLineCount", 1);
        }else {
            onLineCount--;
            context.setAttribute("onLineCount", onLineCount);
        }
    }
}

自定义Session扫描器

当一个Web应用创建的Session很多时，为了避免Session占用太多的内存，我们可以选择手动将这些内存中的session销毁，那么此时也可以借助监听器技术来实现。

public class SessionScanerListener implements HttpSessionListener,ServletContextListener {
    /**
    * @Field: list
    *          定义一个集合存储服务器创建的HttpSession
    *        LinkedList不是一个线程安全的集合
    */ 
    /**
     * private List<HttpSession> list = new LinkedList<HttpSession>();
     * 这样写涉及到线程安全问题,SessionScanerListener对象在内存中只有一个
     * sessionCreated可能会被多个人同时调用，
     * 当有多个人并发访问站点时，服务器同时为这些并发访问的人创建session
     * 那么sessionCreated方法在某一时刻内会被几个线程同时调用，几个线程并发调用sessionCreated方法
     * sessionCreated方法的内部处理是往一个集合中添加创建好的session，那么在加session的时候就会
     * 涉及到几个Session同时抢夺集合中一个位置的情况，所以往集合中添加session时，一定要保证集合是线程安全的才行
     * 如何把一个集合做成线程安全的集合呢？
     * 可以使用使用 Collections.synchronizedList(List<T> list)方法将不是线程安全的list集合包装线程安全的list集合
     */
    //使用 Collections.synchronizedList(List<T> list)方法将LinkedList包装成一个线程安全的集合
    private List<HttpSession> list = Collections.synchronizedList(new LinkedList<HttpSession>());
    //定义一个对象，让这个对象充当一把锁，用这把锁来保证往list集合添加的新的session和遍历list集合中的session这两个操作达到同步
    private Object lock = new Object();
            
    @Override
    public void sessionCreated(HttpSessionEvent se) {
        System.out.println("session被创建了!!");
        HttpSession session = se.getSession();
        
        synchronized (lock){
            /**
             *将该操作加锁进行锁定，当有一个thread-1(线程1)在调用这段代码时，会先拿到lock这把锁，然后往集合中添加session，
             *在添加session的这个过程中假设有另外一个thread-2(线程2)来访问了，thread-2可能是执行定时器任务的，
             *当thread-2要调用run方法遍历list集合中的session时，结果发现遍历list集合中的session的那段代码被锁住了，
             *而这把锁正在被往集合中添加session的那个thread-1占用着，因此thread-2只能等待thread-1操作完成之后才能够进行操作
             *当thread-1添加完session之后，就把lock放开了，此时thread-2拿到lock，就可以执行遍历list集合中的session的那段代码了
             *通过这把锁就保证了往集合中添加session和变量集合中的session这两步操作不能同时进行，必须按照先来后到的顺序来进行。
             */
            list.add(session);
        }
    }
    @Override
    public void sessionDestroyed(HttpSessionEvent se) {
        System.out.println("session被销毁了了!!");
    }
    /* Web应用启动时触发这个事件
     * @see javax.servlet.ServletContextListener#contextInitialized(javax.servlet.ServletContextEvent)
     */
    @Override
    public void contextInitialized(ServletContextEvent sce) {
        System.out.println("web应用初始化");
        //创建定时器
        Timer timer = new Timer();
        //每隔30秒就定时执行任务
        timer.schedule(new MyTask(list,lock), 0, 1000*30);
    }
    @Override
    public void contextDestroyed(ServletContextEvent sce) {
        System.out.println("web应用关闭");
    }
}
class MyTask extends TimerTask {
        
    //存储HttpSession的list集合
    private List<HttpSession> list;
    //存储传递过来的锁
    private Object lock;
    public MyTask(List<HttpSession> list,Object lock){
        this.list = list;
        this.lock = lock;
    }
    /* run方法指明了任务要做的事情
     * @see java.util.TimerTask#run()
     */
    @Override
    public void run() {
            //将该操作加锁进行锁定
        synchronized (lock) {
            System.out.println("定时器执行！！");
            ListIterator<HttpSession> it = list.listIterator();
            /**
             * 迭代list集合中的session，在迭代list集合中的session的过程中可能有别的用户来访问，
             * 用户一访问，服务器就会为该用户创建一个session,此时就会调用sessionCreated往list集合中添加新的session，
             * 然而定时器在定时执行扫描遍历list集合中的session时是无法知道正在遍历的list集合又添加的新的session进来了，
             * 这样就导致了往list集合添加的新的session和遍历list集合中的session这两个操作无法达到同步
             * 那么解决的办法就是把"list.add(session)和while(it.hasNext()){//迭代list集合}"这两段代码做成同步，
             * 保证当有一个线程在访问"list.add(session)"这段代码时，另一个线程就不能访问"while(it.hasNext()){//迭代list集合}"这段代码
             * 为了能够将这两段不相干的代码做成同步，只能定义一把锁(Object lock)，然后给这两步操作加上同一把锁，
             * 用这把锁来保证往list集合添加的新的session和遍历list集合中的session这两个操作达到同步
             * 当在执行往list集合添加的新的session操作时，就必须等添加完成之后才能够对list集合进行迭代操作，
             * 当在执行对list集合进行迭代操作时，那么必须等到迭代操作结束之后才能够往往list集合添加的新的session
             */
            while(it.hasNext()){
                HttpSession session = (HttpSession) it.next();
                /**
                 * 如果当前时间-session的最后访问时间>1000*15(15秒)
                 * session.getLastAccessedTime()获取session的最后访问时间
                 */
                if(System.currentTimeMillis()-session.getLastAccessedTime()>1000*30){
                    //手动销毁session
                    session.invalidate();
                    //移除集合中已经被销毁的session
                    it.remove();
                }
            }
        }
    }
}

标签：#对象#事件#监听器#动作 | 浏览：173 | 发布日期：

免责声明：文章转载自《12、JavaEE--Listener监听器》仅用于学习参考。如对内容有疑问，请及时联系本站处理。

上篇Mybatis中的Mapper.xml映射文件sql查询接收多个参数iOS -NSOperation并发编程下篇

宿迁高防，2C2G15M，22元/月；香港BGP，2C5G5M，25元/月 雨云优惠码：MjYwNzM=

相关文章

c#.net 生成清晰缩略图的解决方案

Bitmap类的GetThumbnailImage方法可以从指定的图像文件中生成缩略图，但是这种方式生成的缩略图清晰度不稳定，有时生成的缩略图的质量很差——模糊不清！ 为什么会这样？为什么生成的图片是模糊的？ 像JPEG这样格式的图像可能把缩略图存在同一个文件中。如果我们使用System.Drawing.Bitmap的GetThumbnailImage方法...

NSURLSession的基本使用

一、简单说明 　　在iOS9.0之后，以前使用的NSURLConnection过期，苹果推荐使用NSURLSession来替换NSURLConnection完成网路请求相关操作。 　　NSURLSession的使用非常简单，先根据会话对象创建一个请求Task，然后执行该Task即可。 　　NSURLSessionTask本身是一个抽象类，在使用的时候，通常...

java的四种引用，强弱软虚和jvm优化

1、强引用（StrongReference）强引用是使用最普遍的引用。如果一个对象具有强引用，那垃圾回收器绝不会回收它。如下：  Object o=new Object();   //  强引用 当内存空间不足，Java虚拟机宁愿抛出OutOfMemoryError错误，使程序异常终止，也不会靠随意回收具有强引用的对象来解决内存不足的问题。如果不使用时，...

Windows编程系列：Windows中的消息

win32控制台程序 控制台程序整个执行过程是按照代码的顺序依次执行，到main函数的结束，标志着整个程序的退出。 1 int main() 2 { 3 4 return 0; 5 } 整个过程可以描述为以下： Windows应用程序 Windows应用程序会响应来自用户和操作系统的事件。 来自用户的事件包括：鼠标单击，按键，触摸屏手势...

浅析Android动画（二），属性动画高级实例探究

转载请注明出处！http://www.cnblogs.com/wondertwo/p/5312482.html ObjectAnimator实现属性动画 为了写好Android动画这几篇博客，在动笔之前我是下过很大决心的，我对自己的要求是尽量把一个小知识点写清楚写明白，说白了就是相对于大而全的长篇大论，我更倾向于去写小而美的博客！为了保证在高产的同时能坚...

Mybatis的@Options注解

mybatis的@Options注解能够设置缓存时间，能够为对象生成自增的key 第一个使用场景： 有一个表 CREATE TABLE instance ( instance_id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT COMMENT '主键id', infos VARCHAR(2048) NOT NULL D...

最新文章

随机推荐

思享工具箱导航