Springboot 整合 WebSocket ，使用STOMP协议实现对建立了websocket的用户使用SimpUserRegistry进行监控

Spring Boot整合WebSocket并使用STOMP协议实现对建立了websocket连接的用户进行监控的步骤如下：

1. 添加依赖：在Spring Boot项目中添加WebSocket和STOMP相关的依赖。通常情况下，`spring-boot-starter-websocket`会包含所需的所有依赖项。

2. 配置WebSocket：创建配置类，继承`WebSocketMessageBrokerConfigurer`接口，并实现其中的方法来配置消息代理，订阅路径等。

3. 消息代理配置：在配置类中，通常需要定义消息代理，使用`enableSimpleBroker`方法来启用一个简单的消息代理。它将为客户端提供目的地前缀，例如`/topic`。

4. 客户端和服务器端的STOMP交互：客户端通过发送特定的STOMP消息到服务器来订阅或者发送消息。服务器端需要处理这些消息，包括发送消息到特定用户或者广播消息给所有用户。

5. 用户注册与监控：通过使用`SimpUserRegistry`，可以获取当前连接的所有用户信息。这个类提供了注册和查询连接用户的功能。

6. 消息处理：编写消息处理器来处理客户端发送的消息，并定义如何回复或者广播给其他用户。

7. 客户端应用：客户端可以使用JavaScript的WebSocket API和STOMP客户端库（如`stomp.js`）来连接到WebSocket服务器，订阅消息和发送消息。

下面是一个简单的配置类示例代码：

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws").withSockJS();
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.enableSimpleBroker("/topic");
        registry.setApplicationDestinationPrefixes("/app");
    }
}

@Service
public class WebSocketService {
    @Autowired
    private SimpMessagingTemplate messagingTemplate;

    public void sendMessageToUser(String user, String message) {
        messagingTemplate.convertAndSendToUser(user, "/queue/messages", message);
    }
}

// 使用@SendToUser注解的方法
@Controller
public class WebSocketController {

    @MessageMapping("/send/{user}")
    @SendToUser("/queue/messages")
    public String sendToUser(@DestinationVariable String user, String message) {
        // 此方法处理发送给特定用户的消息
        return message;
    }
}