DWR3.0推送技术实现QQ即时通信功能(3)
2014-04-12 16:31
330 查看
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)向所有的页面访问者推送
当我们想向所有的页面访问者推送的时候,我们只需要,取得所有的页面访问者,就可以“推”了。
如何取得所有的页面访问者?
(5) 在上面的推送中产生的问题
上面的方法已经可以实现向所有的访问者推送。但是问题是,在客户端,如果用户刷新一次或多次,那么,Collection里面可能就保存了很多的无用的ScriptSession,所以不仅仅会影响性能问题,更重要的是,可能就不能实现你想要的功能。
2.如何管理有效的ScriptSession
2.如何管理有效的ScriptSession
由于上面的问题,我们就需要自己管理ScriptSession。其实,有效地HttpSession,就是那个和当前的HttpSession匹配的ScriptSession。
所以,我们就可以自己维护一个Map,在这个Map里面,我们定义key就是HttpSession的Id,其值就是ScriptSession对象。
在每一次页面载入的时候,都去注册此ScriptSession,那么就会把新的ScriptSession绑定到httpSession上面了。
在DWR3.0中推出了 ScriptSessionListener用来监听ScriptSession的创建及销毁事件。我们可以使用该监听器来维护我们自己的Map。
1.新建一个类实现 ScriptSessionListener接口
2.新建一个类继承 DefaultScriptSessionManager,用来绑定 DWRScriptSessionListener
3.在web.xml中将 DWRScriptSessionManager 配置在 dwr-invoker
servlet中
这样在服务器启动时即会绑定 ScriptSessionListener, ScriptSession在创建时会自动添加到我们维护的Map中
3.使用 ScriptSessionFilter过滤
如果我们不想要给所有的客户端 推送消息,只想给特定的客户端推送,那么我们可以使用 ScriptSessionFilter来实现。在filter中去判定session中的Attribute值是不是我们给定的。
1.使用以下方法推送消息
2.通过参数可知我们需要一个 ScriptSessionFilter对象,此时sendMessage的方法改写成如下:
3.在打开jsp页面时需要在 ScriptSession 中注入设定的attribute,新建一个类GetScriptSession并在dwr.xml中注册其中的onPageLoad方法
4.发送接收消息都写在了index.jsp中了,index.jsp代码如下:
效果如下:
在上一节实现了服务器的推送功能,但是根据 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
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>
效果如下:
相关文章推荐
- DWR3.0推送技术实现QQ即时通信功能(1)
- DWR3.0推送技术实现QQ即时通信功能(2)
- [置顶] 300行代码实现 微信或QQ 抢红包功能
- 类似QQ贴边掩藏功能的实现(三)
- 用DirectShow实现QQ的音视频聊天功能
- 实现QQ中消息窗体闪烁功能 转
- C#实现仿QQ窗体停靠功能
- 用DirectShow实现QQ的音视频聊天功能(转)
- C#如何实现类似QQ那样靠边隐藏的功能
- 关于QQ一些功能的实现(转)
- Android仿QQ实现聊天功能
- 关于QQ一些功能的实现(二)
- QQ聊天功能在局域网中的实现
- 仿QQ语音变声功能实现(二)---移植到android studio 并解决部分问题
- ios 使用自带的UIViewController实现qq加号下拉菜单的功能
- 类似QQ贴边掩藏功能的实现(一)
- 【腾讯开放平台】Android、IOS实现指定QQ临时会话功能
- 实现QQ窗体的缩入伸出功能[转载]
- Android开发实现仿QQ消息SwipeMenuListView滑动删除置顶功能【附源码下载】