|
对于最新的稳定版本，请使用 Spring Framework 6.2.0！ |
用户目标
应用程序可以发送针对特定用户的消息，以及 Spring 的 STOMP 支持
识别前缀为/user/为此目的。
例如，客户端可能会订阅/user/queue/position-updates目的地。UserDestinationMessageHandler处理此目标并将其转换为
destination （destination （destination ） 中唯一的唯一目标（例如/queue/position-updates-user123).
这提供了订阅通用命名目标的便利性，而
同时，确保不会与订阅相同的其他用户发生冲突
目标，以便每个用户都可以接收唯一的 Stock Position 更新。
使用用户目标时，配置 broker 和
应用程序目标前缀，如启用 STOMP 中所示，否则
broker 将处理带有 “/user” 前缀的消息，这些消息只能由UserDestinationMessageHandler. |
在发送端，消息可以发送到目标，例如/user/{username}/queue/position-updates，而
由UserDestinationMessageHandler发送到一个或多个目的地，每个目的地一个
会话。这允许应用程序中的任何组件
发送针对特定用户的消息，而不必了解更多信息
而不是其名称和通用目标。这也通过
annotation 和消息传递模板。
消息处理方法可以将消息发送给与
通过@SendToUser注释（也支持
类级别共享一个公共目标），如下例所示：
@Controller
public class PortfolioController {
@MessageMapping("/trade")
@SendToUser("/queue/position-updates")
public TradeResult executeTrade(Trade trade, Principal principal) {
// ...
return tradeResult;
}
}如果用户有多个会话，则默认情况下，订阅了所有会话
的目标。但是，有时，可能需要
仅以发送正在处理的消息的会话为目标。您可以通过以下方式执行此作
设置broadcast属性设置为 false，如下例所示：
@Controller
public class MyController {
@MessageMapping("/action")
public void handleAction() throws Exception{
// raise MyBusinessException here
}
@MessageExceptionHandler
@SendToUser(destinations="/queue/errors", broadcast=false)
public ApplicationError handleException(MyBusinessException exception) {
// ...
return appError;
}
}虽然用户目标通常意味着经过身份验证的用户，但这并不是严格要求的。
未与已验证的用户关联的 WebSocket 会话
可以订阅用户目标。在这种情况下，@SendToUser注解
的行为与broadcast=false（即，仅将
会话发送正在处理的消息）。 |
您可以从任何应用程序向用户目标发送消息
组件，例如，将SimpMessagingTemplate由 Java 配置创建，或者
XML 命名空间。（bean 名称为brokerMessagingTemplate如果需要
用于@Qualifier.)以下示例显示了如何执行此作：
@Service
public class TradeServiceImpl implements TradeService {
private final SimpMessagingTemplate messagingTemplate;
@Autowired
public TradeServiceImpl(SimpMessagingTemplate messagingTemplate) {
this.messagingTemplate = messagingTemplate;
}
// ...
public void afterTradeExecuted(Trade trade) {
this.messagingTemplate.convertAndSendToUser(
trade.getUserName(), "/queue/position-updates", trade.getResult());
}
}当您将用户目标与外部消息代理一起使用时，应检查代理
有关如何管理非活动队列的文档，以便在用户会话为
over，则删除所有唯一用户队列。例如，RabbitMQ 会创建自动删除
queues （当您使用目标，例如/exchange/amq.direct/position-updates.
因此，在这种情况下，客户端可以订阅/user/exchange/amq.direct/position-updates.
同样，ActiveMQ 具有用于清除非活动目标的配置选项。 |
在多应用程序服务器方案中，用户目标可能保持未解析状态，因为
用户已连接到其他服务器。在这种情况下，您可以配置
destination 广播未解析的消息，以便其他服务器有机会尝试。
这可以通过userDestinationBroadcast属性的MessageBrokerRegistry在 Java 配置中，并且user-destination-broadcast属性
的message-broker元素。