SpringBoot 中 @SendToUser 源码分析

`@SendToUser`是Spring WebFlux中一个用于WebSocket消息定向发送的注解，它允许你在服务层将消息直接发送给特定的WebSocket客户端。这个注解主要用于处理WebSocket消息的分发逻辑，其源码位于`org.springframework.messaging.simp.annotation.SendToUser`包下。

源码分析通常涉及到查看`SendToUser`注解本身以及相关的拦截器或处理器，这里我们简要概述一下关键部分：

- **注解**：`@SendToUser`是一个声明式注解，当你在其目标方法上使用时，会告诉Spring框架这是一条需要发送给某个用户的消息。它的属性包括`user`（接收者用户名）、`destination`（消息的目标路径，比如"/topic/users"）等。

- **处理器**：在Spring的WebFlux体系中，`AbstractMessageHandlerMethodArgumentResolver`处理此类注解。当方法被匹配到并且有`@SendToUser`注解时，它会在响应阶段查找匹配的WebSocket连接。

- **拦截器链**：`MessageBrokerSubscribableChannelInterceptor`负责寻找匹配的`Subscription`实例，也就是与用户相关的WebSocket连接。它会在消息传递之前进行检查，找到对应的用户然后将消息加入到相应的频道。

- **消息发布**：最后，`SimpleBrokerMessageHandler`负责将消息实际推送到用户的WebSocket连接。它会根据`SendToUser`注解的配置来选择正确的主题或用户通道。

要深入了解源码，你需要查阅Spring Framework源代码，特别是在`spring-messaging`模块下的WebSocket相关组件。注意，具体的实现可能会随着版本更新有所变化。