Spring Boot，WebSocket不会向指定用户发送通知

Question

我在向指定用户发送通知时遇到此类问题。这是我的配置文件。

@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
    registry.addEndpoint("/ws")
            .withSockJS();
}

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

这是我的客户代码

$(document).ready(function () {
connect();

}

function connect() {
var socket = new SockJS('/ws');
stompClient = Stomp.over(socket);
stompClient.connect({}, function () {
    stompClient.subscribe("/user/queue/reply", function (notification) {
        console.log("------------------------ subscribed !!!!!!");
        notify(JSON.parse(notification.body).content);
    });
});

}

此控制器处理所有与聊天相关的处理程序方法

@MessageMapping("/message")
@SendToUser("/queue/reply")
public ChatMessage processMessageFromClient(@Payload ChatMessage chatMessage) throws Exception {
    return chatMessage;
}

伙计们，我似乎是SpringBootWebSocket领域的新手，请告诉我是否足以向指定用户发送通知。相反，当我执行上述客户机代码时，得到通知的是我，即用户主体，而不是所需的用户。我做错了什么？它说，spring boot将会话id隐藏起来，并使用它来决定由谁发送通知。但这里似乎不是这样。。。

单击通知发送按钮时，这是浏览器日志。

Opening Web Socket...
stomp.min.js:8 Web Socket Opened...
stomp.min.js:8 >>> CONNECT
accept-version:1.1,1.0
heart-beat:10000,10000
stomp.min.js:8 <<< CONNECTED
version:1.1
heart-beat:0,0
user-name:hmkhitaryan
stomp.min.js:8 connected to server undefined
stomp.min.js:8 >>> SUBSCRIBE
id:sub-0
destination:/user/queue/reply
stomp.min.js:8 >>> SEND
destination:/app/message
content-length:71
{"sender":"hmkhitaryan","content":"friend request","type":"FR_REQUEST"}
stomp.min.js:8 <<< MESSAGE
destination:/user/queue/reply
content-type:application/json;charset=UTF-8
subscription:sub-0
message-id:xgec4kaf-15
content-length:71
{"type":"FR_REQUEST","content":"friend request","sender":"hmkhitaryan"}

问题是，下一个用户不是发送“hmkhitaryan1”，而是发送给我“hmkhitaryan”。

Answer 1

您可以使用转换和发送来回复特定的用户。像这样-

@Controller
public class GreetingController {

@Autowired
private SimpMessageSendingOperations  template ;


@MessageMapping("/message")
public void greeting(@Payload String message, 
          Principal principal){

    template.convertAndSendToUser(<userName_youwant_tosend>,"/queue/queue1",message);
 }
}

在你的配置类中-

@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
    config.enableSimpleBroker("/topic","/queue","/user");
    config.setApplicationDestinationPrefixes("/app");
    config.setUserDestinationPrefix("/user");
}

我和sendToUser也面临同样的问题。但这对我很有效。希望能有帮助。