使用websocket建立长链接实现用户点对点即时通讯

WebSocket是一种网络传输协议，位于OSI模型的应用层，设计用于在单个TCP连接上进行全双工通信。

WebSocket的主要特点包括：

全双工通信：WebSocket允许服务器和客户端之间进行双向实时通信。这与传统的HTTP请求不同，后者通常需要客户端发起请求后才能接收响应。
持久性连接：使用WebSocket时，客户端和服务器完成一次握手之后，就可以建立一个持久性的连接，并通过这个连接进行多次数据交换，而不需要每次通信都重新建立连接。
轻量级数据格式：WebSocket的数据格式相对轻量，性能开销小，这使得通信高效。
兼容性：WebSocket与HTTP有良好的兼容性，它的默认端口是80（ws）和443（wss），且握手阶段采用HTTP协议，因此能通过各种HTTP代理服务器。
无同源限制：WebSocket没有同源限制，客户端可以与任意服务器通信。

总的来说，WebSocket作为一种先进的通信技术，它解决了传统HTTP在实时通信方面的不足，为现代网络应用提供了快速、高效的通信方式。

以下是使用Spring Boot和WebSocket实现用户之间在线即时通讯的代码逻辑：

1. 添加依赖

在pom.xml文件中添加以下依赖：

dependency>
    groupId>org.springframework.boot/groupId>
    artifactId>spring-boot-starter-websocket/artifactId>
/dependency>

2. 配置WebSocket

创建一个WebSocket配置类，例如WebSocketConfig.java，并添加以下代码：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
import org.springframework.web.socket.handler.TextWebSocketHandler;

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(myHandler(), "/myHandler").setAllowedOrigins("*");
    }

    @Bean
    public TextWebSocketHandler myHandler() {
        return new MyHandler();
    }

}

3. 创建WebSocket处理器

创建一个WebSocket处理器类，例如MyHandler.java，并添加以下代码：

import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;

import java.io.IOException;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public class MyHandler extends TextWebSocketHandler {

    private static MapString, WebSocketSession> users = new ConcurrentHashMap>();

    @Override
    public void afterConnectionEstablished(WebSo服务器托管网cketSession session) throws Exception {
        String userId = session.getUri().toString().split("/")[4];
        users.put(userId, session);
    }

    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        String userId = session.getUri().toString().split("/")[4];
        String content = message.getPayload();
        // 处理消息内容，例如转发给其他用户或存储到数据库等
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        String userId = session.getUri().toString().split("/")[4];
        users.remove(userId);
    }

    public static void sendMessageToUser(String userId, String message) {
        WebSocketSession session = users.get(userId);
        if (session != null && session.isOpen()) {
            try {
                session.sendMessage(new TextMessage(message));
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

}

4. 前端页面

在前端页面中，可以使用JavaScript建立WebSocket连接，并发送和接收消息。例如：

DOCTYPE html>
html>
head>
    meta charset="UTF-8">
    title>WebSocket示例title>
    script>
        var socket;
        function connect() {
            var userId = document.getElementById("userId").value;
            socket = new WebSocket("ws://localhost:8080/myHandler/" + userId);
            socket.onopen = function () {
                console.log("连接成功");
            };
            socket.onmessage = function (event) {
                var message = event.data;
                console.log("收到消息：" + message);
            };
            socket.onclose = function () {
                console.log("连接关闭");
            };
        }
        function sendMessage() {
            var message = document.getElementById("message").value;
            socket.send(message);
        }
    script>
head>
body>
服务器托管网    input type="text" id="userId" placeholder="输入用户ID">
    button onclick="connect()">连接button>
    br>
    input type="text" id="message" placeholder="输入消息内容">
    button onclick="sendMessage()">发送消息button>
body>
html>

这样，当用户连接到WebSocket服务器时，他们的会话将被添加到users映射中。当用户发送消息时，可以在handleTextMessage方法中处理消息内容，例如转发给其他用户或存储到数据库等。当用户断开连接时，他们的会话将从users映射中删除。

服务器托管，北京服务器托管，服务器租用 http://www.fwqtg.net

相关推荐: 得物App灰度&全量发布效率提升实践

【直播预告】国产数据库，一半都是花架子？” 服务器托管网 一、背景 得物的发布采用固定的双周迭代，在此基础上如有紧急的需求可以申请中间插入单周迭代版本，在以往的迭代发布过程中从开始准备灰度发布事宜到主要应用市场上架时间跨度较长，站在业务的角度像AB、埋点、新特…