Websocket(一)简单的demo实现

红太狼 2022-06-08 08:24 171阅读 0赞

首先是jar包依赖导入

<dependency>
                <groupId>javax.websocket</groupId>
                <artifactId>javax.websocket-api</artifactId>
                <version>1.1</version>
                <scope>provided</scope> 
            </dependency>
            <dependency>
                <groupId>javax</groupId>
                <artifactId>javaee-api</artifactId>
                <version>7.0</version>
            </dependency>

接着搭建服务器

import java.io.IOException;
    import java.util.concurrent.CopyOnWriteArraySet;
    
    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;
    
    /** * @author szd * @content 聊天室 * * http://127.0.0.1:8080/user/roomChat.jsp * @date 2017年9月13日 */
    @ServerEndpoint("/roomChat") // 该注解在tomcat8.0以上支持
    public class ChatInRoomWebsocket { 
    
        // 静态变量，用来记录当前房间数量
        private static int onlineCount = 0;
    
        // concurrent包的线程安全Set，用来存放每个客户端对应的ChatInRoomWebsocket对象。
        // 若要实现服务端与单一客户端通信的话，可以使用Map来存放，其中Key可以为用户标识
        private static CopyOnWriteArraySet<ChatInRoomWebsocket> webSocketSet = new CopyOnWriteArraySet<ChatInRoomWebsocket>();
    
        // 与某个客户端的连接会话，需要通过它来给客户端发送数据
        private Session session;
    
        /** * 连接建立成功调用的方法 * * @param session * 可选的参数。session为与某个客户端的连接会话，需要通过它来给客户端发送数据 */
        @OnOpen
        public void onOpen(Session session) {
            this.session = session;
            webSocketSet.add(this); // 加入set中
            addOnlineCount(); // 在线数加1
            System.out.println(session.getId() + "，加入聊天室！当前在线人数为" + getOnlineCount());
        }
    
        /** * 连接关闭调用的方法 */
        @OnClose
        public void onClose() {
            webSocketSet.remove(this); // 从set中删除
            subOnlineCount(); // 在线数减1
            System.out.println(session.getId() + "，退出聊天室！当前在线人数为" + getOnlineCount());
        }
    
        /** * 收到客户端消息后调用的方法 * * @param message * 客户端发送过来的消息 * @param session * 可选的参数 */
        @OnMessage
        public void onMessage(String message, Session session) {
            System.out.println("来自客户端的消息:" + message);
            // 群发消息
            for (ChatInRoomWebsocket item : webSocketSet) {
                try {
                    item.sendMessage(session.getId() + ":" + message);
                } catch (IOException e) {
                    e.printStackTrace();
                    continue;
                }
            }
        }
    
        /** * 发生错误时调用 * * @param session * @param error */
        @OnError
        public void onError(Session session, Throwable error) {
            System.out.println("发生错误");
            error.printStackTrace();
        }
    
        /** * 这个方法与上面几个方法不一样。没有用注解，是根据自己需要添加的方法。 * * @param message * @throws IOException */
        public void sendMessage(String message) throws IOException {
            this.session.getBasicRemote().sendText(message);
        }
    
        public static synchronized int getOnlineCount() {
            return onlineCount;
        }
    
        public static synchronized void addOnlineCount() {
            ChatInRoomWebsocket.onlineCount++;
        }
    
        public static synchronized void subOnlineCount() {
            ChatInRoomWebsocket.onlineCount--;
        }
    
    }

搭建客户端页面(roomChat.jsp)：

<%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%>
    <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
    <html>
    <head>
    <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
    <title>room chat</title>
    </head>
    <script type="text/javascript"> var websocket = null; //判断当前浏览器是否支持WebSocket if ('WebSocket' in window) { //socket目标地址结构：ip+端口+项目名+endPoint websocket = new WebSocket("ws://localhost:8080/user/roomChat"); } else { alert('当前浏览器 Not support websocket') } //连接发生错误的回调方法 websocket.onerror = function() { setMessageInnerHTML("WebSocket连接发生错误"); }; //连接成功建立的回调方法 websocket.onopen = function() { setMessageInnerHTML("WebSocket连接成功"); } //接收到消息的回调方法 websocket.onmessage = function(event) { setMessageInnerHTML(event.data); } //连接关闭的回调方法 websocket.onclose = function() { setMessageInnerHTML("WebSocket连接关闭"); } //监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。 window.onbeforeunload = function() { closeWebSocket(); } //将消息显示在网页上 function setMessageInnerHTML(innerHTML) { document.getElementById('message').innerHTML += innerHTML + '<br/>'; } //关闭WebSocket连接 function closeWebSocket() { websocket.close(); } //发送消息 function send() { var message = document.getElementById('text').value; websocket.send(message); } </script>
    <body>
        Welcome
        <br />
        <input id="text" type="text" />
        <button onclick="send()">发送消息</button>
        <hr />
        <button onclick="closeWebSocket()">关闭WebSocket连接</button>
        <hr />
        <div id="message"></div>
    </body>
    </html>