JAVA实现webSocket网页聊天室

程序员文章站 2023-12-01 18:25:52

一、什么是webSocket WebSocket 是一种网络通信协议，是持久化协议。RFC6455 定义了它的通信标准。 WebSocket 是 HTML5 开始提供的一种在单个 TCP 连接上进行全双工通讯的协议。二、为什么要使用webSocket 传统的web通信是使用的http技术，http ......

一、什么是websocket

websocket 是一种网络通信协议，是持久化协议。rfc6455 定义了它的通信标准。

websocket 是 html5 开始提供的一种在单个 tcp 连接上进行全双工通讯的协议。

二、为什么要使用websocket

传统的web通信是使用的http技术，http协议是无状态的、无连接的、单向的应用层协议。一次请求只能对应一个响应，通信请求只能由客户端发出，服务端对请求做出响应。所以服务端发出响应是非常被动的，这种被动的响应注定了服务端无法及时的给客户端主动推送响应，如果服务端有连续的状态变化的时候，客户端获取是很困难的。通过频繁使用了异步ajax去不断地获取请求去实现长轮询，这样做是特别消耗性能，而且效率低下。（不停的握手，或者长时间保持live)。

而websocket允许服务器和客户端之间建立全双工通信，只要建立一次连接，就能一直保持连接状态。一旦建立一次连接，就能双方互相通信，不需要多次握手。

三、实现web聊天室

添加pom.xml，引入jar包

<dependency>
      <groupid>javax</groupid>
         <artifactid>javaee-api</artifactid>
         <version>7.0</version>
         <scope>provided</scope>
 </dependency>

2.建立html和js文件

<!doctype html>
<html>
<head>
<meta charset="utf-8">
<title>在线聊天室</title>
<script type="text/javascript" src="./static/jquery-3.2.0.min.js"></script>
<!-- 最新版本的 bootstrap 核心 css 文件 -->
<link rel="stylesheet" href="https://cdn.bootcss.com/bootstrap/3.3.7/css/bootstrap.min.css" integrity="sha384-bvyiisifek1dgmjrakycuhahrg32omucww7on3rydg4va+pmstsz/k68vbdejh4u" crossorigin="anonymous">
<!-- 最新的 bootstrap 核心 javascript 文件 -->
<script src="https://cdn.bootcss.com/bootstrap/3.3.7/js/bootstrap.min.js" integrity="sha384-tc5iqib027qvyjsmfhjomalkfuwvxzxupncja7l2mcwnipg9mgcd8wgnicpd7txa" crossorigin="anonymous"></script>
</head>
<body>
  <div>
    <div><span>聊天室</span>
         <button class="btn btn-warning" onclick="doclose();">退出聊天</button>
    </div>
    <div><textarea class="form-control" style="width: 40%;" rows="3" id="contentinp"></textarea></div><hr/>
    <div><button class="btn btn-danger" onclick="doclear();">清空会话框</button></div>
    <div id="content">开始聊天<br/></div>
  </div>
</body>
<script type="text/javascript">
   var ws = new websocket("ws://localhost:8080/ws/websocket"); //controller层url
   $(function(){
       $("#contentinp").keyup(function(evt){
           if(evt.which == 13){ //enter键发送消息
               var htm = $("#contentinp").val();
               dosend(htm);
               $("textarea").empty();
           }
       });
   })
   
   ws.onopen = function(){
       appendhtm("连接成功！");
   }
   
   // 从服务端接收到消息，将消息回显到聊天记录区
   ws.onmessage = function(evt){
       appendhtm(evt.data);
   }
   
   ws.onerror = function(){
       appendhtm("连接失败！");
   }
   
   ws.onclose = function(){
       appendhtm("连接关闭！");
   }
   
   function appendhtm(htm){
       ($("#content")[0]).innerhtml += htm +"<br/>" 
   }
   
   // 注销登录
   function doclose(){
       ws.close();
   }
   
   // 发送消息
   function dosend(htm){
      // ($("#content")[0]).innerhtml += htm +"<br/>" 
       ws.send(htm);
   }
   
   function doclear(){
       $("#content").empty();
   }
</script>
</html>

view code

3.后台java代码

package controller;

import java.io.ioexception;
import java.util.concurrent.copyonwritearrayset;

import javax.net.ssl.sslsession;
import javax.websocket.onclose;
import javax.websocket.onerror;
import javax.websocket.onmessage;
import javax.websocket.onopen;
import javax.websocket.session;
import javax.websocket.server.serverendpoint;

@serverendpoint("/websocket")
public class webscoketserver {

    private static integer onlinenum = 0; //当前在线人数，线程必须设计成安全的
    private static copyonwritearrayset<webscoketserver> arrayset = new copyonwritearrayset<webscoketserver>(); //存放每一个客户的的webscoketserver对象，线程安全
    private session session;
    
    /**
     * 连接成功
     * @param session 会话信息
     */
    @onopen
    public void onopen(session session) {
        this.session =session;
        arrayset.add(this);
        this.addonlinenum();
        system.out.println("有一个新连接加入，当前在线 "+this.getonlinenum()+" 人");
    }
    
    /**
     * 连接关闭
     */
    @onclose
    public void onclose() {
        arrayset.remove(this);
        this.subonlinenum();
        system.out.println("有一个连接断开，当前在线 "+this.getonlinenum()+" 人");
    }
    
    /**
     * 连接错误
     * @param session
     * @param error
     */
    @onerror
    public void onerror(session session, throwable error) {
        system.err.println("发生错误！");
        error.printstacktrace();
    }
    
    /**
     * 发送消息,不加注解，自己选择实现
     * @param msg
     * @throws ioexception
     */
    public void onsend(string msg) throws ioexception {
        this.session.getbasicremote().sendtext(msg);
    }
    
    /**
     * 收到客户端消息回调方法
     * @param session
     * @param msg
     */
    @onmessage
    public void onmessage(session session, string msg) {
        system.out.println("消息监控："+msg);
        for (webscoketserver webscoketserver : arrayset) {
            try {
                webscoketserver.onsend(msg);
            } catch (ioexception e) {
                e.printstacktrace();
                continue;
            }
        }
    }
    /**
     * 增加一个在线人数
     */
    private synchronized void addonlinenum() {
        onlinenum++;
    }
    
    /**
     * 减少一个在线人数
     */
    private synchronized void subonlinenum() {
        onlinenum--;
    }
    
    private integer getonlinenum() {
        return onlinenum;
    }
}

view code

4.完成后效果

JAVA实现webSocket网页聊天室