Spring会话Spring web套接字。根据会话id向特定客户端发送消息

Question

我已经按照Quetion1和Quetion2从堆栈溢出发送消息到特定的客户端，基于其会话ID，但找不到成功。

下面是我的示例RestController类

@RestController
public class SpringSessionTestApi {

@Autowired
public SimpMessageSendingOperations messagingTemplate;

@MessageMapping("/messages")
public void greeting(HelloMessage message, SimpMessageHeaderAccessor headerAccessor) throws Exception {

    String sessionId  = (String) headerAccessor.getSessionAttributes().get("SPRING.SESSION.ID");
    messagingTemplate.convertAndSendToUser(sessionId,"/queue/test",message, createHeaders(sessionId));

   }

private MessageHeaders createHeaders(String sessionId) {
    SimpMessageHeaderAccessor headerAccessor = SimpMessageHeaderAccessor.create(SimpMessageType.MESSAGE);
    headerAccessor.setSessionId(sessionId);
    headerAccessor.setLeaveMutable(true);
    return headerAccessor.getMessageHeaders();
   }
}

会话ID：当客户端发送create会话请求时，会生成新的Spring会话ID，并将其存储在MongoDB中。之后，当客户端发送Web套接字连接请求时，会收到与预期存储在mongoDb中的相同的会话ID。直到一切正常。

现在，我的工作是根据SesssionId将响应发送回客户端。为此，我有下面的Web套接字类：

@Configuration
@EnableScheduling
@EnableWebSocketMessageBroker
public class WebSocketConfig extends
    AbstractSessionWebSocketMessageBrokerConfigurer<ExpiringSession> {

@Override
protected void configureStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/messages");
}

public void configureMessageBroker(MessageBrokerRegistry registry) {
    registry.enableSimpleBroker("/queue");
    registry.setApplicationDestinationPrefixes("/app");
   }
}

我用来连接的示例客户端代码是：

function connect() {

stompClient = Stomp.client('ws://localhost:8016/messages');
stompClient.debug = null;

stompClient.connect({}, function (frame) {
    setConnected(true);
    console.log('Connected: ' + frame);
    stompClient.subscribe('/user/queue/test', function (greeting) {
        console.log("Hello "+greeting);
        console.log("Greeting body "+JSON.parse(greeting.body));

    });
});
}

请帮忙，我在这方面哪里做错了？提前谢谢！

Answer 1

我在git中找到了一个完全可行的Spring Stomp聊天项目，链接在这里。你可以参考一下。https://gist.github.com/theotherian/9906304

Answer 2

如果您正在使用 /user通道，请尝试按照此处所述通过用户。

@MessageMapping("/messages")
public void greeting(HelloMessage message, SimpMessageHeaderAccessor headerAccessor, Principal principal) 
    throws Exception {
    messagingTemplate.convertAndSendToUser(principal.getName(), "/queue/test", message);
}