私人消息沒有達到訂戶

我正在擴展此git'let項目以發送/接收私人消息 - 僅針對特定的訂閱用戶。我能夠發送它，但用戶沒有收到它們。我已添加分叉完整代碼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); 
      }); 
     }); 
    }); 
}

來源

2017-04-13 Anand Rockzz

原來，這條線是造成問題。

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

將其更改爲

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

解決了這個問題。用工作副本更新了Github。

來源

2017-04-13 23:28:39

私人消息沒有達到訂戶

回答

相關問題