Ping/Pong 协议
// 设置 Ping 间隔为 20 秒,最大未响应 PING 数量为 5
nc, err := nats.Connect("demo.nats.io", nats.Name("API Ping Example"), nats.PingInterval(20*time.Second), nats.MaxPingsOutstanding(5))
if err != nil {
log.Fatal(err)
}
defer nc.Close()
// 用连接做点事情Options options = new Options.Builder()
.server("nats://demo.nats.io")
.pingInterval(Duration.ofSeconds(20)) // 设置 Ping 间隔
.maxPingsOut(5) // 设置最大未响应 PING 数量
.build();
// 连接是 AutoCloseable 类型
try (Connection nc = Nats.connect(options)) {
// 用连接做点事情
}// 设置 Ping 间隔为 20 秒,最大未响应 PING 数量为 5
const nc = await connect({
pingInterval: 20 * 1000,
maxPingOut: 5,
servers: ["demo.nats.io:4222"],
});最后更新于