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 - “私人”消息传递

回答

相关问题