连接到集群
servers := []string{"nats://127.0.0.1:1222", "nats://127.0.0.1:1223", "nats://127.0.0.1:1224"}
nc, err := nats.Connect(strings.Join(servers, ","))
if err != nil {
log.Fatal(err)
}
defer nc.Close()
// 使用连接做一些事情Options options = new Options.Builder()
.server("nats://127.0.0.1:1222,nats://127.0.0.1:1223,nats://127.0.0.1:1224")
.build();
Connection nc = Nats.connect(options);
// 使用连接做一些事情
nc.close();const nc = await connect({
servers: [
"nats://demo.nats.io:4222",
"nats://localhost:4222",
],
});
// 使用连接做一些事情
doSomething();
// 完成后关闭连接
await nc.close();最后更新于