@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.enableSimpleBroker("/client");
}
@MessageMapping("/send")
@SendToUser(destinations = "/client", broadcast = false)
public String ws(Principal principal, String msg) {
// 客户端订阅的地址是 /user/client
// 服务端@SendToUser发送的代理地址是 /client, 地址将会被转化为 /user/{username}/client
System.out.println(principal);
System.out.println(msg);
return msg;
}
@MessageMapping("/send")
// @SendToUser(destinations = "/client", broadcast = false)
public void ws(Principal principal, String msg) {
// 客户端订阅的地址是 /user/client
// 服务端@SendToUser发送的代理地址是 /client, 地址将会被转化为 /user/{username}/client
System.out.println(principal);
System.out.println(msg);
simpMessagingTemplate.convertAndSendToUser("yawn1", "/client", msg);
}
var socket = new SockJS("/socket");
var stomp = Stomp.over(socket);
stomp.connect("guest", "guest", function(frame){
stomp.subscribe("/user/client", function (message) {
$(".content").html(message.body);
})
});
$(".send").click(function () {
stomp.send("/server/send", {}, $(".msg").val());
});