Лучший способ написать простой цикл Node redis (используя ioredis)?

Question

Итак, я долгое время изучаю путь JS/Node на других языках.

У меня крошечный микросервис, который читается с канала redis, темп сохраняет его на рабочем канале, выполняет работу, удаляет его и перемещается. Если в канале больше, он снова запускается немедленно. Если нет, он устанавливает тайм-аут и снова проверяет через 1 секунду.

Он отлично работает ... но тайм-аут не кажется «правильным» способом приблизиться к этому. И я не нашел много о том, как использовать BRPOPLPUSH, чтобы попытаться заблокировать (против RPOPLPUSH) и подождать в узле .... или другие варианты. (Pub/Sub не является вариантом здесь ... это единственный слушатель, и это не всегда может слушать.)

Вот короткая суть того, что я делаю:

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 не блокирует в Node, он блокирует в клиента. В этом случае я думаю, что это именно то, что вам нужно, чтобы избавиться от опроса.

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(); 

Обратите внимание, что redis.lrem асинхронный, так что вы должны использовать lrem(...).then(redisLoop), чтобы убедиться, что ваш следующий тик выполняется только после того, как элемент успешно удален из channel-working.