无法使用 Spring Websocket 发送用户消息

Question

我阅读了有关用户目的地的Spring文档。我想使用convertAndSendToUser方法仅向特定用户发送消息。

这是 java 代码：

@Controller
public class WebsocketTest {
    @Autowired
    public SimpMessageSendingOperations messagingTemplate;
    @PostConstruct
    public void init(){
        ScheduledExecutorService statusTimerExecutor=Executors.newSingleThreadScheduledExecutor();
        statusTimerExecutor.scheduleAtFixedRate(new Runnable() {                
            @Override
            public void run() {
                messagingTemplate.convertAndSendToUser("myuser","/queue/test", new Return("test"));
            }
        }, 5000,5000, TimeUnit.MILLISECONDS);
    }
}

这是客户端 js 代码：

var socket = new WebSocket('ws://localhost:8080/hello');
            stompClient = Stomp.over(socket);            
            stompClient.connect("myuser","mypass", function(frame) {
                setConnected(true);
                console.log('Connected: ' + frame);
                stompClient.subscribe('/topic/greetings', function(greeting){
                    showGreeting(JSON.parse(greeting.body).value);
                });
                stompClient.subscribe('/user/queue/test', function(greeting){
                    showGreeting(JSON.parse(greeting.body).value);
                });
            });

首先，用户价值

这个是否正确？

stompClient.connect（"myuser",...

为什么这个测试不起作用？此用户未收到任何消息。如果我将目标切换到/topic/greetings并将方法更改为convertAndSend()这有效，但显然是广播，而不仅仅是根据要求发送给特定用户。

小更新

我尝试使用以下代码设置对单个用户的回复：

    @MessageMapping("/hello")
    @SendToUser("/queue/test")
    public Return test(){
        return new Return("test");
    }

这有效，这不是我需要的，因为此回复仅来自客户端的消息。似乎我不能将convertAndSendToUser()用于来自服务器的未解决消息。

Answer 1

在客户端订阅/user/queue/test并使用convertAndSendToUser向/topic/test主题发送消息看起来是正确的。

现在，您如何获得"myUser"值？

您可以在握手期间从request.getUserPrincipal()获取此值，也可以在接收消息时注入Principal;sessionId 在此处也可以工作。您可以查看此提交以获取有关此事的更多详细信息。

Answer 2

也许回答这个问题已经晚了，但对于可能面临类似问题的人来说，这是我所缺少的：要连接到的 websocket URL 也应该是安全的 URL。如果不是，则用户和会话之间没有映射，因此您无法使用 convertAndSendToUser() 向用户发送消息。

因此，例如，您使用URL模式连接到端点/hello那么它应该是一个安全的端点。