私人消息未到达订阅者

Question

我正在扩展此 git'let project to send/receive private messages - targeted only to specific subscribed users. I'm able to send it, but subscribers are not receiving them. I've added the forked full code here，下面是代码的 重要部分 的片段。

配置：

@Configuration
@EnableScheduling
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
    @Autowired
    private SessionBasedHandshakeHandler handshakeHandler;

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic", "/queue");
        config.setApplicationDestinationPrefixes("/app");
    }
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/gs-guide-websocket").setHandshakeHandler(handshakeHandler).withSockJS();
    }
}

控制器：

@Controller
public class GreetingController {
    @Autowired
    public SimpMessageSendingOperations messagingTemplate;
    private Set<String> users = new HashSet<>();

    @GetMapping("/subscribe4PrivateMsgs")
    public @ResponseBody String enablePrivateMessages(HttpSession session) {
        String sessionId = session.getId();
        users.add(sessionId);
        return sessionId;
    }
    @MessageMapping("/hello")
    @SendTo("/topic/greetings")
    public Greeting greeting(HelloMessage message) throws Exception {
        Thread.sleep(1000); // simulated delay
        return new Greeting("Hello, " + message.getName() + "!");
    }
    @Scheduled(fixedDelay = 5000)
    private void sendPrivateMessageToScubscribers() {
        users.forEach((sessionId) -> {
            SimpMessageHeaderAccessor headerAccessor = SimpMessageHeaderAccessor.create(SimpMessageType.MESSAGE);
            headerAccessor.setSessionId(sessionId);
            headerAccessor.setLeaveMutable(true);
            String msg = sessionId + ":" + GregorianCalendar.getInstance().getTimeInMillis();
            Greeting response = new Greeting(msg);
            //Tried the following to Send Private Message, but it doens't works
            messagingTemplate.convertAndSendToUser(sessionId, "/queue/private", response,
                    headerAccessor.getMessageHeaders());
            //The following reached UI successfully - but to all users
            /*response.setContent("Public Msg:: " + msg);
            messagingTemplate.convertAndSend("/topic/greetings", response);*/
        });
    }
}

UI:

function connect() {
    $.get("/subscribe4PrivateMsgs", function(userId) {
        var socket = new SockJS('/gs-guide-websocket');
        stompClient = Stomp.over(socket);
        stompClient.connect({}, function (frame) {
            setConnected(true);
            console.log('Connected: ' + frame);
            stompClient.subscribe('/topic/greetings', function (greeting) {
                showGreeting('Received Public Msg: ' + JSON.parse(greeting.body).content);
            });
            stompClient.subscribe('/user/queue/private', function (greeting) {
                showGreeting('1 Received Private Msg: ' + JSON.parse(greeting.body).content);
            });
            stompClient.subscribe('/user/'+userId+'/queue/private', function (greeting) {
                showGreeting('2 Received Private Msg: ' + JSON.parse(greeting.body).content);
            });
        });
    });
}

Answer 1

原来是这条线引起了问题。

messagingTemplate.convertAndSendToUser(sessionId, "/queue/private", response, headerAccessor.getMessageHeaders());

将其更改为

messagingTemplate.convertAndSendToUser(sessionId, "/queue/private", response);

问题已解决。 Github 更新了工作副本。

私人消息未到达订阅者

Private Messages NOT are reaching the subscribers

stomp

spring-mvc

websocket

sockjs

spring-websocket