代码拉取完成,页面将自动刷新
nats-client 针对fibjs的nats客户端实现
const Nats = require("fibjs-nats").Nats;
//无授权认证方式
var nc = Nats.make({json:true,url:"nats://127.0.0.1:4222"});
//tls认证方式
var nc = Nats.make({json:true,url:"nats://127.0.0.1:4222",ssl:{cert:"/nats/certs/client.pem",key:crt:"/nats/certs/client-key.pem"}});
//通过-username:password认证
var nc_auth_userpassword = Nats.make({json:true,url:"nats://myusername:mypassword@127.0.0.1:4222"});
//通过-authtoken认证
var nc_auth_token = Nats.make({json:true,url:"nats://mytoken@127.0.0.1:4222"});
//通过websockt接入
var nc_by_ws = Nats.make({json:true,url:"ws://127.0.0.1:8022"});
//多cluster接入
var nc = Nats.make({json:true,servers:["nats://127.0.0.1:4222","nats://127.0.0.1:4223","ws://127.0.0.1:8022"]});
//订阅主题
var sub = nc.subscribe("svr.sum",function (data,meta) {
meta.reply(data.a+data.b); //响应消息
});
console.log(nc.request("svr.sum",{a:2,b:3})==5);
//取消订阅
sub.cancel();
nc.unsubscribe(sub);
nc.unsubscribe(sub.sid);
nc.unsubscribeSubject("svr.sum");
//取消所有订阅
uc.unsubscribeAll();
nc.subscribe("svr.log",function (data,meta) {
console.log("svr.log",data);
});
//发布消息
nc.publish("svr.log", "on xxx");
//ping
console.log(nc.ping());
//释放连接
nc.close();
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。