dwr3与struts2整合，实现服务器端推送技术，实现多人聊天功能

<!--new的意思是每次都实例化一个，javascript的意思就是代替-param中的value的简称，可以在js中直接可以用messgeService调用

cn.ittec.zfx.service.impl.MessageServiceImpl中的方法-->

<createcreator="new"javascript="messageService">
1. <paramname="class"value="cn.ittec.zfx.service.impl.MessageServiceImpl"/>
2. </create>
3. </allow>
4. </dwr>

这里还需要注意一点 dwr的过滤器和struts2 的过滤器都过滤的是整个项目，所以会有冲突，所以要在struts.xml中配置一下来解决中途问题

<constantname="struts.action.excludePattern"value="/dwr/*"></constant>

4，接下来就是在接收推送消息的界面引入dwr的js

其中：engine.js和util.js是在dwr.jar包里面的，在项目的WebRoot下面是找不到的，如果你想看，可以到dwr.jar里面找，肯定有，然后还需要引入messageService.js

<scripttype="text/javascript"src="dwr/engine.js"></script>
1. <scripttype="text/javascript"src="dwr/util.js"></script>
2. <scripttype="text/javascript"src="dwr/interface/messageService.js"></script>

5，在接收推送消息的界面body里面初始化一些东西

<scripttype="text/javascript">

//页面加载完之后执行这个方法，与服务器建立长连接

functionunready(){

//dwr.engine.setActiveReverseAjax(true);与服务器建立一个长连接，默认是false，如果是false连接会在5分钟后注销

//onPageLoad会触发自己的一个方法

dwr.engine.setActiveReverseAjax(true);
1. dwr.engine.setNotifyServerOnPageUnload(true);
2. onPageLoad();
3. }
4. /**
5. *当打开此页面时，触发这个方法，与服务器建立一个长连接，随时推送服务器消息
6. **/
7. functiononPageLoad(){

//获取将要给哪个登录的id发送消息

varsendId=document.getElementById("sendId").value;

//****通过这个方法调用cn.ittec.zfx.service.impl.MessageServiceImpl中的onPageLoad方法

messageService.onPageLoad(sendId);
1. </script>

6，下面是 onPageLoad 方法的说明（不用说明的都不用改，只要copy到你的项目就ok了,因为有些我也不是太懂，哈）

publicvoidonPageLoad(StringsendId){//sendId打开的聊天窗口对应的User的id
1. ScriptSessionscriptSession=WebContextFactory.get()
2. .getScriptSession();
3. scriptSession.setAttribute(sendId,sendId);

//DwrScriptSessionManagerUtil是自己写的一个类

DwrScriptSessionManagerUtildwrScriptSessionManagerUtil=newDwrScriptSessionManagerUtil();
1. try{
2. dwrScriptSessionManagerUtil.init();
3. }catch(ServletExceptione){
4. e.printStackTrace();
5. }

下面是DwrScriptSessionManagerUtil.java类的说明

packagecn.ittec.zfx.util;
1. importjavax.servlet.ServletException;
2. importjavax.servlet.http.HttpSession;
3. importorg.directwebremoting.Container;
4. importorg.directwebremoting.ServerContextFactory;
5. importorg.directwebremoting.WebContextFactory;
6. importorg.directwebremoting.event.ScriptSessionEvent;
7. importorg.directwebremoting.event.ScriptSessionListener;
8. importorg.directwebremoting.extend.ScriptSessionManager;
9. importorg.directwebremoting.servlet.DwrServlet;
10. importcn.ittec.zfx.domain.User;
11. publicclassDwrScriptSessionManagerUtilextendsDwrServlet{
12. privatestaticfinallongserialVersionUID=1L;
13. publicvoidinit()throwsServletException{
14. Containercontainer=ServerContextFactory.get().getContainer();
15. ScriptSessionManagermanager=container
16. .getBean(ScriptSessionManager.class);
17. ScriptSessionListenerlistener=newScriptSessionListener(){
18. publicvoidsessionCreated(ScriptSessionEventev){
19. HttpSessionsession=WebContextFactory.get().getSession();

//这里的意思是你放在session里用户的id

Useruser=(User)session.getAttribute("user");
1. StringuserId=user.getId()+"";
2. //StringuserId=ZfxUtils.getUserFromSession().getId()+"";
3. ev.getSession().setAttribute("userId",userId);
4. }
5. publicvoidsessionDestroyed(ScriptSessionEventev){
6. };
7. manager.addScriptSessionListener(listener);
8. }

7，到此接收端的一些操作就完成了，下面是发送信息端的代码。

当你点击发送按钮将推送信息的时候要用js触发这个方法

messageService.pushMessagee(id,name,contextTwo);

下面是pushMessagee的代码：

<precode_snippet_id="207359"snippet_file_name="blog_20140227_27_6582088"class="java"name="code">publicvoidpushMessagee(Stringuserid,Stringname,StringcontextTwo)throwsException{
1. finalStringuserId=userid;//接收端用户的id</pre><precode_snippet_id="207359"snippet_file_name="blog_20140227_28_2405394"class="java"name="code">finalStringuserName=name;//发送端的name，告诉他是谁谁谁发的，类似QQ
2. finalStringautoMessage=contextTwo;//将要发送的内容
3. Browser.withAllSessionsFiltered(newScriptSessionFilter(){
4. publicbooleanmatch(ScriptSessionsession){
5. if(session.getAttribute("userId")==null){
6. returnfalse;
7. else{
8. return(session.getAttribute("userId")).equals(userId);
9. },newRunnable(){
10. privateScriptBufferscript=newScriptBuffer();
11. publicvoidrun(){
12. </pre><precode_snippet_id="207359"snippet_file_name="blog_20140227_29_9864902"class="java"name="code">//这里比较重要了。showMessage是接收页面js中的方法名，userName和antoMessage分别是方法的参数，信息全部发送过去了，接下来你要弹框还是写到页面就看你的需求了，</pre><precode_snippet_id="207359"snippet_file_name="blog_20140227_30_3736360"class="java"name="code">script.appendCall("showMessage",userName,autoMessage);
13. Collection<ScriptSession>sessions=Browser
14. .getTargetSessions();
15. for(ScriptSessionscriptSession:sessions){
16. scriptSession.addScript(script);
17. });
18. }</pre><br>
19. <pre></pre>
20. <h3><aname="t11"></a><br>
21. 8，至此全部搞定了，看似很简单，但是有些地方还是不太清楚，由于原项目不方便供给大家参考，如果大家还有什么不懂的，可以留言告诉我，我会尽力帮助大家，互相帮忙嘛！！</h3>
22. <p></p>
23. <p></p>
24. <p></p>

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!