springboot 集成socket

在Spring Boot中集成WebSocket可以使用Spring的WebSocket模块来实现。下面是一个简单的示例，演示如何在Spring Boot应用程序中使用WebSocket。

1. 添加依赖

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

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

2. 创建WebSocket配置类

创建一个WebSocket配置类，该类将启用WebSocket支持并定义WebSocket处理程序。

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
 
   @Override
   public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
      registry.addHandler(new MyWebSocketHandler(), "/my-websocket-endpoint");
   }
 
}

3. 创建WebSocket处理程序

创建一个WebSocket处理程序，该处理程序将处理传入的WebSocket连接。

public class MyWebSocketHandler extends TextWebSocketHandler {
 
   @Override
   public void handleTextMessage(WebSocketSession session, TextMessage message) {
      // 处理消息
   }
 
}

4. 配置WebSocket的端点

在您的应用程序中创建一个控制器类，并将WebSocket端点映射到该类中的方法。

@Controller
public class WebSocketController {
 
   @MessageMapping("/hello")
   @SendTo("/topic/greetings")
   public Greeting greeting(HelloMessage message) throws Exception {
      return new Greeting("Hello, " + message.getName() + "!");
   }
 
}

5. 测试WebSocket连接

现在，您可以使用JavaScript或其他客户端来测试WebSocket连接。以下是一个简单的JavaScript示例：

var socket = new WebSocket('ws://localhost:8080/my-websocket-endpoint');
 
socket.onopen = function() {
   console.log('WebSocket is open!');
};
 
socket.onmessage = function(event) {
   console.log('WebSocket message received:', event.data);
};
 
socket.onclose = function() {
   console.log('WebSocket is closed!');
};

以上是一个简单的Spring Boot集成WebSocket的示例。您可以根据自己的需求进行调整和扩展。