- 浏览: 39821 次
- 性别:
- 来自: 北京
最新评论
-
fengzhaoyang:
serverMessage.jsp 代码不全吧客户端的jsp页 ...
基于DWR的点对点聊天实现 server---client
RemoteMessageServer 客服类
RemoteMessageClient 客户端
DwrScriptSessionManagerUtil 监听
RemoteMessageConstant 静态常量
serverMessage.jsp 客服页
package com.gw.medical.hospital.utils.dwr; import java.util.Iterator; import java.util.Map; import javax.servlet.http.HttpSession; import org.directwebremoting.ScriptBuffer; import org.directwebremoting.ScriptSession; import org.directwebremoting.WebContextFactory; import org.directwebremoting.annotations.RemoteMethod; import org.directwebremoting.annotations.RemoteProxy; @RemoteProxy(name = "RemoteMessageServer") public class RemoteMessageServer { /** *服务端初始化 */ @RemoteMethod public void onPageLoad() { getHttpSession().setAttribute("userInfo", "CustomerService1"); // 测试用,存入模拟userInfo信息 RemoteMessageConstant.getServerList().put(getScriptSession().getId(), getScriptSession());// 存储当前客服,到在线客服列表 } /** * 服务端发送信息 * * @param message */ @RemoteMethod public void addMessage(final String message) { HttpSession httpsession = getHttpSession();// 获取session String clientName = httpsession.getAttribute("clientName") == null ? "" : httpsession.getAttribute("clientName").toString();// 当前客户端ID ScriptSession session = RemoteMessageConstant.getMapList().get(clientName);// 根据clientName获取scriptSession; if (session != null) { // 发送消息 String serverMessage=getHttpSession().getAttribute("userInfo").toString(); serverMessage=serverMessage+":"+message; sendMessage(session,"receiveMessages",serverMessage); } } /** * 选择下一个客户端 * * @return boolean */ @RemoteMethod public String selectClient() { addMessage("本次会话结束!感谢您的咨询!"); // 销毁上一位客户 removeClient(); ScriptSession sessionServer = getScriptSession();// 获取客服ScriptSsession HttpSession httpsession = getHttpSession();// 获取session Map<String, ScriptSession> userMap = RemoteMessageConstant.getMapList();// 用户在线MAP Iterator<String> iterator = userMap.keySet().iterator(); String clientName = "";// 获取客户端列表中的,clientName; while (iterator.hasNext()) { // 判断当前用户是否有客服接入,如未接入,接入该客户 String tempName = iterator.next(); if (RemoteMessageConstant.getMappingList().get(tempName) == null) { clientName = tempName; break; } } ScriptSession session = userMap.get(clientName);// 根据clientName获取scriptSession; // 更改客户端的服务ID if (session != null) { // 调用页面JS sendMessage(session, "setServerName", httpsession.getAttribute("userInfo").toString()); httpsession.setAttribute("clientName", clientName);// 存储当前客户ID RemoteMessageConstant.getMappingList().put(session.getId(), sessionServer);// 存储对应关系,到关系MAP return RemoteMessageConstant.getUserNamList().get(clientName); } return ""; } /** * 销毁当前,服务端对应的客户端信息 */ public void removeClient() { HttpSession httpSession = getHttpSession();// 获取httpsession String clientName = httpSession.getAttribute("clientName") == null ? "" : httpSession.getAttribute("clientName").toString(); RemoteMessageConstant.getMappingList().remove(clientName);// 从关系Map中,删除对应关系。 RemoteMessageConstant.getMapList().remove(clientName);// 从用户Map中,删除该用户; RemoteMessageConstant.getUserNamList().remove(clientName);//从用户名列表 删除该用户名 httpSession.removeAttribute("clientName");// 删除当前服务端的,客户ID } /** * 调用页面JS * @param scriptSession,jsName:JS方法名,message:发送的信息 */ public void sendMessage(ScriptSession scriptSession, String jsName, String message) { ScriptBuffer script = new ScriptBuffer(); script.appendCall(jsName, message); scriptSession.addScript(script); } /** * get set */ public ScriptSession getScriptSession() { return WebContextFactory.get().getScriptSession(); } public HttpSession getHttpSession() { return WebContextFactory.get().getSession(); } }
RemoteMessageClient 客户端
package com.gw.medical.hospital.utils.dwr; import java.util.Collection; import java.util.Iterator; import javax.servlet.ServletException; import javax.servlet.http.HttpSession; import org.directwebremoting.Browser; import org.directwebremoting.ScriptBuffer; import org.directwebremoting.ScriptSession; import org.directwebremoting.ScriptSessionFilter; import org.directwebremoting.WebContextFactory; import org.directwebremoting.annotations.RemoteMethod; import org.directwebremoting.annotations.RemoteProxy; @RemoteProxy(name = "RemoteMessageClient") public class RemoteMessageClient { /** * 客户端初始化 */ @RemoteMethod public void onPageLoadClient() { ScriptSession scriptSession = getScriptSession(); HttpSession httpSession = getHttpSession(); String clientName = scriptSession.getId();// 获取seciptSessionID作为clientName httpSession.setAttribute("clientName", clientName); RemoteMessageConstant.getMapList().put(clientName, scriptSession);// 存储用户信息到在线用户列表 RemoteMessageConstant.getUserNamList().put(clientName, "游客"); // 服务器显示在线用户列表; showOnlinClient(); DwrScriptSessionManagerUtil dssm = new DwrScriptSessionManagerUtil(); try { dssm.init(); } catch (ServletException e) { e.printStackTrace(); } } /** * 客户端发送信息 * * @param message */ @RemoteMethod public void addMessageClient(String message) { HttpSession httpSession = getHttpSession(); String clientName = httpSession.getAttribute("clientName") == null ? "" : httpSession.getAttribute("clientName").toString();// 获取当前登录客户端ID,在用户列表中查找相应客服 String autoMessage = message;// 发送的内容 ScriptSession scriptSession = RemoteMessageConstant.getMappingList().get(clientName);// 从对应Map中获取,当前客户端对应的服务端ScriptSession if (scriptSession != null) { String clientMessage=RemoteMessageConstant.getUserNamList().get(clientName); clientMessage+=":"+autoMessage; sendMessage(scriptSession,"receiveMessages",clientMessage); } } /** * 更改服务端在线用户列表 */ public void showOnlinClient() { Browser.withAllSessionsFiltered(new ScriptSessionFilter() { // 筛选scriptSession的用户,发送目标ID,是否在scriptSession中存在 public boolean match(ScriptSession session) { if (RemoteMessageConstant.getServerList().get(session.getId()) != null) { return true; } else { return false; } } }, new Runnable() { private ScriptBuffer script = new ScriptBuffer(); public void run() { // 输出内容到页面 Iterator<String> it = RemoteMessageConstant.getMapList().keySet().iterator(); String autoMessage = new String(); while (it.hasNext()) { String key = it.next().toString(); // 如果没有被分配客服,显示在等待列表中 if (RemoteMessageConstant.getMappingList().get(key) == null) { autoMessage += RemoteMessageConstant.getUserNamList().get(key) + ";"; } } script.appendCall("showOnlinClient", autoMessage); Collection<ScriptSession> sessions = Browser.getTargetSessions(); for (ScriptSession scriptSession : sessions) { scriptSession.addScript(script); } } }); } /** * get set */ /** * 调用页面JS * * @param scriptSession * ,jsName:JS方法名,message:发送的信息 */ public void sendMessage(ScriptSession scriptSession, String jsName, String message) { ScriptBuffer script = new ScriptBuffer(); script.appendCall(jsName, message); scriptSession.addScript(script); } public ScriptSession getScriptSession() { return WebContextFactory.get().getScriptSession(); } public HttpSession getHttpSession() { return WebContextFactory.get().getSession(); } }
DwrScriptSessionManagerUtil 监听
package com.gw.medical.hospital.utils.dwr; import javax.servlet.ServletException; import org.directwebremoting.Container; import org.directwebremoting.ScriptBuffer; import org.directwebremoting.ScriptSession; import org.directwebremoting.ServerContextFactory; import org.directwebremoting.event.ScriptSessionEvent; import org.directwebremoting.event.ScriptSessionListener; import org.directwebremoting.extend.ScriptSessionManager; import org.directwebremoting.servlet.DwrServlet; public class DwrScriptSessionManagerUtil extends DwrServlet { private static final long serialVersionUID = -7504612622407420071L; public void init() throws ServletException { Container container = ServerContextFactory.get().getContainer(); ScriptSessionManager manager = container.getBean(ScriptSessionManager.class); ScriptSessionListener listener = new ScriptSessionListener() { public void sessionCreated(ScriptSessionEvent ev) { } public void sessionDestroyed(ScriptSessionEvent ev) { if (RemoteMessageConstant.getMappingList().get(ev.getSession().getId()) != null) { ScriptSession scriptSession = RemoteMessageConstant.getMappingList().get(ev.getSession().getId()); sendMessage(scriptSession,"receiveMessages","客户端已关闭!"); } // 删除该用户的列表信息 RemoteMessageConstant.getMapList().remove(ev.getSession().getId()); RemoteMessageConstant.getMappingList().remove(ev.getSession().getId()); RemoteMessageConstant.getServerList().remove(ev.getSession().getId()); RemoteMessageConstant.getUserNamList().remove(ev.getSession().getId()); // 更新服务端在线列表 RemoteMessageClient rc = new RemoteMessageClient(); rc.showOnlinClient(); } }; manager.addScriptSessionListener(listener); } /** * 调用页面JS * @param scriptSession,jsName:JS方法名,message:发送的信息 */ public void sendMessage(ScriptSession scriptSession, String jsName, String message) { ScriptBuffer script = new ScriptBuffer(); script.appendCall(jsName, message); scriptSession.addScript(script); } }
RemoteMessageConstant 静态常量
package com.gw.medical.hospital.utils.dwr; import java.util.HashMap; import java.util.Map; import org.directwebremoting.ScriptSession; public class RemoteMessageConstant { private static Map<String, ScriptSession> mapList = new HashMap<String, ScriptSession>();// 在线用户,Key为在线用户,Value为对应的客服,如果为空表示当前无客服接入;用户等待列表 private static Map<String, String> userNamList = new HashMap<String, String>();// 在线用户名称 private static Map<String, ScriptSession> mappingList = new HashMap<String, ScriptSession>();// 对应关系Map private static Map<String, ScriptSession> serverList = new HashMap<String, ScriptSession>();// 服务端在线列表 /** * get set */ public static Map<String, ScriptSession> getMapList() { return mapList; } public static void setMapList(Map<String, ScriptSession> mapList) { RemoteMessageConstant.mapList = mapList; } public static Map<String, ScriptSession> getMappingList() { return mappingList; } public static void setMappingList(Map<String, ScriptSession> mappingList) { RemoteMessageConstant.mappingList = mappingList; } public static Map<String, ScriptSession> getServerList() { return serverList; } public static void setServerList(Map<String, ScriptSession> serverList) { RemoteMessageConstant.serverList = serverList; } public static Map<String, String> getUserNamList() { return userNamList; } public static void setUserNamList(Map<String, String> userNamList) { RemoteMessageConstant.userNamList = userNamList; } }
serverMessage.jsp 客服页
<%@ page language="java" contentType="text/html; charset=utf-8" pageEncoding="utf-8"%> <!DOCTYPE html > <html> <head> <meta http-equiv="Content-Type" content="text/html; charset=utf-8"> <title>Server</title> <link rel="stylesheet" type="text/css" href="<%=request.getContextPath()%>/css/themes/default/easyui.css"> <script type="text/javascript" src="<%=request.getContextPath()%>/dwr/engine.js"> </script> <script type='text/javascript' src='<%=request.getContextPath()%>/dwr/util.js'></script> <script type="text/javascript" src="<%=request.getContextPath()%>/dwr/interface/RemoteMessageServer.js"> </script> <script type="text/javascript" src="<%=request.getContextPath()%>/js/jquery-1.8.3.min.js"> </script> <script type="text/javascript" src="<%=request.getContextPath()%>/js/jquery.easyui.min.js"> </script> <script type="text/javascript"> $(function(){ dwr.engine.setActiveReverseAjax(true); dwr.engine.setNotifyServerOnPageUnload(true); onPageLoad(); //对话框初始化 $("#messageDialog").dialog({ title:'对话框', width:600, height:550, closed:false, cache:false }); }); function sendMessage(message) { // 通过代理调用后台的addMessage方法发送消息 RemoteMessageServer.addMessage(message); } // 前台接受消息的方法,由后台调用 function receiveMessages(messages) { var p=$(" "); $(p).append(messages); $("#messageContent").append(p); } //读取name值作为推送的唯一标示 function onPageLoad(){ // 通过代理,传入区别本页面的唯一标识符 RemoteMessageServer.onPageLoad(); } function selectClient(){ RemoteMessageServer.selectClient({ callback:function(clientName) { if(clientName=="") alert("选择失败!") else $("#messageContent").append("客户:"+clientName+",已成功接入!"+"<br/>"); $("#messageDialog").dialog({title:'客户:'+clientName}); } }); } function showOnlinClient(str){ $(".onlineUser").html(str); } /** * 页面JS */ function showIcon(){ if($("#icondiv").css("display")=="none"){ $("#icondiv").css("display","block"); }else{ $("#icondiv").css("display","none"); } } function addIcon(str){ var img=$('<img src="<%=request.getContextPath()%>/images/dwr/'+str+'.gif"/>'); $("#messageTextArea").append($(img)); } function jsSendMessage(){ var message=$("#messageTextArea").html(); $("#messageContent").append("我:"+message+"<br/>"); $("#messageTextArea").html(""); this.sendMessage(message); } </script> <style type="text/css"> #icondiv ul{ width: 400px; height: 130px; overflow: auto; border: 1px solid black; } #icondiv ul li{ float: left; width: 45px; list-style: none; } #icondiv ul li img{ width: 40px; height: 40px; } </style> </head> <body> [align=center;] [url=javascript:void(0)]发送[/url] [/align] </div> </div> <div><input type="button" onclick="selectClient()" value="selectClient"/></div> [align=center;] [url=javascript:void(0)]发送[/url] [/align] </div> </div> </body> </html>
发表评论
-
阿里巴巴JAVA开发手册
2017-02-13 13:48 592目录 一 、编程规约 编程规约 ............... ... -
druid 数据库密码加密
2017-01-23 14:59 413cmd命令: 1、切换的druid-0.2.9.jar包所在目 ... -
spring mvc 表单提交controller中文乱码
2015-03-02 16:11 1962用spring的编码器过滤所有请求,但还是有问题,最后发现是表 ... -
Hibernate hql left join
2015-01-30 17:13 11341.配置映射关系 2.from A表 left join A表 ... -
ajax 提交表单数据 到action
2015-01-27 15:11 524$.ajax({ url:'showDe ... -
easyui
2015-01-21 17:43 792$(function(){ var pageCou ... -
Jquery ImageMapste Map area
2015-01-09 09:29 782ImageMapste 可以给Map Area 添加背景色 ... -
Flex Repeater
2014-02-20 18:35 462<mx:VBox x="674" ... -
Flex Struts2 fileupload上传文件
2014-02-20 18:33 766file=new FileReference(); ... -
Myeclipse提示Jquery
2011-08-31 11:22 962项目右键properties MyEclipse -> ... -
java获取土豆视频
2011-04-02 14:03 1128通过JAVA获取土豆视频,现在很多社会网站都有这个功能,用户输 ... -
flex鱼眼菜单
2011-03-31 10:46 1805flex鱼眼菜单 -
datagrid 套combobox
2011-03-29 15:20 868<mx:DataGridColumn headerTex ... -
Web开发人员必备的20款超赞的jQuery插件
2011-02-24 08:51 766中文:http://sd.csdn.net/a/2011021 ... -
Oracle修改默认数据库,及启动关闭命令,查询连接的当前数据库
2011-02-22 09:55 2772Oracle Windows平台修改默认sid假如window ... -
JQuery的thickbox插件,弹出窗
2011-02-17 11:29 852http://jquery.com/demo/thickbox ... -
JQuery的jqzoom插件的两种使用方法
2011-02-17 09:26 5281第一种实现的方法 注意:本方法用的是jqzoom.pack.1 ... -
jQuery的appendto()移动
2011-02-16 09:45 1302var $self = obj.find("u ... -
flex 饼图缓动
2011-02-09 10:32 1263<?xml version="1.0&qu ... -
jquery图片动态加载示例
2011-01-25 09:39 2200<!DOCTYPE html PUBLIC &quo ...
相关推荐
【基于DWR推送的Web聊天系统】是一种利用Direct Web Remoting (DWR) 技术构建的实时交互式在线聊天应用。DWR是一款开源的Java库,它允许JavaScript在浏览器端与服务器端的Java对象进行直接通信,实现了AJAX(异步...
在这个"基于DWR推送技术的聊天室"项目中,我们将探讨如何利用DWR实现一个实时的在线聊天平台。 首先,让我们理解DWR的工作原理。DWR通过建立一个HTTP长连接,保持客户端与服务器端的持续通信。当服务器端有新的消息...
在这个"使用dwr实现的网页即时聊天"项目中,我们将深入探讨如何利用DWR的服务器推技术来创建一个实时的群聊系统。 1. **DWR框架**: DWR简化了JavaScript与Java之间的通信,通过在浏览器端提供动态生成的JavaScript ...
"基于DWR的AJAX技术研究与实现" 本文主要研究了基于DWR的AJAX技术的实现机制和应用。DWR是一个基于Java的开源框架,允许将服务器端的对象上的方法直接暴露给AJAX请求,从而可以直接调用服务器上的Servlet并获取处理...
综上所述,基于DWR的实时Web聊天系统利用了DWR的核心特性,实现了高效的前后端通信,提供了流畅的用户体验。通过合理的架构设计和优化,这样的系统能够满足大规模在线聊天的需求,同时也为其他实时交互应用提供了...
<servlet-name>dwr-invoker</servlet-name> <servlet-class>org.directwebremoting.servlet.DwrServlet</servlet-class> <init-param> 调试DWR,发布系统时应将其设为false <param-name>debug</param-name> ...
在本项目"jsp DWR框架推模式实现的聊天室"中,我们将探讨如何利用DWR的推送(Push)模式来构建一个实时的在线聊天应用。** 首先,我们需要了解DWR的基本工作原理。DWR通过在浏览器和服务器之间建立一个持久连接,...
**DWR(Direct Web Remoting)技术是一种在Web应用程序中实现AJAX(Asynchronous JavaScript and XML)通信的方法,它允许JavaScript直接调用Java方法,从而实现在不刷新整个页面的情况下更新部分网页内容。...
这样,你就创建了一个基于DWR的实时聊天系统,前端JavaScript与后端Java之间可以通过DWR进行高效的通信,实现了即时聊天功能。 总结来说,DWR反转实现实时聊天的关键在于正确配置`dwr.xml`和`web.xml`,以及编写...
Spring提供稳定的服务层支持,而DWR则负责实现高效的客户端和服务器通信,尤其是Server Push特性,使得聊天功能更加实时和流畅。通过合理的架构设计和安全控制,这样的聊天系统能够为用户提供优秀的交互体验。
"基于DWR的AJAX技术研究与实现" DWR(Direct Web Remoting)是一种基于Java的AJAX框架,它使得Java开发者可以轻松地在Web开发中使用AJAX技术。DWR的出现解决了Java开发者在使用AJAX技术时遇到的问题,使得Java...
DWR(Direct Web Remoting)是一种Java技术,用于在Web应用...通过以上分析,我们可以看出DWR在这个在线即时聊天系统中的关键作用,它不仅简化了前后端的交互,还实现了高效的实时通信,使得私聊功能得以流畅地运行。
DWR 在线即时聊天系统,实现了对指定用户发送消息,和即时显示功能.rarDWR 在线即时聊天系统,实现了对指定用户发送消息,和即时显示功能.rarDWR 在线即时聊天系统,实现了对指定用户发送消息,和即时显示功能.rarDWR 在线...
基于DWR的webIM系统,利用反向ajax(comet)技术和dwr框架实现了聊天室和点对点聊天的功能,项目运行起来后打开页面,输入用户名即可登录,登录后用户会显示在左侧用户框中,若想与用户私聊,在用户框中点击用户,在...
### dwr-下拉菜单实现 #### 知识点概览 本文将详细介绍如何使用DWR(Direct Web Remoting)框架结合JavaScript与HTML技术来实现动态下拉菜单功能。主要涉及的技术点包括:DWR的基本原理、如何通过DWR调用服务器端...
总结起来,DWR3的在线聊天系统是基于Java和Ajax技术的实时通信解决方案,通过`ScriptSessionListener` 和 `ScriptSessionFilter`接口,实现了会话管理和安全性控制,提供了丰富的交互体验。而具体的实现细节,包括...
**基于DWR3实现的在线客服系统** DWR (Direct Web Remoting) 是一个开源的Java库,允许JavaScript和服务器端的Java代码进行实时交互,实现了浏览器与服务器之间的双向通信,使得Web应用能够具备类似桌面应用的用户...
在这个在线聊天模块中,“基于DWR实现”意味着服务器端的业务逻辑和数据处理通过DWR来完成。当用户发送消息时,DWR将这些请求直接转发到后台,处理完成后,结果会实时反馈回前端,无需刷新页面。这种方式极大地提高...
综上所述,这个项目展示了一个基于DWR的实时聊天系统实现,它利用了J2EE的稳定性、DWR的双向通信能力、Servlet的请求处理功能以及JavaScript的客户端交互性,创建了一个无需数据库支持的高效聊天应用。用户可以进行...
总之,这个基于DWR的聊天系统实例展示了DWR在创建实时Web应用中的强大功能,包括反转Ajax、Push技术、数据流处理、加密和持久化等。通过学习这个项目,开发者可以进一步提升自己在构建高效、安全的Ajax应用方面的...