如何使用 Redis Pub/Sub 在多个工作人员之间映射工作？

Question

我有一个 Redis 客户端，需要在 3 个工作人员之间拆分/映射一项工作。假设该工作由 3 个任务组成。我想以这样的方式映射它们，其中 3 个并行运行，并且该作业仅花费（大约）1/3 的执行时间。 Redis本身有什么办法可以做到这一点吗？我没有找到。

Answer 1

您可以使用redis创建任务队列。例如，您可以让主进程将任务推送到任务队列，然后让工作进程不断轮询任务队列以查找新工作。

Master伪代码：

while(1)
  if some_condition
    redis.rpush "tasks", "task1"
    redis.rpush "tasks", "task2"
    redis.rpush "tasks", "task3"
  end
  sleep 5
end

Worker伪代码：

while(1)
  # blpop blocks until there is an element in "tasks" 
  task = redis.blpop("tasks", 0)[1]
  perform task
end