在异步回调中操作redis的一个异常
2014-09-01 · 549 chars · 3 min read
昨天在使用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
参数,具体用法看这里。