DWR3.0推送技术实现QQ即时通信功能3

1.ScriptSession使用中存在的问题

在上一节实现了服务器的推送功能，但是根据 ScriptSession的生命周期我们可以得出以下几点的问题：

（1）ScriptSession不会与HttpSession同时创建

当我们访问一个页面的时候，如果是第一次访问，就会创建一个新的HttpSession,之后再访问的时候，就会保持当前的Session,即使是刷新，也能保持当前的HttpSession。

但是，ScriptSession不同，第一次访问，会创建一个ScriptSession,但是，如果你刷新，就会创建一个新的ScriptSession.

（2）如何得到ScriptSession

在DWR中，我们可以通过WebContextFactory.get()来取得一个WebContext对象，进而通过WebContext的getScriptSession()取得ScriptSession对象。

但是要注意，在我们自定义的Servlet中，我们也可以通过WebContextFactory.get()来取得一个WebContext,但是这种方法却不能取得ScriptSession对象。因为，此WebContext对象其实不是通过DWR的上下文环境得到的，所以，就根本没有创建ScriptSession对象。

假设这种方式也能得到ScriptSession的话，那么我们实现“推”也就可以不局限在DWR的上下文环境中了，那么其灵活性就会大很多了。所以，这就是我们不能在Servlet中实现推的原因。

（3）关于刷新就创建一个新的ScriptSession问题

在我们需要推送的页面中，如果你刷新一下，那么就提交一个Http的request,此时，如果是第一次，那么就会创建一个httpSession对象，同时，请求由DwrServlet来处理后，就会创建一个ScriptSession.这个ScriptSession会和你的request请求的URI绑定放在一个由ScriptSessionManager维护的Map里面（这里面其实是一个URI对应的Set,在Set里面放置的是URI绑定的所有ScriptSession）。

当你刷新的时候，同样的一个HttpSession,却会创建一个新的ScriptSession,然后绑定到对应的URI上。

（4）向所有的页面访问者推送
当我们想向所有的页面访问者推送的时候，我们只需要，取得所有的页面访问者，就可以“推”了。
如何取得所有的页面访问者？

//得到所有ScriptSession   
				Collection<ScriptSession> sessions = browser.getTargetSessions();
				for(ScriptSession session :sessions){
					session.addScript(script);
				}

（5）在上面的推送中产生的问题
上面的方法已经可以实现向所有的访问者推送。但是问题是，在客户端，如果用户刷新一次或多次，那么，Collection里面可能就保存了很多的无用的ScriptSession,所以不仅仅会影响性能问题，更重要的是，可能就不能实现你想要的功能。

2.如何管理有效的ScriptSession

由于上面的问题，我们就需要自己管理ScriptSession。其实，有效地HttpSession,就是那个和当前的HttpSession匹配的ScriptSession。

所以，我们就可以自己维护一个Map,在这个Map里面，我们定义key就是HttpSession的Id,其值就是ScriptSession对象。

在每一次页面载入的时候，都去注册此ScriptSession,那么就会把新的ScriptSession绑定到httpSession上面了。

在DWR3.0中推出了 ScriptSessionListener用来监听ScriptSession的创建及销毁事件。我们可以使用该监听器来维护我们自己的Map。

1.新建一个类实现 ScriptSessionListener接口

package com.DWR.dwr;

import java.util.Collection;
import java.util.HashMap;
import java.util.Map;

import javax.servlet.http.HttpSession;

import org.directwebremoting.ScriptSession;
import org.directwebremoting.WebContext;
import org.directwebremoting.WebContextFactory;
import org.directwebremoting.event.ScriptSessionEvent;
import org.directwebremoting.event.ScriptSessionListener;

public class DWRScriptSessionListener implements ScriptSessionListener{
	private Map<String,ScriptSession> scriptsessionMap = new HashMap<String,ScriptSession>();
	public void sessionCreated(ScriptSessionEvent event) {
		WebContext webcontext = WebContextFactory.get();
		HttpSession httpsession = webcontext.getSession();
		ScriptSession scriptsession = event.getSession();
		scriptsessionMap.put(httpsession.getId(),scriptsession);
		System.out.println("scriptsession is create!");
	}

	public void sessionDestroyed(ScriptSessionEvent arg0) {
		WebContext webcontext = WebContextFactory.get();
		HttpSession httpsession = webcontext.getSession();
		scriptsessionMap.remove(httpsession.getId());
		System.out.println("scriptsession is destoryed!!");
		
	}
	public Collection<ScriptSession> getAllSessions(){
		return scriptsessionMap.values();
	}
	public ScriptSession getonescriptSession(String str){
		 Collection<ScriptSession> sessions = getAllSessions();
		 ScriptSession session = null;
		 for(ScriptSession sess:sessions){
			 if(str.equals(sess.getAttribute("trogonum"))){
				 session = sess;
				 break;
			 }
		 }
		return session;
	}
}

2.新建一个类继承 DefaultScriptSessionManager，用来绑定 DWRScriptSessionListener

package com.DWR.dwr;

import org.directwebremoting.impl.DefaultScriptSessionManager;

public class DWRScriptSessionManager extends DefaultScriptSessionManager{
	public DWRScriptSessionManager(){
		//绑定一个ScriptSession增加销毁事件的监听器   
		addScriptSessionListener(new DWRScriptSessionListener(){});
		System. out.println( "bind DWRScriptSessionListener");  

	}
}

3.在web.xml中将 DWRScriptSessionManager 配置在 dwr-invoker servlet中

 <init-param>  
            <param-name> org.directwebremoting.extend.ScriptSessionManager</param-name > 
            <param-value> com.DWR.dwr.DWRScriptSessionManager</param-value >
        </init-param>

这样在服务器启动时即会绑定 ScriptSessionListener， ScriptSession在创建时会自动添加到我们维护的Map中

3.使用 ScriptSessionFilter过滤

如果我们不想要给所有的客户端推送消息，只想给特定的客户端推送，那么我们可以使用 ScriptSessionFilter来实现。在filter中去判定session中的Attribute值是不是我们给定的。

1.使用以下方法推送消息

//执行推送
browser.withAllSessionsFiltered(filter,run);    //注意这里调用了有filter功能的方法

2.通过参数可知我们需要一个 ScriptSessionFilter对象，此时sendMessage的方法改写成如下：

package com.DWR.dwr;

import java.util.Collection;

import org.directwebremoting.browser;
import org.directwebremoting.ScriptBuffer;
import org.directwebremoting.ScriptSession;
import org.directwebremoting.ScriptSessionFilter;

public class MessagePush {
	public void sendMessage(final String id,final String content){
		System.out.println("MessagePush:"+id);
		ScriptSessionFilter filter = new ScriptSessionFilter(){

			public boolean match(ScriptSession scriptsession) {
				String str = (String)scriptsession.getAttribute("id");
				return str.equals(id);
			}
			
		};
		Runnable run = new Runnable(){
			ScriptBuffer script = new ScriptBuffer();
			public void run(){
				//设置要调用的 js及参数
				script.appendCall("showMessage",content);
				//得到ScriptSession   
				ScriptSession scriptsession = DWRScriptSessionListener.getonescriptSession(id);
				scriptsession.addScript(script);
			}
		};
		//执行推送
		browser.withAllSessionsFiltered(filter,run);
	}
}

3.在打开jsp页面时需要在 ScriptSession 中注入设定的attribute，新建一个类GetScriptSession并在dwr.xml中注册其中的onPageLoad方法

public void onPageLoad(String str){
		WebContext webcontext = WebContextFactory.get();
		ScriptSession scriptsession = webcontext.getScriptSession();
		System.out.println(str);
		scriptsession.setAttribute("id",str);
	}

4.发送接收消息都写在了index.jsp中了，index.jsp代码如下：

<%@ page language="java" import="java.util.*" pageEncoding="utf-8"%>
<%
String path = request.getcontextpath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
  <head>
    <base href="<%=basePath%>">
    
    <title>My JSP 'index.jsp' starting page</title>
	<Meta http-equiv="pragma" content="no-cache">
	<Meta http-equiv="cache-control" content="no-cache">
	<Meta http-equiv="expires" content="0">    
	<Meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
	<Meta http-equiv="description" content="This is my page">
	<!--
	<link rel="stylesheet" type="text/css" href="styles.css">
	-->
	<script src="jquery-1.7.js"></script>
	<script type= "text/javascript" src ="dwr/util.js"></script>     
     <script type="text/javascript" src= "dwr/engine.js"></script >   
     <script type="text/javascript" src= "dwr/interface/messagePush.js" ></script>  
	<script type="text/javascript" src= "dwr/interface/getScriptSession.js" ></script> 
	<script>
		//这个方法用来启动该页面的ReverseAjax功能 
			dwr.engine.setActiveReverseAjax(true);
			//设置在页面关闭时，通知服务端销毁会话 
			dwr.engine.setNotifyServerOnPageUnload(true);
			var id ='1';
			getScriptSession.onPageLoad(id);
			//这个函数是提供给后台推送的时候 调用的
			
		$('document').ready(function(){
			$('#send').bind('click',function(){
				var mess= $('#message').val();
				messagePush.sendMessage('1',mess);
			});
		});
		function showMessage(content){
				$('#getMessage').append(content);
		};
	</script>
  </head>
  <%
  		
   %>
  <body>
    <input type="text" id="message" size="20"/>
    <input type="button" id ="send" value="send"/>
    <div id="getMessage" style="padding:100px;border:1px solid #F00;">
    	
    		<ul></ul>
    	</div>
  </body>
</html>

效果如下：

原文地址：https://www.jb51.cc/ajax/165021.html

DWR3.0推送技术实现QQ即时通信功能3

相关推荐