node.js - 如何在多个 docker 容器从 redis kue nodejs 消耗时一次处理单个作业

Question

我有多个 docker 容器，它们使用来自同一个 redis kue 队列的作业。问题是他们从事相同的工作。我的需要是在一个容器上工作，然后在它完成一些其他容器工作之后。作业的顺序很重要。

如果我不能在 redis kue 中完成，但可以与其他队列管理器(如 kafka)一起完成，那也很好

Answer 1

我所做的是使用 switch case 保持状态机:

var index;

function whatever (){

    if (typeof state === 'undefined') {
        state = 0;
    }

    switch (state) {
        case 0:
            // Do whatever stuff needed;
            state++;
            break;

        case 1:
            // Do whatever stuff needed;
            state++;
            break;

        // Keep adding states

        case (last):
            // Do whatever stuff needed;
            state = 0; // if you need to reset state machine
            break;

    }
}

您可以做的另一件事是使用 Async , 已经在本站多次提及