小编Chu*_*Liu的帖子

我用 spring 编写了一个 Web 套接字服务器和一个客户端。代码如下。向服务器发送消息的代码可以工作，但 session.subscribe 方法无法从服务器接收消息。我搜索了很多文档并检查了我的代码。我不明白为什么它不能工作。

这是我的客户代码：

public class Test {

    public static void main(String[] args) {

        Thread thread = new Thread(new WebsocketThread());
        thread.start();
        Thread.sleep(5000);
    }
}

class MyStompSessionHandler extends StompSessionHandlerAdapter {

    @Override
    public void afterConnected(StompSession session, StompHeaders connectedHeaders) {
        session.send("/app/messages", "{'payload3':2222}".getBytes());
        session.subscribe("/user/queue/position-updates", new StompFrameHandler() {

            @Override
            public Type getPayloadType(StompHeaders headers) {
                return String.class;
            }

            @Override
            public void handleFrame(StompHeaders headers, Object payload) {
                System.out.println("test:" + payload);
            }

        });
    }
}

class WebsocketThread implements Runnable{
    @Override
    public void run() { …