是否可以通过 Spring WebSocket 发送同步消息？

Question

我有一个 Spring 应用程序，它通过 Spring WebSocket 异步向另一台服务器发送消息。但是对于我需要同步发送消息的特定情况，我应该使用来自服务器的传入响应继续该过程。

我不想只为此进程进行 HTTP 调用，因为已经有一个打开的 TCP 连接，我想使用它。

例如在 Tyrus WebSocket 实现中，可以通过同步或异步发送消息

session.getBasicRemote().sendText(message);
session.getAsyncRemote().sendText(message);

Tyrus 相关文档link.

顺便说一句，我不使用 sub-protocol 像带有 Spring WebSocket 的 STOMP。

Answer 1

您可以将自定义模式添加到需要回复的消息中。

假设您要将表单服务器 A 发送到服务器 B：

sendToB("REPLY ME!");

在您实际发送消息之前，服务器 A 在其中放入一个自定义短语，例如：

sendToB("REQUEST:1234" + "#$#" + "REPLY-ME!");

当服务器B收到消息时：

String[] parts = message.split("#$#");
if (parts.length > 0) {
    String[] keyValue = parts[0].split(":");
    sendToA("RESPONSE:" + keyValue[1] + "#$#" + "CALM DOWN!");
}

最后，服务器A收到消息：

"RESPONSE:1234#$#CALM DOWN!"

那么同步消息就完成了。