admin管理员组文章数量:1635840
应用程序可以发送针对特定用户的消息,并且Spring的STOMP支持识别以/user/
为前缀的destination。例如,客户端可能会订阅/user/queue/position-updates
的destination。UserDestinationMessageHandler
处理此destination,并将其转换为特定于用户会话的destination(例如/queue/position-updates-user123
)。这提供了订阅通用命名destination的便利,同时确保与其他订阅相同目的地的用户没有冲突,以便每个用户都可以接收到独特的股票位置更新。
使用用户目标时,配置代理和应用程序目标前缀非常重要,如启用 STOMP 中所示,否则代理将处理仅应由
UserDestinationMessageHandler
处理的“/user”前缀消息。
在发送端,消息可以发送到诸如 /user/{username}/queue/position-updates
之类的destination,而该destination又由 UserDestinationMessageHandler
转换为一个或多个destination,每个destination对应与用户关联的每个会话。这使得应用程序中的任何组件都可以发送针对特定用户的消息,而无需知道除用户名和通用destination之外的任何信息。这也可以通过注释和消息模板来支持。
消息处理方法可以通过@SendToUser
注解向正在处理的消息关联的用户发送消息(也可以在类级别上支持,以共享一个共同的目的地),如下例所示:
@Controller
public class PortfolioController {
@MessageMapping("/trade")
@SendToUser("/queue/position-updates")
public TradeResult executeTrade(Trade trade, Principal principal) {
*// ...*return tradeResult;
}
}
如果用户有多个会话,则默认情况下,订阅给定destination的所有会话都会成为目标。然而,有时,可能需要仅针对发送正在处理的消息的会话。你可以通过将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;
}
}
虽然用户destination通常意味着已认证的用户,但这并不是严格要求的。未与已认证用户关联的WebSocket会话可以订阅用户destination。在这种情况下,
@SendToUser
注解的行为与broadcast=false
完全相同(即,仅定位发送正在处理的消息的会话)。
你可以通过注入由Java配置或XML命名空间创建的SimpMessagingTemplate
来向用户destinations发送消息。(如果需要通过@Qualifier
进行限定,bean名称为brokerMessagingTemplate
)。以下示例展示了如何执行此操作:
@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());
}
}
当你将用户目标与外部消息代理一起使用时,应检查代理文档了解如何管理不活动的队列,以便在用户会话结束后,删除所有唯一的用户队列。例如,当你使用
/exchange/amq.direct/position-updates
等destinations时,RabbitMQ 会创建自动删除队列。因此,在那种情况下,客户端可以订阅/user/exchange/amq.direct/position-updates
。同样,ActiveMQ有配置选项来清除不活动的目的地。
在多应用程序服务器场景中,由于用户连接到不同的服务器,因此用户destination可能仍未解析。在这种情况下,你可以配置一个destination来广播未解析的消息,以便其他服务器有机会尝试。这可以通过 Java 配置中 MessageBrokerRegistry
的 userDestinationBroadcast
属性和 XML 中 message-broker
元素的 user-destination-broadcast
属性来完成。
版权声明:本文标题:Spring STOMP-用户的目的地 内容由热心网友自发贡献,该文观点仅代表作者本人, 转载请联系作者并注明出处:https://m.elefans.com/xitong/1729217777a1190621.html, 本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,一经查实,本站将立刻删除。
发表评论