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

HTML5WebSocket实现点对点聊天

程序员文章站 2022-07-09 12:48:16
昨天使用html5的websocket与tomcat实现了多人聊天,那是最简单也是最基本的,其中注意的就是开发环境,要满足jdk1.7和tomcat8,当然了tom7 的7.063也行! 今天是国庆...

昨天使用html5的websocket与tomcat实现了多人聊天,那是最简单也是最基本的,其中注意的就是开发环境,要满足jdk1.7和tomcat8,当然了tom7 的7.063也行!
今天是国庆的最后一天,苦逼的加班,继续搞代码!令人欣慰的是,我用google找到了关于websocket的点对点聊天,更好的是可以和大多数很好的配合起来看下效果图
HTML5WebSocket实现点对点聊天
因为是模拟的,这里给出的是两个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 socketlist; public void init(servletconfig config) throws servletexception { initservlet.socketlist = new hashmap(); super.init(config); system.out.println(初始化聊天容器); } public static hashmap getsocketlist() { return initservlet.socketlist; } },messageinbound>,messageinbound>,messageinbound>

这里你可以跟自己的系统结合,对应的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%>

<script type=text/javascript src=js/jquery-1.7.2.min.js></script><%session.setattribute(user, 小化);%> <script type=text/javascript> var ws = null; function startwebsocket() { if ('websocket' in window) ws = new websocket(ws://localhost:8080/websocketuser/websocket.do); else if ('mozwebsocket' in window) ws = new mozwebsocket(ws://localhost:8080/websocketuser/websocket.do); else alert(not support); ws.onmessage = function(evt) { //alert(evt.data); console.log(evt); // $(#xiaoxi).val(evt.data); setmessageinnerhtml(evt.data); }; function setmessageinnerhtml(innerhtml){ document.getelementbyid('message').innerhtml += innerhtml + '
'; } 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)

 

喎?>