0

目前，我有一个以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消息，但是在客户端，它希望在1s内收到消息，但是当它等待超过一秒时，连接仍然在那里，WebSocket 仍在工作。

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

4

1 回答 1

0

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

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

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

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

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

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

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

在另一个方向，<sx>并<cy>以相同的方式使用。

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

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

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

于 2021-03-23T20:02:10.813 回答