単純なノードredisループ（ioredisを使用）を書く方が良いですか？

Question

だから、私は他の言語で長い時間からJS/Nodeの方法を学んでいます。

私はredisチャネルから読み込み、一時的にそれをワーキングチャネルに保存し、作業を行い、それを除去し、移動する小さなマイクロサービスを持っています。チャンネルにもっと多くのものがある場合、すぐに再実行されます。そうでない場合は、タイムアウトを設定し、1秒後に再度チェックします。

これはうまくいきますが、タイムアウトポーリングはこれに近づく「正しい」方法ではないようです。そして、私は、RPOPLPUSHに対してブロックしようとすると、Node ....やその他のオプションで待機するためにBRPOPLPUSHを使用することについて多くを見いだせませんでした。 （パブ/サブはこれが唯一のリスナーです...ここにオプションではありません、そしてそれは常に聞いてすることはできません。）

は、ここで私がやっているの短い本質です：

var Redis = require('ioredis'); 
var redis = new Redis(); 

var redisLoop = function() { 
    redis.rpoplpush('channel', 'channel-working').then(function (result) { 
     if (result) { 
      processJob(result); //do stuff 

      //delete the item from the working channel, and check for another item 
      redis.lrem('channel-working', 1, result).then(function (result) { }); 
      redisLoop(); 
     } else { 
      //no items, wait 1 second and try again 
      setTimeout(redisLoop, 1000); 
     } 
    }); 
}; 

redisLoop(); 

私は本当に明白な何かを見逃しているように感じる。ありがとう！

Answer 1

BRPOPLPUSHはノードにクライアントで、それをブロックしていません。この例では、あなたがポーリングを取り除くために必要なものだと私は思っています。あなたがあなたの次のダニは、アイテムが正常にchannel-workingから削除された後にのみ実行されることを保証するためにlrem(...).then(redisLoop)を使用する必要がありますのでredis.lremは、非同期であることを

var Redis = require('ioredis'); 
var redis = new Redis(); 

var redisLoop = function() { 
    redis.brpoplpush('channel', 'channel-working', 0).then(function (result) { 
     // because we are using BRPOPLPUSH, the client promise will not resolve 
     // until a 'result' becomes available 
     processJob(result); 

     // delete the item from the working channel, and check for another item 
     redis.lrem('channel-working', 1, result).then(redisLoop); 
    }); 
}; 

redisLoop(); 

注意。