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

本文主要是介绍使用websocket建立长链接实现用户点对点即时通讯，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

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

WebSocket的主要特点包括：

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

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

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

添加依赖

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

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

配置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 {@Overridepublic void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {registry.addHandler(myHandler(), "/myHandler").setAllowedOrigins("*");}@Beanpublic TextWebSocketHandler myHandler() {return new MyHandler();}}

创建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 Map<String, WebSocketSession> users = new ConcurrentHashMap<>();@Overridepublic void afterConnectionEstablished(WebSocketSession session) throws Exception {String userId = session.getUri().toString().split("/")[4];users.put(userId, session);}@Overrideprotected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {String userId = session.getUri().toString().split("/")[4];String content = message.getPayload();// 处理消息内容，例如转发给其他用户或存储到数据库等}@Overridepublic 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();}}}}

前端页面

在前端页面中，可以使用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>