问题描述
***
var redisClient = redis.createClient(6379,"127.0.0.1");
redisClient.on('connect',function() {
console.log('we are connected with redis server')
});
redisClient.subscribe('message','call','status');
redisClient.on("message",function(channel,message) {
var data = JSON.parse(message);
console.log("new message in queue " + "channel : " + channel + " reciever: " + message);
io.in(data.receiver_id).emit("message",message);
});
redisClient.on("call",call) {
var data = JSON.parse(call);
console.log("new call in queue " + "channel : " + channel + " reciever: " + call);
io.in(data.receiver_id).emit("call",call);
});
redisClient.on("status",status) {
var data = JSON.parse(status);
console.log("new status in queue " + "channel : " + channel + " reciever: " + status);
io.in(data.receiver_id).emit("status",status);
});***
创建了第一个消息事件,并在消息事件内部创建了其他消息
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)