如何向特定会话发送消息？
我有一个未经身份验证的WebSocket连接客户端和Spring servlet。当异步作业结束时，我需要向特定连接发送一条未请求的消息。
@Controller
public class WebsocketTest {
@Autowired
public SimpMessageSendingOperations messagingTemplate;
ExecutorService executor = Executors.newSingleThreadExecutor();
@MessageMapping("/start")
public void start(SimpMessageHeaderAccessor accessor) throws Exception {
String applicantId=accessor.getSessionId();
executor.submit(() -> {
//... slow job
jobEnd(applicantId);
});
}
public void jobEnd(String sessionId){
messagingTemplate.convertAndSend("/queue/jobend"); //how to send only to that session?
}
}
正如您在此代码中所看到的，客户端可以启动异步作业，并且当它完成时，需要结束消息。显然，我只需要向申请人发送消息，而不是广播给所有人。
如果有一个@SendToSession注释或messagingTemplate.convertAndSendToSession方法将会非常好。
更新
我尝试了这个：
messagingTemplate.convertAndSend("/queue/jobend", true, Collections.singletonMap(SimpMessageHeaderAccessor.SESSION_ID_HEADER, sessionId));
更新2
使用convertAndSendToUser()方法进行测试。 此测试是官方Spring教程的黑客：https://spring.io/guides/gs/messaging-stomp-websocket/ 这是服务器代码：
@Controller
public class WebsocketTest {
@PostConstruct
public void init(){
ScheduledExecutorService statusTimerExecutor=Executors.newSingleThreadScheduledExecutor();
statusTimerExecutor.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
messagingTemplate.convertAndSendToUser("1","/queue/test", new Return("test"));
}
}, 5000,5000, TimeUnit.MILLISECONDS);
}
@Autowired
public SimpMessageSendingOperations messagingTemplate;
}
这是客户端代码：
function connect() {
var socket = new WebSocket('ws://localhost:8080/hello');
stompClient = Stomp.over(socket);
stompClient.connect({}, function(frame) {
setConnected(true);
console.log('Connected: ' + frame);
stompClient.subscribe('/user/queue/test', function(greeting){
console.log(JSON.parse(greeting.body));
});
});
}
不幸的是，客户端没有按预期每5000毫秒接收到其每个会话的回复。我确定"1"是第二个连接的有效sessionId，因为我在调试模式下使用了SimpMessageHeaderAccessor.getSessionId()
背景情景
我想为远程作业创建一个进度条，客户端向服务器请求异步作业，并通过从服务器发送的websocket消息检查其进度。这不是文件上传，而是远程计算，因此只有服务器知道每个作业的进度。 我需要向特定会话发送消息，因为每个作业都是由会话启动的。 客户端请求远程计算 服务器启动此作业，并针对每个作业步骤回复申请人客户端其作业进度状态。 客户端获取有关其作业的消息，并构建进度/状态栏。 这就是我需要每个会话消息的原因。 我也可以使用每个用户消息，但Spring不提供每个用户未经请求的消息。（无法使用Spring Websocket发送用户消息）
工作解决方案
__ __ ___ ___ _ __ ___ _ _ ___ ___ ___ _ _ _ _____ ___ ___ _ _
\ \ / // _ \ | _ \| |/ /|_ _|| \| | / __| / __| / _ \ | | | | | ||_ _||_ _|/ _ \ | \| |
\ \/\/ /| (_) || /| ' < | | | .` || (_ | \__ \| (_) || |__| |_| | | | | || (_) || .` |
\_/\_/ \___/ |_|_\|_|\_\|___||_|\_| \___| |___/ \___/ |____|\___/ |_| |___|\___/ |_|\_|
从我的UPDATE2解决方案开始，我必须使用最后一个参数（MessageHeaders）完成convertAndSendToUser方法的转换和发送：
messagingTemplate.convertAndSendToUser("1","/queue/test", new Return("test"), createHeaders("1"));
其中createHeaders()是这个方法：
private MessageHeaders createHeaders(String sessionId) {
SimpMessageHeaderAccessor headerAccessor = SimpMessageHeaderAccessor.create(SimpMessageType.MESSAGE);
headerAccessor.setSessionId(sessionId);
headerAccessor.setLeaveMutable(true);
return headerAccessor.getMessageHeaders();
}