0

我正在使用来自https://www.npmjs.com/package/bullmqconst queue = new Queue('Paint')页面的非常基本的示例 ( ) - 一切正常(默认为)。localhost:6379

但是,当我添加new Queue('Paint', { connection })基于对 Redis ( rediss://...) 的 TLS 访问的连接 () 时,我仍然可以将作业推送到队列中(我在 Redis 本身中看到),但是这些作业都不会被工作人员拉取。

也许我错过了一些隐藏的标志?

谢谢!

-Dror

4

2 回答 2

1

我发现了发生了什么——尽管我仍然不确定为什么:

当问题浮出水面时,我正在使用ioredis作为公牛的连接。当我用redis替换它时,它开始正常工作,将作业从队列中拉出。

这两个包都完全支持 Redis over TLS,但由于某种原因,与 Bull 的集成对 ioredis 不起作用。

-Dror

于 2021-09-04T17:44:03.807 回答
0

发生这种情况是由于此处对 redis url 的手动和不完整解析:https ://github.com/OptimalBits/bull/blob/develop/lib/queue.js#L308

redis:// vs redis:// 根本没有考虑到。

要解决此问题,我必须向其他“redis”键添加更多键:

export const REDIS_CONNECTION: Redis.RedisOptions = {
  ...(REDIS_URL.startsWith('rediss://') ? { tls: {} } : null), // This trick makes sure SSL would work
  retryStrategy: (times) => {
    // reconnect after
    return Math.min(times * 50, 2000);
  },
};

export const queue = new Bull<JobData>('foobar', REDIS_URL, {
  redis: REDIS_CONNECTION,
...
于 2021-12-01T22:11:02.777 回答