问题描述
我正在使用 websocket 像消息代理一样使用rabbitmq 推送通知。在控制器中,我使用 SimpMessageTemplate 通过用户的昵称来 convertAndSendToUser 一条消息
@PostMapping("/{nickName}/notification")
public void send(@PathVariable String nickName,@RequestBody NotificationRes notificationRes) {
messagingTemplate.convertAndSendToUser(nickName,"/exchange/amq.direct/notification",notificationRes);
}
我通过使用 JWT 进行一些配置来授权用户并在用户开始连接时将用户设置为 StompHeaderAccessor。
Spring 安全消息传递当前转换为发送给用户。使用该端点 spring 会将其转换为 /exchange/amq.direct/notification-user{session_id}。 rabbitmq 会创建一个自动删除的队列。所以,如果我同时有 100 个连接。它将创建 100 个队列。我想自定义此流程以创建一个队列,spring 将使用消息头,以便 spring 可以知道要向其发送消息的用户。
我对 UserDestinationResolver 进行了一些研究,但我仍然不知道如何让 spring 可以处理标头而不是像 ...-user{session_id} 这样的 url。 @.@。这种情况我该怎么办?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)