WebSocket的Spring STOMP - 「私人」消息傳遞

我正在使用WebSocket聊天。我做了一個簡單的發送每個消息給每個人。但我正在嘗試製作類似私人消息的內容，而且我真的不知道該怎麼做。我嘗試過不同的選擇，但我不知道如何使它工作。WebSocket的Spring STOMP - 「私人」消息傳遞

這裏是我的代碼：

WebSocketConfig.java

@Configuration 
@EnableWebSocketMessageBroker 
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer { 

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

    @Override 
    public void registerStompEndpoints(StompEndpointRegistry registry) { 
     registry.addEndpoint("/gs-guide-websocket").withSockJS(); 
    } 
}

GreetingController.java

@Controller 
public class GreetingController { 

    @MessageMapping("/hello") 
    @SendTo("/topic/greetings") 
    public Greeting greeting(Message message) throws Exception { 
     return new Greeting(message.getFrom_user_id(), message.getMessage(), message.getTo_user_id()); 

    } 
}

而我的JS函數來連接和發送消息：

function connect() { 
var socket = new SockJS('/gs-guide-websocket'); 
stompClient = Stomp.over(socket); 
var theUserId = 1; 
stompClient.connect({user:theUserId}, function (frame) { 
    setConnected(true); 
    console.log('Connected: ' + frame); 
    //stompClient.subscribe('/topic/greetings', function (greeting) { 
    stompClient.subscribe('/topic/greetings', function (greeting) { 
     showGreeting(JSON.parse(greeting.body).content); 
    }); 
}); 
} 


function sendName() { 
stompClient.send("/app/hello", {}, JSON.stringify(
     { 
      'from_user_id': parseInt($("#from_user_id").val()), 
      'message': $("#message").val(), 
      'to_user_id': parseInt($("#to_user_id").val()) 
     })); 
}

如何使私人信息的工作？有人可以解釋我應該如何工作嗎？

乾杯安德魯！

來源

2017-08-17 Andrew

我們可以利用SimpMessagingTemplate的將消息發送到適當的目的地隊列

文檔：https://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/messaging/simp/SimpMessagingTemplate.html：

@Autowired 
    private SimpMessagingTemplate template; 

    @MessageMapping("/hello") 
    public void greeting(Message message) throws Exception { 

    this.template.convertAndSend("/topic/"+message.getFrom_user_id(),message); 

    }

因此定義客戶端

來源

2017-08-17 08:15:25 Barath

感謝訂閱主題您！奇蹟般有效：） – Andrew

WebSocket的Spring STOMP - 「私人」消息傳遞

回答

相關問題