本文转自:http://htj1231825.iteye.com/blog/2206526
RemoteMessageServer 客服类
- 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>
相关推荐
【基于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应用方面的...