我在javascript中有以下代码
var nsq = require('nsqjs');
var reader = new nsq.Reader('output', 'out', {
lookupdHTTPAddresses: '172.32.10.224:4161'
});
reader.connect();
reader.on('message', function (msg) {
console.log('Received message [%s]: %s', msg.id, msg.body.toString());
});
这是python中的等效版本。
import nsq
def handler(message):
print str(message.body)
return True
r = nsq.Reader(message_handler=handler,
lookupd_http_addresses=['http://172.32.10.224:4161'],
topic='output', channel='out')
nsq.run()
与javascript相比,python版本的运行速度非常快。 javascript版本似乎每2分钟处理1条消息。而且python似乎可以在毫秒内处理。我真的很惊讶这里发生了什么?这是我运行的确切代码,我的队列中有很多我已验证的消息。任何想法为什么javascript版本真的很慢?
最佳答案
您不是在告诉NSQ您已处理此消息:
reader.on('message', function (msg) {
console.log('Received message [%s]: %s', msg.id, msg.body.toString());
msg.finish(); // <---
});
请参见here。
我认为Python驱动程序会根据处理程序的返回值隐式执行此操作(
True
完成,False
重新排队)。