服务热线:13616026886

技术文档 欢迎使用技术文档,我们为你提供从新手到专业开发者的所有资源,你也可以通过它日益精进

位置:首页 > 技术文档 > JAVA > 新手入门 > 基础入门 > 查看文档

使用xmlhttp和java session监听改善站内消息系统

使用xmlhttp和java session监听改善站内消息系统

bromon 原创  引自:http://www.javaresearch.org/article/showarticle.jsp?column=106&thread=25340

  这个题目含有许多需要解释的概念,最容易说明的是“站内消息”,这是很多论坛都有的功能,可以通过web向其他的在线用户发送消息,很多用户都使用过。站内消息的第一个好处是大家都不需要安装客户端,你不用知道对方的msn或者qq,就能与他联系,称赞他的观点或者是给他一顿臭骂。第二个好处是客户管理方便,利用session来维护在线名单,各种脚本都已经把session操作封装得很易用了,不用像其他无状态的即时通信工具(比如使用udp通信的工具)一样,要费一些脑细胞来解决在线名单的问题。缺点嘛,就是实时性不好,一般是在用户跳转或者刷新页面才能探测消息、更新在线名单。

  session监听嘛,没什么好解释的,java提供了很灵活的事件机制来监听session,可以监听session的创建和销毁,监控session所携带数据的创建、变化和销毁,可以监听session的锐化和钝化(了解对象序列化的兄弟应该知道这个),其他的平台是个什么情况我不太清楚,估计也差不多吧。如果能够对所有客户的session进行监控,就不用再去操作麻烦而危险的application了。

  xmlhttp是ms推的一项技术,功能很复杂,可以做很多事情,比如客户端可以在简单的html中打开http连接,主动向server请求数据并获得返回数据,是dom技术一个非常重要的应用,利用它来写无刷新的动态页面简直是so easy,做过web开发的兄弟应该明白它的意义有多么重大。

一、 session监听

  servlet中对session的监听有很多接口,功能很灵活,最常用的是监听session和attribute。这里要澄清一下概念,servlet中的session监听和attribute监听含义有差别,session监听指的不是我们一般所理解的放置一个session或者销毁一个session,这是attribute监听的功能,因为servlet中放置session的语法是session.setattribute(“session名”,要放入的对象)。而session监听,监听的是http连接,只要有用户与server连接,就算连接的是一个空白的jsp页面,也会触发session事件,所以此处的session实际上指的是connection,用来统计当前在线用户数最合适了。不知道我说清楚了没有。下面分别讲解这两种监听方式。

1、 session监听

  首先编写一个session监听类,实作httpsessionlistener接口,它的作用是计算当前有多少个在线用户:

  1. /**
  2. *@author bromon
  3. *2004-6-12
  4. */
  5. package org.bromon.test;
  6. import javax.servlet.*;
  7. import javax.servlet.http.*;
  8. public class sessioncount implements httpsessionlistener
  9. {
  10.     private static int count=0;
  11.     public void sessioncreated(httpsessionevent se)
  12.     {
  13.         count++;
  14.         system.out.println(“session创建:”+new java.util.date());
  15.     }
  16.     public void sessiondestroyed(httpsessionevent se)
  17.     {
  18.        count--;
  19.        system.out.println(“session销毁:”+new java.util.date());
  20.     }
  21.     public static int getcount()
  22.     {
  23.        return(count);
  24.      }
  25. }

  怎么样,是不是一目了然?count被定义为static,是因为要保证整个系统只有这一个count。如果你实在不放心,可以把它写成一个单例类。

  然后在web.xml中声明这个监听器:
<listener>
<listener-class>
org.bromon.test.sessioncount
</listener-class>
</listener>

  编写一个测试页面test.jsp,内容是获得count:
<%
int count=org.bromon.test.sessioncount.getcount();
out.println(count);
%>

  需要注意的是,这里根本不涉及任何session的操作。重启动app server,试着连接test.jsp,可以看到监听器已经开始工作。

2、 attribute监听
  作为一个站内消息系统,肯定要获得所有登陆者的id,才有可能互发消息。这就涉及attribute监听。假设我们写了个用户登陆的模块,用户通过身份验证之后会产生一个session,保存它的相关信息,比如:
  1. //check.jsp
  2. <%
  3.     string name=request.getparameter(“name”);
  4.     name=new string(name.getbytes(“iso8859-1”));
  5.     session.setattribute(“user”,name);
  6. %>


  做过jsp的兄弟应该对这段代码再熟悉不过了,下面写个监听器来监听用户登陆,把所有用户的id保存到一个list当中,这个监听器实作httpsessionattributelistener接口:

  1. /**
  2. *@author bromon
  3. *2004-6-12
  4. */
  5. package org.bromon.test;
  6. import javax.servlet.*;
  7. import javax.servlet.http.*;
  8. import java.util.*;
  9. public class onlinelist implements httpsessionattributelistener
  10. {
  11.     private static list list=new arraylist();
  12.     public void attributeadded(httpsessionbindingevent se)
  13.     {
  14.         if(“user”.equals(se.getname()))
  15.         {
  16.             list.add(se.getvalue());
  17.          }
  18.     }
  19.     public void attributeremoved(httpsessionbindingevent se)
  20.     {
  21.          if(“user”.equals(se.getname()))
  22.          {
  23.             list.remove(se.getvalue());
  24.          }
  25.     }
  26.     public void attributereplaced(httpsessionbindingevent se){}
  27.     public static list getlist()
  28.     {
  29.          return(list);
  30.      }
  31. }


写个简单的jsp来得到用户列表:
<%
    java.util.list list=org.bromon.test.onlinelist.getlist();
    out.println(“共有”+list.size()+”名用户已登陆:”);
    for(int i=0;i<lise.size();i++)
    {
        out.println(list.get(i));
    }
%>

也许你说,这有什么神奇呢,监听session而已,不着急,看看xmlhttp。

二、 xmlhttp

  xmlhttp的用处很多,这里只说我们需要的,就是无刷新的与server通信,看这段代码:

  1. <script language="javascript"
  2. xml = new activexobject("microsoft.xmlhttp"); 
  3. var post=" ";//构造要携带的数据 
  4. xml.open("post","http://localhost:7001/testwl/index.jsp",false);//使用post方法打开一个到服务器的连接,以异步方式通信 
  5. xml.setrequestheader("content-length",post.length); 
  6. xml.setrequestheader("content-type","application/x-www-form-urlencoded"); 
  7. xml.send(post);//发送数据 
  8. var res = xml.responsetext;//接收服务器返回的数据 
  9. document.write(res); 
  10. </script>



  豁然开朗,这段代码就是打开一个http连接,以标准的http格式传递数据,如果你喜欢,可以用xml的格式来传递。更改一下xml对象的构造方式就可以兼容mozilla和netscape。下面来写一个轮询,每隔一段时间刷新一次用户列表,当然,是不需要刷新页面的:

  1. <html>
  2. <head><title>探测器</title>
  3. <script language="javascript">
  4. function detect()
  5. {
  6. xml = new activexobject("microsoft.xmlhttp"); 
  7. var post=" ";//构造要携带的数据 
  8. xml.open("post","http://localhost:7001/testwl/index.jsp",false);//使用post方法打开一个到服务器的连接,以异步方式通信 
  9. xml.setrequestheader("content-length",post.length); 
  10. xml.setrequestheader("content-type","application/x-www-form-urlencoded"); 
  11. xml.send(post);//发送数据 
  12. var res = xml.responsetext;//接收服务器返回的数据 
  13. list.innertext=res;
  14. settimeout(“detect()”,5000);//每隔5秒钟轮询一次
  15. </script>
  16. <body onload=”detect()”>
  17. <a id=”list”></a>
  18. </body>
  19. </html>


  这样的通信方式数据量很小,不用重新传递整个页面,5秒钟轮一次,普通pc也能承受较大的在线数。构造一个探测器来监听在线列表和消息,效果是很好的,即使你的客户坐在电脑前袖手旁观,键鼠都不碰一下,也能保证数据即时传递,页面也不会发生跳转和刷新。

  session监听加上xmlhttp通信,开发一个较为完善的站内消息系统实在易如反掌。

扫描关注微信公众号