代码拉取完成,页面将自动刷新
同步操作将从 qianbo0423/iotserver-netty 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
var redis = require("redis");
var client = redis.createClient(6379, "192.168.1.222");
var client1 = redis.createClient(6379, "192.168.1.222");
client1.on('connect', function () {
client1.subscribe("draw");
});
client1.on("message", function (channel, message) {
console.log(typeof (message));
var obj = JSON.parse(message);
console.log("普通订阅接收到来自" + channel + "的信息:" + obj.session);
if (message == "quit") {
client1.unsubscribe("draw");
console.log("普通订阅操作已经取消");
//client2.quite();
}
});
/*
var client2 = redis.createClient("6379", "192.168.1.222");
client2.on('connect', function () {
client2.psubscribe("draw*");
});
client2.on("pmessage", function (p, channel, message) {
console.log("批量订阅接收到来自" + channel + "的信息:" + message);
if (message == "quit") {
client2.punsubscribe("draw*");
console.log("批量订阅操作已经取消");
//client2.quite();
}
});
*/
/*
function getRedisData() {
//客户端连接redis成功后执行回调
client.on("ready", function () {
//订阅消息
client.subscribe("chat");
client.subscribe("chat1");
console.log("订阅成功。。。");
});
client.on("error", function (error) {
console.log("Redis Error " + error);
});
//监听订阅成功事件
client.on("subscribe", function (channel, count) {
console.log("client subscribed to " + channel + "," + count + "total subscriptions");
});
//收到消息后执行回调,message是redis发布的消息
client.on("message", function (channel, message) {
console.log("我接收到信息了" + message);
//dealWithMsg(message);
});
//监听取消订阅事件
client.on("unsubscribe", function (channel, count) {
console.log("client unsubscribed from" + channel + ", " + count + " total subscriptions")
});
}
function dealWithMsg(message) {
//按照message查询内容
client1.zscore("key", message, function (err, reply) {
console.log(message + "的内容是:" + reply);
});
}
getRedisData();
*/
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。