欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

基于DWR的点对点聊天实现 server---client

程序员文章站 2022-05-13 11:15:02
...

本文转自:http://htj1231825.iteye.com/blog/2206526

RemoteMessageServer 客服类 

Java代码  基于DWR的点对点聊天实现 server---client
            
    
    博客分类: javadwr javadwr 
  1. package com.gw.medical.hospital.utils.dwr;  
  2.   
  3. import java.util.Iterator;  
  4. import java.util.Map;  
  5.   
  6. import javax.servlet.http.HttpSession;  
  7.   
  8. import org.directwebremoting.ScriptBuffer;  
  9. import org.directwebremoting.ScriptSession;  
  10. import org.directwebremoting.WebContextFactory;  
  11. import org.directwebremoting.annotations.RemoteMethod;  
  12. import org.directwebremoting.annotations.RemoteProxy;  
  13.   
  14. @RemoteProxy(name = "RemoteMessageServer")  
  15. public class RemoteMessageServer {  
  16.   
  17.     /** 
  18.      *服务端初始化 
  19.      */  
  20.     @RemoteMethod  
  21.     public void onPageLoad() {  
  22.         getHttpSession().setAttribute("userInfo""CustomerService1"); // 测试用,存入模拟userInfo信息  
  23.         RemoteMessageConstant.getServerList().put(getScriptSession().getId(), getScriptSession());// 存储当前客服,到在线客服列表  
  24.     }  
  25.   
  26.     /** 
  27.      * 服务端发送信息 
  28.      *  
  29.      * @param message 
  30.      */  
  31.     @RemoteMethod  
  32.     public void addMessage(final String message) {  
  33.         HttpSession httpsession = getHttpSession();// 获取session  
  34.         String clientName = httpsession.getAttribute("clientName") == null ? "" : httpsession.getAttribute("clientName").toString();// 当前客户端ID  
  35.         ScriptSession session = RemoteMessageConstant.getMapList().get(clientName);// 根据clientName获取scriptSession;  
  36.         if (session != null) {  
  37.             // 发送消息  
  38.             String serverMessage=getHttpSession().getAttribute("userInfo").toString();  
  39.             serverMessage=serverMessage+":"+message;  
  40.             sendMessage(session,"receiveMessages",serverMessage);  
  41.         }  
  42.     }  
  43.   
  44.     /** 
  45.      * 选择下一个客户端 
  46.      *  
  47.      * @return boolean 
  48.      */  
  49.     @RemoteMethod  
  50.     public String selectClient() {  
  51.         addMessage("本次会话结束!感谢您的咨询!");  
  52.         // 销毁上一位客户  
  53.         removeClient();  
  54.         ScriptSession sessionServer = getScriptSession();// 获取客服ScriptSsession  
  55.         HttpSession httpsession = getHttpSession();// 获取session  
  56.         Map<String, ScriptSession> userMap = RemoteMessageConstant.getMapList();// 用户在线MAP  
  57.         Iterator<String> iterator = userMap.keySet().iterator();  
  58.         String clientName = "";// 获取客户端列表中的,clientName;  
  59.   
  60.         while (iterator.hasNext()) {  
  61.             // 判断当前用户是否有客服接入,如未接入,接入该客户  
  62.             String tempName = iterator.next();  
  63.             if (RemoteMessageConstant.getMappingList().get(tempName) == null) {  
  64.                 clientName = tempName;  
  65.                 break;  
  66.             }  
  67.         }  
  68.         ScriptSession session = userMap.get(clientName);// 根据clientName获取scriptSession;  
  69.         // 更改客户端的服务ID  
  70.         if (session != null) {  
  71.             // 调用页面JS  
  72.             sendMessage(session, "setServerName", httpsession.getAttribute("userInfo").toString());  
  73.             httpsession.setAttribute("clientName", clientName);// 存储当前客户ID  
  74.             RemoteMessageConstant.getMappingList().put(session.getId(), sessionServer);// 存储对应关系,到关系MAP  
  75.             return RemoteMessageConstant.getUserNamList().get(clientName);  
  76.         }  
  77.   
  78.         return "";  
  79.     }  
  80.   
  81.     /** 
  82.      * 销毁当前,服务端对应的客户端信息 
  83.      */  
  84.     public void removeClient() {  
  85.         HttpSession httpSession = getHttpSession();// 获取httpsession  
  86.         String clientName = httpSession.getAttribute("clientName") == null ? "" : httpSession.getAttribute("clientName").toString();  
  87.         RemoteMessageConstant.getMappingList().remove(clientName);// 从关系Map中,删除对应关系。  
  88.         RemoteMessageConstant.getMapList().remove(clientName);// 从用户Map中,删除该用户;  
  89.         RemoteMessageConstant.getUserNamList().remove(clientName);//从用户名列表 删除该用户名  
  90.         httpSession.removeAttribute("clientName");// 删除当前服务端的,客户ID  
  91.     }  
  92.   
  93.     /** 
  94.      * 调用页面JS 
  95.      * @param scriptSession,jsName:JS方法名,message:发送的信息 
  96.      */  
  97.     public void sendMessage(ScriptSession scriptSession, String jsName, String message) {  
  98.         ScriptBuffer script = new ScriptBuffer();  
  99.         script.appendCall(jsName, message);  
  100.         scriptSession.addScript(script);  
  101.     }  
  102.   
  103.     /** 
  104.      * get set 
  105.      */  
  106.   
  107.     public ScriptSession getScriptSession() {  
  108.   
  109.         return WebContextFactory.get().getScriptSession();  
  110.     }  
  111.   
  112.     public HttpSession getHttpSession() {  
  113.   
  114.         return WebContextFactory.get().getSession();  
  115.     }  
  116.   
  117. }  



RemoteMessageClient  客户端 

Java代码  基于DWR的点对点聊天实现 server---client
            
    
    博客分类: javadwr javadwr 
  1. package com.gw.medical.hospital.utils.dwr;  
  2.   
  3. import java.util.Collection;  
  4. import java.util.Iterator;  
  5.   
  6. import javax.servlet.ServletException;  
  7. import javax.servlet.http.HttpSession;  
  8.   
  9. import org.directwebremoting.Browser;  
  10. import org.directwebremoting.ScriptBuffer;  
  11. import org.directwebremoting.ScriptSession;  
  12. import org.directwebremoting.ScriptSessionFilter;  
  13. import org.directwebremoting.WebContextFactory;  
  14. import org.directwebremoting.annotations.RemoteMethod;  
  15. import org.directwebremoting.annotations.RemoteProxy;  
  16.   
  17. @RemoteProxy(name = "RemoteMessageClient")  
  18. public class RemoteMessageClient {  
  19.   
  20.     /** 
  21.      * 客户端初始化 
  22.      */  
  23.     @RemoteMethod  
  24.     public void onPageLoadClient() {  
  25.         ScriptSession scriptSession = getScriptSession();  
  26.         HttpSession httpSession = getHttpSession();  
  27.         String clientName = scriptSession.getId();// 获取seciptSessionID作为clientName  
  28.         httpSession.setAttribute("clientName", clientName);  
  29.         RemoteMessageConstant.getMapList().put(clientName, scriptSession);// 存储用户信息到在线用户列表  
  30.         RemoteMessageConstant.getUserNamList().put(clientName, "游客");  
  31.         // 服务器显示在线用户列表;  
  32.         showOnlinClient();  
  33.         DwrScriptSessionManagerUtil dssm = new DwrScriptSessionManagerUtil();  
  34.         try {  
  35.             dssm.init();  
  36.         } catch (ServletException e) {  
  37.             e.printStackTrace();  
  38.         }  
  39.     }  
  40.   
  41.     /** 
  42.      * 客户端发送信息 
  43.      *  
  44.      * @param message 
  45.      */  
  46.     @RemoteMethod  
  47.     public void addMessageClient(String message) {  
  48.         HttpSession httpSession = getHttpSession();  
  49.         String clientName = httpSession.getAttribute("clientName") == null ? "" : httpSession.getAttribute("clientName").toString();// 获取当前登录客户端ID,在用户列表中查找相应客服  
  50.         String autoMessage = message;// 发送的内容  
  51.         ScriptSession scriptSession = RemoteMessageConstant.getMappingList().get(clientName);// 从对应Map中获取,当前客户端对应的服务端ScriptSession  
  52.   
  53.         if (scriptSession != null) {  
  54.             String clientMessage=RemoteMessageConstant.getUserNamList().get(clientName);  
  55.             clientMessage+=":"+autoMessage;  
  56.             sendMessage(scriptSession,"receiveMessages",clientMessage);  
  57.         }  
  58.     }  
  59.   
  60.     /** 
  61.      * 更改服务端在线用户列表 
  62.      */  
  63.     public void showOnlinClient() {  
  64.         Browser.withAllSessionsFiltered(new ScriptSessionFilter() {  
  65.             // 筛选scriptSession的用户,发送目标ID,是否在scriptSession中存在  
  66.             public boolean match(ScriptSession session) {  
  67.                 if (RemoteMessageConstant.getServerList().get(session.getId()) != null) {  
  68.                     return true;  
  69.                 } else {  
  70.                     return false;  
  71.                 }  
  72.             }  
  73.         }, new Runnable() {  
  74.             private ScriptBuffer script = new ScriptBuffer();  
  75.   
  76.             public void run() {  
  77.                 // 输出内容到页面  
  78.                 Iterator<String> it = RemoteMessageConstant.getMapList().keySet().iterator();  
  79.                 String autoMessage = new String();  
  80.                 while (it.hasNext()) {  
  81.                     String key = it.next().toString();  
  82.                     // 如果没有被分配客服,显示在等待列表中  
  83.                     if (RemoteMessageConstant.getMappingList().get(key) == null) {  
  84.   
  85.                         autoMessage += RemoteMessageConstant.getUserNamList().get(key) + ";";  
  86.                     }  
  87.                 }  
  88.                 script.appendCall("showOnlinClient", autoMessage);  
  89.                 Collection<ScriptSession> sessions = Browser.getTargetSessions();  
  90.                 for (ScriptSession scriptSession : sessions) {  
  91.                     scriptSession.addScript(script);  
  92.                 }  
  93.             }  
  94.         });  
  95.     }  
  96.   
  97.   
  98.     /** 
  99.      * get set 
  100.      */  
  101.     /** 
  102.      * 调用页面JS 
  103.      *  
  104.      * @param scriptSession 
  105.      *            ,jsName:JS方法名,message:发送的信息 
  106.      */  
  107.     public void sendMessage(ScriptSession scriptSession, String jsName, String message) {  
  108.         ScriptBuffer script = new ScriptBuffer();  
  109.         script.appendCall(jsName, message);  
  110.         scriptSession.addScript(script);  
  111.     }  
  112.   
  113.     public ScriptSession getScriptSession() {  
  114.   
  115.         return WebContextFactory.get().getScriptSession();  
  116.     }  
  117.   
  118.     public HttpSession getHttpSession() {  
  119.   
  120.         return WebContextFactory.get().getSession();  
  121.     }  
  122. }  




DwrScriptSessionManagerUtil 监听 

Java代码  基于DWR的点对点聊天实现 server---client
            
    
    博客分类: javadwr javadwr 
  1. package com.gw.medical.hospital.utils.dwr;  
  2.   
  3. import javax.servlet.ServletException;  
  4.   
  5. import org.directwebremoting.Container;  
  6. import org.directwebremoting.ScriptBuffer;  
  7. import org.directwebremoting.ScriptSession;  
  8. import org.directwebremoting.ServerContextFactory;  
  9. import org.directwebremoting.event.ScriptSessionEvent;  
  10. import org.directwebremoting.event.ScriptSessionListener;  
  11. import org.directwebremoting.extend.ScriptSessionManager;  
  12. import org.directwebremoting.servlet.DwrServlet;  
  13.   
  14. public class DwrScriptSessionManagerUtil extends DwrServlet {  
  15.   
  16.     private static final long serialVersionUID = -7504612622407420071L;  
  17.   
  18.     public void init() throws ServletException {  
  19.         Container container = ServerContextFactory.get().getContainer();  
  20.         ScriptSessionManager manager = container.getBean(ScriptSessionManager.class);  
  21.         ScriptSessionListener listener = new ScriptSessionListener() {  
  22.             public void sessionCreated(ScriptSessionEvent ev) {  
  23.   
  24.             }  
  25.   
  26.             public void sessionDestroyed(ScriptSessionEvent ev) {  
  27.                 if (RemoteMessageConstant.getMappingList().get(ev.getSession().getId()) != null) {  
  28.                     ScriptSession scriptSession = RemoteMessageConstant.getMappingList().get(ev.getSession().getId());  
  29.                     sendMessage(scriptSession,"receiveMessages","客户端已关闭!");  
  30.                 }  
  31.                 // 删除该用户的列表信息  
  32.                 RemoteMessageConstant.getMapList().remove(ev.getSession().getId());  
  33.                 RemoteMessageConstant.getMappingList().remove(ev.getSession().getId());  
  34.                 RemoteMessageConstant.getServerList().remove(ev.getSession().getId());  
  35.                 RemoteMessageConstant.getUserNamList().remove(ev.getSession().getId());  
  36.                 // 更新服务端在线列表  
  37.                 RemoteMessageClient rc = new RemoteMessageClient();  
  38.                 rc.showOnlinClient();  
  39.             }  
  40.         };  
  41.         manager.addScriptSessionListener(listener);  
  42.     }  
  43.     /** 
  44.      * 调用页面JS 
  45.      * @param scriptSession,jsName:JS方法名,message:发送的信息 
  46.      */  
  47.     public void sendMessage(ScriptSession scriptSession, String jsName, String message) {  
  48.         ScriptBuffer script = new ScriptBuffer();  
  49.         script.appendCall(jsName, message);  
  50.         scriptSession.addScript(script);  
  51.     }  
  52. }  



RemoteMessageConstant 静态常量 

Java代码  基于DWR的点对点聊天实现 server---client
            
    
    博客分类: javadwr javadwr 
  1. package com.gw.medical.hospital.utils.dwr;  
  2.   
  3. import java.util.HashMap;  
  4. import java.util.Map;  
  5.   
  6. import org.directwebremoting.ScriptSession;  
  7.   
  8. public class RemoteMessageConstant {  
  9.     private static Map<String, ScriptSession> mapList = new HashMap<String, ScriptSession>();// 在线用户,Key为在线用户,Value为对应的客服,如果为空表示当前无客服接入;用户等待列表  
  10.     private static Map<String, String> userNamList = new HashMap<String, String>();// 在线用户名称  
  11.     private static Map<String, ScriptSession> mappingList = new HashMap<String, ScriptSession>();// 对应关系Map  
  12.     private static Map<String, ScriptSession> serverList = new HashMap<String, ScriptSession>();// 服务端在线列表  
  13.   
  14.     /** 
  15.      * get set 
  16.      */  
  17.     public static Map<String, ScriptSession> getMapList() {  
  18.         return mapList;  
  19.     }  
  20.   
  21.     public static void setMapList(Map<String, ScriptSession> mapList) {  
  22.         RemoteMessageConstant.mapList = mapList;  
  23.     }  
  24.   
  25.     public static Map<String, ScriptSession> getMappingList() {  
  26.         return mappingList;  
  27.     }  
  28.   
  29.     public static void setMappingList(Map<String, ScriptSession> mappingList) {  
  30.         RemoteMessageConstant.mappingList = mappingList;  
  31.     }  
  32.   
  33.     public static Map<String, ScriptSession> getServerList() {  
  34.         return serverList;  
  35.     }  
  36.   
  37.     public static void setServerList(Map<String, ScriptSession> serverList) {  
  38.         RemoteMessageConstant.serverList = serverList;  
  39.     }  
  40.   
  41.     public static Map<String, String> getUserNamList() {  
  42.         return userNamList;  
  43.     }  
  44.   
  45.     public static void setUserNamList(Map<String, String> userNamList) {  
  46.         RemoteMessageConstant.userNamList = userNamList;  
  47.     }  
  48.   
  49.   
  50. }  



serverMessage.jsp  客服页 

Java代码  基于DWR的点对点聊天实现 server---client
            
    
    博客分类: javadwr javadwr 
  1. <%@ page language="java" contentType="text/html; charset=utf-8"  pageEncoding="utf-8"%>  
  2. <!DOCTYPE html >  
  3. <html>  
  4. <head>  
  5. <meta http-equiv="Content-Type" content="text/html; charset=utf-8">  
  6. <title>Server</title>  
  7. <link rel="stylesheet" type="text/css" href="<%=request.getContextPath()%>/css/themes/default/easyui.css">  
  8. <script type="text/javascript" src="<%=request.getContextPath()%>/dwr/engine.js"> </script>  
  9. <script type='text/javascript' src='<%=request.getContextPath()%>/dwr/util.js'></script>  
  10. <script type="text/javascript" src="<%=request.getContextPath()%>/dwr/interface/RemoteMessageServer.js"> </script>  
  11. <script type="text/javascript" src="<%=request.getContextPath()%>/js/jquery-1.8.3.min.js"> </script>  
  12. <script type="text/javascript" src="<%=request.getContextPath()%>/js/jquery.easyui.min.js"> </script>  
  13. <script type="text/javascript">  
  14.     $(function(){  
  15.         dwr.engine.setActiveReverseAjax(true);  
  16.         dwr.engine.setNotifyServerOnPageUnload(true);  
  17.         onPageLoad();  
  18.         //对话框初始化  
  19.         $("#messageDialog").dialog({  
  20.             title:'对话框',  
  21.             width:600,  
  22.             height:550,  
  23.             closed:false,  
  24.             cache:false  
  25.         });  
  26.     });  
  27.       function sendMessage(message) {  
  28.             // 通过代理调用后台的addMessage方法发送消息  
  29.             RemoteMessageServer.addMessage(message);  
  30.     }  
  31.     // 前台接受消息的方法,由后台调用   
  32.       function receiveMessages(messages) {  
  33.             var p=$("  
  34. ");  
  35.             $(p).append(messages);  
  36.             $("#messageContent").append(p);  
  37.       }  
  38.         
  39.       //读取name值作为推送的唯一标示  
  40.       function onPageLoad(){  
  41.         // 通过代理,传入区别本页面的唯一标识符  
  42.         RemoteMessageServer.onPageLoad();  
  43.        }  
  44.        function selectClient(){  
  45.            RemoteMessageServer.selectClient({  
  46.                callback:function(clientName) {   
  47.                   if(clientName=="")  
  48.                       alert("选择失败!")  
  49.                   else  
  50.                      $("#messageContent").append("客户:"+clientName+",已成功接入!"+"<br/>");  
  51.                      $("#messageDialog").dialog({title:'客户:'+clientName});  
  52.                }  
  53.                  
  54.            });  
  55.        }  
  56.        function showOnlinClient(str){  
  57.            $(".onlineUser").html(str);  
  58.        }  
  59.         /** 
  60.      * 页面JS 
  61.      */  
  62.      function showIcon(){  
  63.         if($("#icondiv").css("display")=="none"){  
  64.             $("#icondiv").css("display","block");  
  65.         }else{  
  66.             $("#icondiv").css("display","none");  
  67.         }  
  68.      }  
  69.      function addIcon(str){  
  70.          var img=$('<img src="<%=request.getContextPath()%>/images/dwr/'+str+'.gif"/>');  
  71.          $("#messageTextArea").append($(img));  
  72.      }  
  73.      function jsSendMessage(){  
  74.          var message=$("#messageTextArea").html();  
  75.          $("#messageContent").append("我:"+message+"<br/>");  
  76.          $("#messageTextArea").html("");  
  77.          this.sendMessage(message);  
  78.      }  
  79.           
  80. </script>  
  81. <style type="text/css">  
  82.     #icondiv ul{  
  83.         width: 400px;   
  84.         height: 130px;  
  85.         overflow: auto;  
  86.         border: 1px solid black;  
  87.     }  
  88.     #icondiv ul li{  
  89.         float: left;  
  90.         width: 45px;  
  91.         list-style: none;  
  92.           
  93.     }  
  94.     #icondiv ul li img{  
  95.         width: 40px;  
  96.         height: 40px;  
  97.     }  
  98. </style>  
  99. </head>  
  100. <body>  
  101.     [align=center;]  
  102.             [url=javascript:void(0)]发送[/url]  
  103.             [/align]  
  104.         </div>  
  105.     </div>  
  106.     <div><input type="button" onclick="selectClient()" value="selectClient"/></div>  
  107.     [align=center;]  
  108.             [url=javascript:void(0)]发送[/url]  
  109.             [/align]  
  110.         </div>  
  111.     </div>  
  112. </body>  
  113. </html>  
相关标签: java dwr