使用 STOMP

如何解决使用 STOMP

目前我有一个项目，使用Websocket和Stomp作为消息传递的子协议，我需要管理Websocket上的断开连接事件和重新连接事件。 我的最终目标是如果服务器和客户端之间没有消息，则在 5 秒后关闭与 STOMP 的 WebSocket 会话。在服务器和客户端中设置时，我对心跳值感到非常困惑。例如，我在客户端设置了这些心跳值（使用 Stomp.js）：

stompClient.heartbeat.outgoing = 5000;
stompClient.heartbeat.incoming = 1000;

这是我在服务器端（Spring Boot）的心跳值：

config.enableSimpleBroker("/topic")
                .setTaskScheduler(taskScheduler()).setHeartbeatValue(new long[]{5000,5000});

所以我在服务器端设置了这个值，它会每 5 秒发送一个 PONG 消息，但是在客户端，它期望在 1 秒内收到消息，但是当它等待超过一秒时，连接仍然存在，WebSocket 仍在工作。

如果我更改一侧的一个值，它会如何影响另一侧？以及如何使用这些心跳值断言连接将在特定时间关闭？非常感谢。

解决方法

STOMP specification 解释了心跳的工作原理。创建连接时，客户端和代理之间会达成协议，其中将使用最大 心跳值。

heart-beat 标头提供了足够的信息，以便每一方都可以了解是否可以使用心跳、在哪个方向以及以哪个频率使用。

更正式地说，初始帧如下所示：

CONNECT
heart-beat:<cx>,<cy>

CONNECTED
heart-beat:<sx>,<sy>

对于从客户端到服务器的心跳：

• 如果 <cx> 为 0（客户端无法发送心跳）或 <sy> 为 0（服务器不想接收心跳），则不会有
• 否则，每 MAX(<cx>,<sy>) 毫秒就会有一次心跳

在另一个方向，<sx> 和 <cy> 的用法相同。

在您的情况下，客户端指定它希望每 1 秒接收一次心跳，但代理只能每 5 秒发送一次 ping（基于您指定的配置），因此客户端应该只期望每 一次 ping 5 秒（从 5 > 1）。

另一个示例...如果您有 cx,cy = 5000,10000 和 sx,sy = 15000,20000，客户端将每 20 秒向代理发送一次心跳（即 MAX(<cx>,<sy>)），并且代理将发送心跳-每 15 秒向客户端发送一次（即 MAX(<sx>,<cy>)）。

另外，请记住，心跳和 MESSAGE 帧是两种不同的东西。如果您的客户端未收到 MESSAGE 帧，则连接仍然有效，并且客户端和代理在此期间仍可以交换心跳。