IT评测·应用市场-qidao123.com

标题: WebSocket [打印本页]
作者: 莱莱    时间: 2025-3-15 12:05
标题: WebSocket
一、WebSocket基础

1. WebSocket介绍

WebSocket是一种网络通信协议，提供全双工通信通道，允许服务器和客户端之间举行长期、双向的通信。与传统HTTP差别，WebSocket在创建毗连后保持开放状态，双方可以随时发送数据。
2. WebSocket与HTTP比力


3. WebSocket工作原理

毗连创建：客户端发送标准HTTP请求，请求头包罗升级协议信息
  1. GET /chat HTTP/1.1
  2. Host: server.example.com
  3. Upgrade: websocket
  4. Connection: Upgrade
  5. Sec-WebSocket-Key: x3JJHMbDL1EzLkh9GBhXDw==
  6. Sec-WebSocket-Protocol: chat, superchat
  7. Sec-WebSocket-Version: 13
复制代码
握手确认：服务器同意升级，返回确认相应
  1. HTTP/1.1 101 Switching Protocols
  2. Upgrade: websocket
  3. Connection: Upgrade
  4. Sec-WebSocket-Accept: HSmrc0sMlYUkAGmm5OPpG2HaGWk=
  5. Sec-WebSocket-Protocol: chat
复制代码
双向通信：握手成功后，毗连保持开放，双方可以随时发送数据帧
毗连关闭：任一方可以发送关闭帧，制止毗连
二、Spring Boot整合WebSocket示例（聊天室）

下面详细介绍利用Spring Boot创建WebSocket聊天室应用的步调：
步调1：创建Spring Boot项目

pom.xml依赖：
  1. <dependencies>
  2.     <!-- Spring Boot Web -->
  3.     <dependency>
  4.         <groupId>org.springframework.boot</groupId>
  5.         <artifactId>spring-boot-starter-web</artifactId>
  6.     </dependency>
  7.    
  8.     <!-- WebSocket -->
  9.     <dependency>
  10.         <groupId>org.springframework.boot</groupId>
  11.         <artifactId>spring-boot-starter-websocket</artifactId>
  12.     </dependency>
  13.    
  14.     <!-- Lombok（可选） -->
  15.     <dependency>
  16.         <groupId>org.projectlombok</groupId>
  17.         <artifactId>lombok</artifactId>
  18.         <optional>true</optional>
  19.     </dependency>
  20. </dependencies>
复制代码
步调2：创建WebSocket配置类

创建WebSocketConfig类：
  1. package com.example.websocket.config;
  3. import org.springframework.context.annotation.Bean;
  4. import org.springframework.context.annotation.Configuration;
  5. import org.springframework.web.socket.server.standard.ServerEndpointExporter;
  7. @Configuration
  8. public class WebSocketConfig {
  9.    
  10.     @Bean
  11.     public ServerEndpointExporter serverEndpointExporter() {
  12.         return new ServerEndpointExporter();
  13.     }
  14. }
复制代码
说明：

步调3：定义消息实体类

创建Message类：
  1. package com.example.websocket.model;
  3. import lombok.Data;
  5. @Data
  6. public class Message {
  7.     private String username;  // 发送者用户名
  8.     private String content;   // 消息内容
  9.     private String timestamp; // 时间戳
  10.    
  11.     // 如果不使用Lombok，需要添加getter、setter和构造方法
  12. }
复制代码
步调4：创建WebSocket端点类

创建ChatEndpoint类：
  1. package com.example.websocket.endpoint;
  3. import com.example.websocket.model.Message;
  4. import com.fasterxml.jackson.databind.ObjectMapper;
  5. import org.slf4j.Logger;
  6. import org.slf4j.LoggerFactory;
  7. import org.springframework.stereotype.Component;
  9. import javax.websocket.*;
  10. import javax.websocket.server.PathParam;
  11. import javax.websocket.server.ServerEndpoint;
  12. import java.io.IOException;
  13. import java.util.Map;
  14. import java.util.concurrent.ConcurrentHashMap;
  16. @Component
  17. @ServerEndpoint("/chat/{username}")
  18. public class ChatEndpoint {
  19.    
  20.     private static final Logger logger = LoggerFactory.getLogger(ChatEndpoint.class);
  21.     private static final Map<String, Session> onlineSessions = new ConcurrentHashMap<>();
  22.     private static final ObjectMapper objectMapper = new ObjectMapper();
  23.    
  24.     /**
  25.      * 连接建立时调用
  26.      */
  27.     @OnOpen
  28.     public void onOpen(Session session, @PathParam("us
复制代码
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 IT评测·应用市场-qidao123.com (https://dis.qidao123.com/) Powered by Discuz! X3.4