使用 rabbitmq

如何解决使用 rabbitmq

我正在使用 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。 @.@。这种情况我该怎么办？