Java websocket 服务端

Java可以使用SpringBoot快速整合WebSocket实现WebSocket服务端。以下是一个基本的Java WebSocket服务端代码实现，使用SpringBoot快速整合WebSocket实现客户端服务端相互推送信息[^1]：

1.将SpringBoot应用程序的starter websocket添加到Maven依赖项中，pom.xml文件内容如下：

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

2.创建一个WebSocket处理程序，实现WebSocketHandler接口，并重写接口中的方法，onOpen()、onMessage()、onError()、onClose()，如下：

@Component
public class MyWebSocketHandler implements WebSocketHandler {

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        // 与客户端建立连接后，在此方法中可以记录用户信息，方便后面发信息
        System.out.println("建立连接成功！" + session.getId());
    }

    @Override
    public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
        // 处理业务逻辑
        System.out.println("收到消息了：" + message.getPayload());
        // 回复客户端消息
        session.sendMessage(new TextMessage("Hello Client!"));
    }
    @Override
    public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
        System.out.println("连接出错");
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
        System.out.println("连接关闭");
    }

    @Override
    public boolean supportsPartialMessages() {
        return false;
    }
}

3.配置WebSocket处理程序和处理程序映射，如下：

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Autowired
    private MyWebSocketHandler myWebSocketHandler;

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        // 配置处理程序，处理客户端发来的请求
        registry.addHandler(myWebSocketHandler, "/ws").setAllowedOrigins("*");
    }
}

4.编写Controller类，用于指定WebSocket请求的URL，并返回WebSocket视图。如下：

@Controller
public class WebSocketController {

    @RequestMapping("/websocket")
    public String websocket() {
        return "websocket";
    }
}

以上代码实现了一个简单的Java WebSocket服务端。在客户端连接WebSocket服务端之后，通过WebSocket发送消息时，服务端会接收到并处理，然后回复消息给客户端。需要注意的是，在实际开发中，还需要考虑并发和线程安全问题，可以使用ConcurrentHashMap等线程安全的数据结构进行存储和操作。