rsocket-js KeepAlive与Lease完全指南：保活心跳和背压租约的2大核心机制

rsocket-js KeepAlive与Lease完全指南保活心跳和背压租约的2大核心机制【免费下载链接】rsocket-jsJavaScript implementation of RSocket项目地址: https://gitcode.com/gh_mirrors/rs/rsocket-js在rsocket-jsRSocket 协议的 JavaScript 实现中KeepAlive 保活心跳和Lease 背压租约是保障长连接稳定性的 2 大核心机制前者让客户端与服务器能及时发现假死连接并自动断开后者让服务器按配额控制客户端的请求速率避免服务被打垮。本指南用最少的代码帮你彻底搞懂这两个机制的工作原理与配置方法。为什么需要保活心跳和租约控制RSocket 建立在双向复用连接之上TCP、WebSocket 等一条连接上可以跑无数个流。这带来两个隐患连接假死网络闪断、对端崩溃时TCP 层面可能并不立刻报错。没有心跳客户端可能对着一条死连接傻等。请求洪峰客户端可以无限制地发起 requestResponse / requestChannel 请求服务器内存会被拖垮。rsocket-js 用 KeepAlive 解决第一个问题用 Lease 解决第二个问题。两者都实现在核心包packages/rsocket-core/src/RSocketSupport.ts中。一、KeepAlive 保活心跳机制工作原理发送器 检查器KeepAlive 由两个类配合完成见packages/rsocket-core/src/RSocketSupport.ts组件职责KeepAliveSender按固定间隔keepAlive 周期向对端发送 KEEPALIVE 帧KeepAliveHandler记录最后一次收到 KEEPALIVE 帧的时间超时未收到就主动关闭连接关键点客户端默认就有心跳packages/rsocket-core/src/RSocketConnector.ts中connect()完成后会自动keepAliveSender.start()无需任何配置。服务器默认不主动发心跳只有服务器配置了serverSideKeepAlive: true见packages/rsocket-core/src/RSocketServer.ts中的ServerConfig才会启动KeepAliveSender。两端都在数秒无论谁发双方的KeepAliveHandler都在盯着。任何一方在 lifetime 时长内没收到对端的心跳就关闭连接并抛出类似No keep-alive acks for xxx millis的错误。收到带RESPOND标志的心跳帧时KeepAliveHandler会立刻回一个不带 RESPOND 标志的心跳帧完成一次应答。KeepAlive 两个关键参数怎么配连接建立时客户端在 SETUP 帧里声明两个数值默认值见packages/rsocket-core/src/RSocketConnector.ts的connect()实现参数含义默认值keepAlive心跳发送间隔毫秒600001 分钟lifetime多久没收到心跳就判定连接已死毫秒3000005 分钟在连接器中这样配置即可生效new RSocketConnector({ setup: { keepAlive: 10000, // 每 10 秒发一次心跳 lifetime: 60000, // 60 秒没收到心跳就断开 }, transport: new TcpClientTransport({ /* ... */ }), });⚠️ 经验法则lifetime 应明显大于 keepAlive官方默认比例约 5 倍。心跳太频繁浪费带宽lifetime 太短则容易误杀正常连接。测试用例packages/rsocket-core/__tests__/KeepAliveHandler.spec.ts直观演示了行为超时未收到 KEEPALIVE 帧 → 调用connection.close()中途收到一帧 → 倒计时重置。二、Lease 租约背压机制Lease 解决什么问题把服务器想象成一家银行每个客户端来取业务发请求都要先领一张业务号票。服务器通过Lease 帧LeaseFrame见packages/rsocket-core/src/Frames.ts向客户端发放号票票面写清两个信息ttl号票有效期毫秒requestCount可以发起多少个请求客户端如何消费租约核心逻辑在LeaseHandler同样位于packages/rsocket-core/src/RSocketSupport.ts流程非常直观有票就直接发收到 Lease 帧后记下expirationTime ttl now、availableLease requestCount然后立即把排队中的请求逐个放行。没票就排队调用requestLease()时若可用租约为 0 或已过期请求进入pendingRequests等待队列。排队过长直接拒绝队列长度达到maxPendingRequests默认256可在lease配置中修改新请求立即收到REJECTED错误No available lease given。所以 Lease 是连接级背压它限制的是能同时发起多少条流而不是单条流内的 payload 节奏后者由 REQUEST_N 帧负责。开启 Lease 的两个前提双方必须达成一致packages/rsocket-core/src/RSocketServer.ts中如果服务器配置了lease而客户端 SETUP 帧没带 LEASE 标志或反过来服务器直接回REJECTED_SETUP并断开连接。这是新手最常踩的坑。租约由服务器颁发客户端只是消费方需要持续收到 Lease 帧才有新配额。最小开启方式参考示例packages/rsocket-examples/src/tcp/ClienRequestFnfnWithLeaseExampleTcp.ts// 客户端 new RSocketConnector({ lease: {}, transport: /* ... */ }); // 服务器RSocketServer 的 ServerConfig { lease: { maxPendingRequests: 512 }, transport: /* ... */ }三大机制对照速查表对比项KeepAlive 保活心跳Lease 背压租约目的检测并清理死连接控制客户端请求速率核心帧KEEPALIVELEASE关键参数keepAlive / lifetimettl / requestCount / maxPendingRequests默认值60s / 300s队列上限 256是否默认开启是客户端自动发送否需双方显式配置失败后果关闭整条连接请求进队列 / REJECTED 拒绝常见问题 FAQQKeepAlive 和 TCP keepalive 是一回事吗不是。TCP keepalive 是操作系统层面的、周期很长RSocket 的 KeepAlive 是应用层协议帧由 rsocket-js 精确控制间隔与超时语义上属于协议层探活。Q服务器不配serverSideKeepAlive会发生什么不会报错只是服务器不主动发心跳。只要客户端在发双方照样能互相探活但若双方都不发极少见lifetime 到期后连接会被单方面掐断。QLease 下取消排队中的请求可以吗可以。LeaseHandler.cancelRequest()会把请求从pendingRequests队列中移除见LeaseManager接口定义packages/rsocket-core/src/Lease.ts避免无效请求挤占队列。掌握 KeepAlive 与 Lease 这两个机制你就理解了 rsocket-js 在连接可靠性与流控上的全部核心设计可以自信地在生产环境中部署基于 RSocket 的双向通信服务了 【免费下载链接】rsocket-jsJavaScript implementation of RSocket项目地址: https://gitcode.com/gh_mirrors/rs/rsocket-js创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考