在异步回调中操作redis的一个异常

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了在异步回调中操作redis的一个异常，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2525字，纯文字阅读大概需要4分钟。

内容图文

昨天在使用node redis的时候报了这样一个错： TypeError: Object [object Object] has no method 'send_command' at RedisClient.(anonymous function) (D:\index.js:991:25) at null._onTimeout (D:\index.js:17:22) at Timer.listOnTimeout [as ontimeout]

昨天在使用node redis的时候报了这样一个错：

TypeError: Object [object Object] has no method 'send_command'
    at RedisClient.(anonymous function) (D:\index.js:991:25)
    at null._onTimeout (D:\index.js:17:22)
    at Timer.listOnTimeout [as ontimeout] (timers.js:110:15)

这个bug比较隐蔽，一步一步来看：

起因

我要实现的是批量插入redis的列表（list），相关的api是这样的：client.rpush(key, [value1, value2, ..., callback]) ，参数必须一个一个列出来，要想批量添加（数组），只能使用apply 方法了：

var array = ['list', '1', '2', '3', '4',
    function() {
        console.log('success');
    }
];
client.rpush.apply(this, array);

数组的第一参数是key，最后一个是回调函数，之间全部是要添加的数据。构造这样一个数组，使用apply 就很完美的解决了批量添加的问题。但是还是太年轻啊，执行demo的时候很正常，但是放入正式代码中就有问题了。

解决

正式代码的数据一般是异步得到的，用setTimeout 模拟一下：

var redis = require('redis'),
    client = redis.createClient(6379, '127.0.0.1', {
        auth_pass: 'home.local.17173.com'
    });
client.on('error', function(err) {
    console.log('redis错误：' + err);
});
client.on('connect', function() {
    setTimeout(function() {
        var array = ['list', '1', '2', '3', '4',
            function() {
                console.log('success');
            }
        ];
        client.rpush.apply(this, array);
    }, 1000);
});

执行上面的代码会报出文章开头的错误，提示“Object [object Object] has no method ‘send_command’”，联系到apply 的this，问题可能出在作用域上，修改倒数第三行代码：

client.rpush.apply(client, array);

执行后就ok了：

所以问题就是出在作用域上，apply 这样的比较明显，但是使用async等就不是那么明显了。在stackoverflow上找到一个问题，有bug的代码是这样的：

var async = require('async');
var redis = require('redis');
var keys = ['key1', 'key2', 'key3'];
var client = redis.createClient();
var multi = client.multi();
for (var key in keys) {
  multi.hmset(key, {'some': 'value'});
}
multi.exec(function(err, res) {
  if (err) throw err;
  console.dir(res);
  var myCallback = function(err, res) {
    console.log('in myCallback');
    console.dir(res);
    client.quit();
    process.exit();
  };
 async.concat(keys, client.hgetall, myCallback);
});

错误还是和文章开头的一样，解决方法是使用bind 函数。修改倒数第二行代码如下：

async.concat(keys, client.hgetall.bind(client), myCallback);

bind函数可以用来设置this 参数，具体用法看这里。

原文地址：在异步回调中操作redis的一个异常, 感谢原作者分享。

内容总结

以上是互联网集市为您收集整理的在异步回调中操作redis的一个异常全部内容，希望文章能够帮你解决在异步回调中操作redis的一个异常所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端