Bullmq不能通过TLS从Redis拉取作业

Question

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

但是，当我添加一个基于对Redis (rediss://...)的TLS访问的连接(new Queue('Paint', { connection }))时，我仍然可以将作业推入队列(我在Redis中看到了这一点)，但是这些作业都不会被worker拉出。

也许我遗漏了一些隐藏的旗帜？

谢谢!

-Dror

Answer 1

我发现了发生了什么-尽管我仍然不确定为什么：

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

这两个包都完全支持Redis over TLS，但由于某些原因，与bull的集成不适用于ioredis。

-Dror

Answer 2

这是由于对redis url的手动解析和不完整造成的：https://github.com/OptimalBits/bull/blob/develop/lib/queue.js#L308

rediss:// 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,
...