HTML5WebSocket实现点对点聊天
昨天使用html5的websocket与tomcat实现了多人聊天,那是最简单也是最基本的,其中注意的就是开发环境,要满足jdk1.7和tomcat8,当然了tom7 的7.063也行!
今天是国庆的最后一天,苦逼的加班,继续搞代码!令人欣慰的是,我用google找到了关于websocket的点对点聊天,更好的是可以和大多数很好的配合起来看下效果图
因为是模拟的,这里给出的是两个jsp页面a和b,里面分别向session里放了两个名字小明和小化,注意,这里的session是httpsession session,之前多人聊天里的session是javax.websocket.session;不一样的。
这里想一下, 使用httpsession session控制聊天的用户,好处怎样,自己猜~~~
这里没有使用注解,传统的web.xml配置方式,首先在系统启动的时候调用initservlet方法喎? f/ware/vc/"="" target="_blank" class="keylink">vcd4ncjxwcmugy2xhc3m9"brush:java;">
public class initservlet extends httpservlet {
private static final long serialversionuid = -3163557381361759907l;
private static hashmap
这里你可以跟自己的系统结合,对应的web配置代码如下:
websocket socket.mywebsocketservlet websocket *.do initservlet socket.initservlet 1 index.jsp
这就是最普通的前台像后台发送请求的过程,也是很容易嵌入到自己的系统里
mywebsocketservlet:
public class mywebsocketservlet extends websocketservlet { public string getuser(httpservletrequest request){ string username = (string) request.getsession().getattribute(user); if(username==null){ return null; } return username; } protected streaminbound createwebsocketinbound(string arg0, httpservletrequest request) { system.out.println(用户 + request.getsession().getattribute(user) + 登录); return new mymessageinbound(this.getuser(request)); } }
mymessageinbound继承messageinbound
package socket; import java.io.ioexception; import java.nio.bytebuffer; import java.nio.charbuffer; import java.util.hashmap; import org.apache.catalina.websocket.messageinbound; import org.apache.catalina.websocket.wsoutbound; import util.messageutil; public class mymessageinbound extends messageinbound { private string name; public mymessageinbound() { super(); } public mymessageinbound(string name) { super(); this.name = name; } @override protected void onbinarymessage(bytebuffer arg0) throws ioexception { } @override protected void ontextmessage(charbuffer msg) throws ioexception { //用户所发消息处理后的map hashmap messagemap = messageutil.getmessage(msg); //处理消息类 //上线用户集合类map hashmap usermsgmap = initservlet.getsocketlist(); string fromname = messagemap.get(fromname); //消息来自人 的userid string toname = messagemap.get(toname); //消息发往人的 userid //获取该用户 messageinbound messageinbound = usermsgmap.get(toname); //在仓库中取出发往人的messageinbound messageinbound messagefrominbound = usermsgmap.get(fromname); if(messageinbound!=null && messagefrominbound!=null){ //如果发往人 存在进行操作 wsoutbound outbound = messageinbound.getwsoutbound(); wsoutbound outfrombound = messagefrominbound.getwsoutbound(); string content = messagemap.get(content); //获取消息内容 string msgcontentstring = fromname + 说: + content; //构造发送的消息 //发出去内容 charbuffer tomsg = charbuffer.wrap(msgcontentstring.tochararray()); charbuffer frommsg = charbuffer.wrap(msgcontentstring.tochararray()); outfrombound.writetextmessage(frommsg); outbound.writetextmessage(tomsg); // outfrombound.flush(); outbound.flush(); } } @override protected void onclose(int status) { initservlet.getsocketlist().remove(this); super.onclose(status); } @override protected void onopen(wsoutbound outbound) { super.onopen(outbound); //登录的用户注册进去 if(name!=null){ initservlet.getsocketlist().put(name, this);//存放客服id与用户 } } @override public int getreadtimeout() { return 0; } }
在ontextmessage中处理前台发出的信息,并封装信息传给目标
还有一个messageutil
package util; import java.nio.charbuffer; import java.util.hashmap; public class messageutil { public static hashmap getmessage(charbuffer msg) { hashmap map = new hashmap(); string msgstring = msg.tostring(); string m[] = msgstring.split(,); map.put(fromname, m[0]); map.put(toname, m[1]); map.put(content, m[2]); return map; } }
当然了,前台也要按照规定的格式传信息
<%@ page language=java contenttype=text/html; charset=utf-8 pageencoding=utf-8%>
'; } ws.onclose = function(evt) { //alert(close); document.getelementbyid('denglu').innerhtml=离线; }; ws.onopen = function(evt) { //alert(open); document.getelementbyid('denglu').innerhtml=在线; document.getelementbyid('username').innerhtml='小化'; }; } function sendmsg() { var fromname = 小化; var toname = document.getelementbyid('name').value; //发给谁 var content = document.getelementbyid('writemsg').value; //发送内容 ws.send(fromname+,+toname+,+content);//注意格式 } </script>
聊天功能实现
登录状态: 正在登录
登录人:
发送给谁:
发送内容:
聊天框:
这是a.jsp页面,b同上
通过以上代码,就可以实现一个点对点的聊天功能,如果做的大,可以做成一个web版的聊天系统,包括聊天室和单人聊天,都说websocket不支持二进制的传输,但是看到个大流说了这样的话
不过现在做下来 感觉使用二进制的意义不是很大。很久以前就一直困混,怎么都说js不支持二进制,发现其实只是一堆坑货对这个没研究。。(用的是filereader)
喎?>
下一篇: “不看新闻联播是下等人”引热议