Spring Websocket ConvertandSendToser不工作

Question

我成功订阅了一个队列，但在发送消息时，另一个用户没有收到它

消息代理配置：

override fun configureMessageBroker(config: MessageBrokerRegistry) {
    config.enableSimpleBroker("/queue", "/topic")
    config.setApplicationDestinationPrefixes("/app")
}

我如何发送消息

messageTemplate.convertAndSendToUser(recipientId.toString(), "/queue/chat", message)

在ws-connection上创建自定义用户主体

override fun preSend(message: Message<*>, channel: MessageChannel): Message<*>? {
            val accessor = MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor::class.java)
            if (accessor != null && StompCommand.CONNECT == accessor.command) {
                val customPrincipal = CustomPrincipal(userId)
                val authentication = CustomAuthToken(customPrincipal, roles)
                accessor.user = authentication
                return MessageBuilder.createMessage(message.payload, accessor.messageHeaders)
            }
            return message
        }
    }

在客户端，我连接套接字

this.stompClient.connect(headers, () => {
    this.stompClient.subscribe(headers, "/user/queue/chat", (message) => {
        console.log("connected");
        console.log(message);
    });
});

当我连接到stomp时，我会在浏览器控制台中看到下一条消息

<<< CONNECTED
user-name:1
heart-beat:0,0
version:1.2
content-length:0

user name是此用户的实际id
我将id为1的用户和id为2的用户订阅到同一队列，当我从用户1向用户2发送消息时，第二个用户没有收到消息<我错过什么了吗？

Answer 1

经过5个小时的Spring调试，我发现了如何解决这个问题

只需将访问器（在preSendmethod中）设置为不可变

accessor.setLeaveMutable(false)

我仍然不完全理解为什么会发生这种情况，如果有人能解释的话，那将非常有用
我在文档中没有找到任何关于这一点的信息