`
htj1231825
  • 浏览: 39821 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

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

阅读更多
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>
0
3
分享到:
评论
1 楼 fengzhaoyang 2015-04-29  
serverMessage.jsp 代码不全吧
客户端的jsp页面也没有

相关推荐

    基于DWR推送的web聊天系统

    【基于DWR推送的Web聊天系统】是一种利用Direct Web Remoting (DWR) 技术构建的实时交互式在线聊天应用。DWR是一款开源的Java库,它允许JavaScript在浏览器端与服务器端的Java对象进行直接通信,实现了AJAX(异步...

    基于dwr推送技术的聊天室

    在这个"基于DWR推送技术的聊天室"项目中,我们将探讨如何利用DWR实现一个实时的在线聊天平台。 首先,让我们理解DWR的工作原理。DWR通过建立一个HTTP长连接,保持客户端与服务器端的持续通信。当服务器端有新的消息...

    dwr实现的网页即时聊天

    在这个"使用dwr实现的网页即时聊天"项目中,我们将深入探讨如何利用DWR的服务器推技术来创建一个实时的群聊系统。 1. **DWR框架**: DWR简化了JavaScript与Java之间的通信,通过在浏览器端提供动态生成的JavaScript ...

    基于DWR的AJAX技术研究与实现.pdf

    "基于DWR的AJAX技术研究与实现" 本文主要研究了基于DWR的AJAX技术的实现机制和应用。DWR是一个基于Java的开源框架,允许将服务器端的对象上的方法直接暴露给AJAX请求,从而可以直接调用服务器上的Servlet并获取处理...

    基于DWR的实时web聊天系统

    综上所述,基于DWR的实时Web聊天系统利用了DWR的核心特性,实现了高效的前后端通信,提供了流畅的用户体验。通过合理的架构设计和优化,这样的系统能够满足大规模在线聊天的需求,同时也为其他实时交互应用提供了...

    java+dwr框架实现聊天室

    &lt;servlet-name&gt;dwr-invoker&lt;/servlet-name&gt; &lt;servlet-class&gt;org.directwebremoting.servlet.DwrServlet&lt;/servlet-class&gt; &lt;init-param&gt; 调试DWR,发布系统时应将其设为false &lt;param-name&gt;debug&lt;/param-name&gt; ...

    jsp DWR框架推模式实现的聊天室

    在本项目"jsp DWR框架推模式实现的聊天室"中,我们将探讨如何利用DWR的推送(Push)模式来构建一个实时的在线聊天应用。** 首先,我们需要了解DWR的基本工作原理。DWR通过在浏览器和服务器之间建立一个持久连接,...

    采用dwr技术实现的聊天室

    **DWR(Direct Web Remoting)技术是一种在Web应用程序中实现AJAX(Asynchronous JavaScript and XML)通信的方法,它允许JavaScript直接调用Java方法,从而实现在不刷新整个页面的情况下更新部分网页内容。...

    dwr反转实现及时聊天

    这样,你就创建了一个基于DWR的实时聊天系统,前端JavaScript与后端Java之间可以通过DWR进行高效的通信,实现了即时聊天功能。 总结来说,DWR反转实现实时聊天的关键在于正确配置`dwr.xml`和`web.xml`,以及编写...

    spring3+dwr3实现聊天功能

    Spring提供稳定的服务层支持,而DWR则负责实现高效的客户端和服务器通信,尤其是Server Push特性,使得聊天功能更加实时和流畅。通过合理的架构设计和安全控制,这样的聊天系统能够为用户提供优秀的交互体验。

    基于DWR的AJAX技术研究与实现 (1).pdf

    "基于DWR的AJAX技术研究与实现" DWR(Direct Web Remoting)是一种基于Java的AJAX框架,它使得Java开发者可以轻松地在Web开发中使用AJAX技术。DWR的出现解决了Java开发者在使用AJAX技术时遇到的问题,使得Java...

    DWR在线即时聊天系统,实现了对指定用户发送消息,和即时显示功能

    DWR(Direct Web Remoting)是一种Java技术,用于在Web应用...通过以上分析,我们可以看出DWR在这个在线即时聊天系统中的关键作用,它不仅简化了前后端的交互,还实现了高效的实时通信,使得私聊功能得以流畅地运行。

    DWR 在线即时聊天系统,实现了对指定用户发送消息,和即时显示功能.rar

    DWR 在线即时聊天系统,实现了对指定用户发送消息,和即时显示功能.rarDWR 在线即时聊天系统,实现了对指定用户发送消息,和即时显示功能.rarDWR 在线即时聊天系统,实现了对指定用户发送消息,和即时显示功能.rarDWR 在线...

    基于DWR的webIM系统

    基于DWR的webIM系统,利用反向ajax(comet)技术和dwr框架实现了聊天室和点对点聊天的功能,项目运行起来后打开页面,输入用户名即可登录,登录后用户会显示在左侧用户框中,若想与用户私聊,在用户框中点击用户,在...

    dwr-下拉菜单实现

    ### dwr-下拉菜单实现 #### 知识点概览 本文将详细介绍如何使用DWR(Direct Web Remoting)框架结合JavaScript与HTML技术来实现动态下拉菜单功能。主要涉及的技术点包括:DWR的基本原理、如何通过DWR调用服务器端...

    DWR3实现的在线聊天系统

    总结起来,DWR3的在线聊天系统是基于Java和Ajax技术的实时通信解决方案,通过`ScriptSessionListener` 和 `ScriptSessionFilter`接口,实现了会话管理和安全性控制,提供了丰富的交互体验。而具体的实现细节,包括...

    基于dwr3实现的在线客服系统

    **基于DWR3实现的在线客服系统** DWR (Direct Web Remoting) 是一个开源的Java库,允许JavaScript和服务器端的Java代码进行实时交互,实现了浏览器与服务器之间的双向通信,使得Web应用能够具备类似桌面应用的用户...

    这是一个用Extjs写的前端在线聊天模块,基于DWR实现!

    在这个在线聊天模块中,“基于DWR实现”意味着服务器端的业务逻辑和数据处理通过DWR来完成。当用户发送消息时,DWR将这些请求直接转发到后台,处理完成后,结果会实时反馈回前端,无需刷新页面。这种方式极大地提高...

    web聊天,私聊,群聊。dwr实现。无数据库

    综上所述,这个项目展示了一个基于DWR的实时聊天系统实现,它利用了J2EE的稳定性、DWR的双向通信能力、Servlet的请求处理功能以及JavaScript的客户端交互性,创建了一个无需数据库支持的高效聊天应用。用户可以进行...

    Dwr 推例子 反转 ajax dwr dwr推群聊 dwr聊天系统源码 聊天系统 广播系统

    总之,这个基于DWR的聊天系统实例展示了DWR在创建实时Web应用中的强大功能,包括反转Ajax、Push技术、数据流处理、加密和持久化等。通过学习这个项目,开发者可以进一步提升自己在构建高效、安全的Ajax应用方面的...

Global site tag (gtag.js) - Google Analytics