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

Question

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

这是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);
                });
            });

首先，考虑用户价值是否正确？

StampClient.connect（"myuser"，...

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

我试图设置一个回复单用户与此代码：

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

这是工作，这不是我需要的，因为这个答复只是从客户端的消息。似乎我无法使用convertAndSendToUser（）处理来自服务器的未经请求的消息。

Answer 1

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

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

Answer 2

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

现在，您如何获得“myUser”值？

您可以在握手过程中从request.getUser主体（）获取此值，或者在接收消息时注入主体；在这里也可以使用sesionId。您可以查看此提交以了解有关此事的更多详细信息。