posts - 14,  comments - 37,  trackbacks - 0
由于工作需要,最近在找一些解决方案,发现Listener是一个很好的东西,

能够监听到session,application的create,destroy,可以监听到session,application

 属性绑定的变化,考虑了一下,可以应用在"在线人数统计","数据缓存"等各个方面,

下面是整理的一些资料.


Listener是Servlet的监听器,它可以监听客户端的请求、服务端的操作等。通过监听器,可以自动激发一些操作,比如监听在线的 用户的数量。当增加一个HttpSession时,就激发sessionCreated(HttpSessionEvent se)方法,这样就可以给在线人数加1。常用的监听接口有以下几个:

ServletContextAttributeListener监听对ServletContext属性的操作,比如增加、删除、修改属性。

ServletContextListener监听ServletContext。当创建ServletContext时,激发 contextInitialized(ServletContextEvent sce)方法;当销毁ServletContext时,激发contextDestroyed(ServletContextEvent sce)方法。

HttpSessionListener监听HttpSession的操作。当创建一个Session时,激发session Created(HttpSessionEvent se)方法;当销毁一个Session时,激发sessionDestroyed (HttpSessionEvent se)方法。

HttpSessionAttributeListener监听HttpSession中的属性的操作。当在Session增加一个属性时,激发 attributeAdded(HttpSessionBindingEvent se) 方法;当在Session删除一个属性时,激发attributeRemoved(HttpSessionBindingEvent se)方法;当在Session属性被重新设置时,激发attributeReplaced(HttpSessionBindingEvent se) 方法。

下面我们开发一个具体的例子,这个监听器能够统计在线的人数。在ServletContext初始化和销毁时,在服务器控制台打印对应的信息。当ServletContext里的属性增加、改变、删除时,在服务器控制台打印对应的信息。

要获得以上的功能,监听器必须实现以下3个接口:

HttpSessionListener

ServletContextListener

ServletContextAttributeListener

我们看具体的代码,见示例14-9。

【程序源代码】

 1// ==================== Program Discription =====================
 2// 程序名称:示例14-9 : EncodingFilter .java
 3// 程序目的:学习使用监听器
 4// ==============================================================
 5import javax.servlet.http.*;
 6import javax.servlet.*;
 7
 8public class OnLineCountListener implements HttpSessionListener, ServletContextListener,
 9        ServletContextAttributeListener
10{
11    private int count;
12
13    private ServletContext context = null;
14
15    public OnLineCountListener()
16    {
17        count = 0;
18        // setContext();
19    }

20
21    // 创建一个session时激发
22    public void sessionCreated(HttpSessionEvent se)
23    {
24        count++;
25        setContext(se);
26
27    }

28
29    // 当一个session失效时激发
30    public void sessionDestroyed(HttpSessionEvent se)
31    {
32        count--;
33        setContext(se);
34    }

35
36    // 设置context的属性,它将激发attributeReplaced或attributeAdded方法
37    public void setContext(HttpSessionEvent se)
38    {
39        se.getSession().getServletContext().setAttribute("onLine"new Integer(count));
40    }

41
42    // 增加一个新的属性时激发
43    public void attributeAdded(ServletContextAttributeEvent event)
44    {
45
46        log("attributeAdded('" + event.getName() + "', '" + event.getValue() + "')");
47
48    }

49
50    // 删除一个新的属性时激发
51    public void attributeRemoved(ServletContextAttributeEvent event)
52    {
53
54        log("attributeRemoved('" + event.getName() + "', '" + event.getValue() + "')");
55
56    }

57
58    // 属性被替代时激发
59    public void attributeReplaced(ServletContextAttributeEvent event)
60    {
61
62        log("attributeReplaced('" + event.getName() + "', '" + event.getValue() + "')");
63    }

64
65    // context删除时激发
66    public void contextDestroyed(ServletContextEvent event)
67    {
68
69        log("contextDestroyed()");
70        this.context = null;
71
72    }

73
74    // context初始化时激发
75    public void contextInitialized(ServletContextEvent event)
76    {
77
78        this.context = event.getServletContext();
79        log("contextInitialized()");
80
81    }

82
83    private void log(String message)
84    {
85
86        System.out.println("ContextListener: " + message);
87    }

88}

89

【程序注解】
在OnLineCountListener里,用count代表当前在线的人数,OnLineCountListener将在 Web服务器启动时自动执行。当OnLineCountListener构造好后,把count设置为0。每增加一个Session, OnLineCountListener会自动调用sessionCreated(HttpSessionEvent se)方法;每销毁一个Session,OnLineCountListener会自动调用sessionDestroyed (HttpSessionEvent se)方法。当调用sessionCreated(HttpSessionEvent se)方法时,说明又有一个客户在请求,此时使在线的人数(count)加1,并且把count写到ServletContext中。 ServletContext的信息是所有客户端共享的,这样,每个客户端都可以读取到当前在线的人数。
 

 


从作用域范围来说,Servlet的作用域有ServletContext,HttpSession,ServletRequest.

Context范围:

ServletContextListener:
对一个应用进行全局监听.随应用启动而启动,随应用消失而消失主要有两个方法:

contextDestroyed(ServletContextEvent event)

在应用关闭的时候调用

contextInitialized(ServletContextEvent event)

在应用启动的时候调用

这个监听器主要用于一些随着应用启动而要完成的工作,也就是很多人说的我想在容器
启动的时候干..........
一般来说对"全局变量"初始化,如

public void contextInitialized(ServletContextEvent event){
ServletContex sc = event.getServletContext();
sc.setAttribute(name,value);
}

以后你就可以在任何servlet中getServletContext().getAttribute(name);
我最喜欢用它来做守护性工作,就是在contextInitialized(ServletContextEvent event)
方法中实现一个Timer,然后就让应用在每次启动的时候让这个Timer工作:
程序代码:
public void contextInitialized(ServletContextEvent event){
timer = new Timer();
timer.schedule(new TimerTask(){
public void run(){
//do any things
}
},0,时间间隔);
}


有人说Timer只能规定从现在开始的多长时间后,每隔多久做一次事或在什么时间做
一次事,那我想在每月1号或每天12点做一项工作如何做呢?
你只要设一个间隔,然后每次判断一下当时是不是那个时间段就行了啊,比如每月一号做,那你
时间间隔设为天,即24小时一个循环,然后在run方法中判断当时日期new Date().getDate()==1
就行了啊.如果是每天的12点,那你时间间隔设为小时,然后在run中判断new Date().getHour()
==12,再做某事就行了.

ServletContextAttributeListener:

这个监听器主要监听ServletContex对象在setAttribute()和removeAttribute()的事件,注意
也就是一个"全局变量"在被Add(第一次set),replace(对已有的变量重新赋值)和remove的时候.
分别调用下面三个方法:
public void attributeAdded(ServletContextAttributeEvent scab)这个方法不仅可以知道
哪些全局变量被加进来,而且可获取容器在启动时自动设置了哪些context变量:
程序代码:
public void attributeAdded(ServletContextAttributeEvent scab){
System.out.println(scab.getName());
}
public void attributeRemoved(ServletContextAttributeEvent scab)

public void attributeReplaced(ServletContextAttributeEvent scab)


Session范围:
HttpSessionListener:
这个监听器主要监听一个Session对象被生成和销毁时发生的事件.对应有两个方法:
程序代码:
public void sessionCreated(HttpSessionEvent se)

public void sessionDestroyed(HttpSessionEvent se)


一般来说,一个session对象被create时,可以说明有一个新客端进入.可以用来粗略统计在线人
数,注意这不是精确的,因为这个客户端可能立即就关闭了,但sessionDestroyed方法却会按一定
的策略很久以后才会发生.

HttpSessionAttributeListener:
和ServletContextAttributeListener一样,它监听一个session对象的Attribut被Add(一个特定
名称的Attribute每一次被设置),replace(已有名称的Attribute的值被重设)和remove时的事件.
对就的有三个方法.
程序代码:
public void attributeAdded(HttpSessionBindingEvent se)

public void attributeRemoved(HttpSessionBindingEvent se)

public void attributeReplaced(HttpSessionBindingEvent se)


上面的几个监听器的方法,都是在监听应用逻辑中servlet逻辑中发生了什么事,一般的来说.
我们只要完成逻辑功能,比如session.setAttribute("aaa","111");我只要把一个名为aaa的变量
放在session中以便以后我能获取它,我并不关心当session.setAttribute("aaa","111");发生时
我还要干什么.(当然有些时候要利用的),但对于下面这个监听器,你应该好好发解一下:

HttpSessionBindingListener:
上面的监听器都是作为一个独立的Listener在容器中控制事件的.而HttpSessionBindingListener
对在一对象中监听该对象的状态,实现了该接口的对象如果被作为value被add到一个session中或从
session中remove,它就会知道自己已经作为一个session对象或已经从session删除,这对于一些非
纯JAVA对象,生命周期长于session的对象,以及其它需要释放资源或改变状态的对象非常重要.
比如:
session.setAttribute("abcd","1111");
以后session.removeAttribute("abcd");因为abcd是一个字符中,你从session中remove后,它就会
自动被垃圾回收器回收,而如果是一个connection:(只是举例,你千万不要加connection往session
中加入)
程序代码:
session.setAttribute("abcd",conn);

以后session.removeAttribute("abcd");这时这个conn被从session中remove了,你已经无法获取它
的句柄,所以你根本没法关闭它.而在没有remove之前你根本不知道什么时候要被remove,你又无法
close(),那么这个connection对象就死了.另外还有一些对象可以在被加入一个session时要锁定
还要被remove时要解锁,应因你在程序中无法判断什么时候被remove(),add还好操作,我可以先加锁
再add,但remove就后你就找不到它的句柄了,根本没法解锁,所以这些操作只能在对象自身中实现.
也就是在对象被add时或remove时通知对象自己回调相应的方法:
程序代码:
MyConn extends Connection implements HttpSessionBindingListener{
public void valueBound(HttpSessionBindingEvent se){
this.initXXX();
}
public void valueUnbound(HttpSessionBindingEvent se){

this.close();
}
}


session.setAttribute("aaa",new MyConn());
这时如果调用session.removeAttribute("aaa"),则触发valueUnbound方法,就会自动关闭自己.
而其它的需要改变状态的对象了是一样.


下面代码是晓光兄弟的:
  1package com.kingbole.listener;
  2
  3import javax.servlet.http.HttpSessionAttributeListener;
  4import javax.servlet.http.HttpSessionBindingEvent;
  5import javax.servlet.http.HttpSessionEvent;
  6import javax.servlet.http.HttpSessionListener;
  7import org.apache.log4j.Logger;
  8import com.kingbole.context.IContext;
  9import com.kingbole.mn.util.LoginUtil;
 10import com.kingbole.shop.struts.model.User;
 11
 12/**
 13 * 
 14 * @author songxg
 15 * 
 16 */

 17public class KingboleSessionListener implements HttpSessionListener, HttpSessionAttributeListener
 18{
 19
 20    private static final Logger logger = Logger.getRootLogger();
 21
 22    /**
 23     * 在session被创建时调用,并为其绑定一个初始IContext对象
 24     * 
 25     * @param evt
 26     *            事件对象
 27     */

 28    public void sessionCreated(HttpSessionEvent evt)
 29    {
 30        // TODO add your code here:
 31        evt.getSession().setAttribute("IContext"new IContext());
 32        logger.info("新建Session");
 33    }

 34
 35    /**
 36     * 在Session被销毁时调用,将User的在线状态更改为下线
 37     * 
 38     * @param evt
 39     *            事件对象
 40     */

 41    public void sessionDestroyed(HttpSessionEvent evt)
 42    {
 43        // TODO add your code here:
 44        IContext icontext = (IContext) evt.getSession().getAttribute("IContext");
 45        if (icontext != null)
 46        {
 47            User user = icontext.getUser();
 48            if (user != null)
 49            {
 50                int userId = user.getId();
 51                if (userId > 0)
 52                {
 53                    // OnlineUsersSet.getInstance().removeUser(userId);
 54                    logger.info("用户 " + userId + " 的Session被销毁");
 55                }

 56                else
 57                {
 58                    logger.info("错误的用户Session超时");
 59                }

 60            }

 61            else
 62            {
 63                logger.info("无用户的Session超时");
 64            }

 65        }

 66        else
 67        {
 68            logger.info("Session销毁时IContext上下文为空");
 69        }

 70    }

 71
 72    public void attributeAdded(HttpSessionBindingEvent arg0)
 73    {
 74        // TODO Auto-generated method stub
 75        String attribute = arg0.getName();
 76        if ("edu.yale.its.tp.cas.client.filter.user".equals(attribute))
 77        {
 78            IContext icontext = (IContext) arg0.getSession().getAttribute("IContext");
 79            if (icontext == null)
 80            {
 81                icontext = new IContext();
 82            }

 83            User user = User.loadUserByUserName((String) arg0.getValue());
 84
 85            icontext.setUser(user);
 86            arg0.getSession().setAttribute("IContext", icontext);
 87            LoginUtil.mnLogin(attribute, arg0.getSession());
 88        }

 89    }

 90
 91    public void attributeRemoved(HttpSessionBindingEvent arg0)
 92    {
 93        // TODO Auto-generated method stub
 94
 95    }

 96
 97    public void attributeReplaced(HttpSessionBindingEvent arg0)
 98    {
 99        // TODO Auto-generated method stub
100
101    }

102
103}

104
posted on 2007-07-10 09:49 冰封的爱 阅读(134) 评论(0)  编辑  收藏 所属分类: J2EE

只有注册用户登录后才能发表评论。


网站导航:
 
<2024年12月>
24252627282930
1234567
891011121314
15161718192021
22232425262728
2930311234

常用链接

留言簿(3)

随笔档案

文章分类

文章档案

相册

搜索

  •  

最新评论

阅读排行榜

评论排行榜