我不确定我遇到的问题是redis本身的限制还是nodejs 'redis‘模块实现的限制。
var redis = require('redis');
var client = redis.createClient(6379,'192.168.200.5');
client.on('error',function (error) {
console.log("** error in connection **");
process.exit(1);
});
client.on('connect',function () {
console.log("** connected **");
client.on('message',function (channel,message) {
if (channel == 'taskqueue') {
console.log(channel + ' --> ' + message);
var params = message.split(' ');
var inputf = params[0];
var outputf = params[1];
var dim = inputf.split('_').slice(-1)[0];
client.rpush('records',message,function (e,reply) {
});
}
});
client.subscribe('taskqueue');
});通过上面的代码片段,我尝试在"ON MESSAGE“订阅事件中执行RPUSH。它不工作,并且我得到一个客户端'ON ERROR‘事件,因此,它在连接中打印错误。执行此操作的正确方法是什么?
发布于 2015-10-09 04:06:05
经过进一步的搜索,我发现了这个页面的https://github.com/phpredis/phpredis/issues/365,它似乎解释了这个场景。
https://stackoverflow.com/questions/33019042
复制相似问题