使用BullMQ集成Bull Arena报错：3.0.0+需提供队列构造函数

这个报错是因为Bull Arena 3.0.0版本起，要求显式指定每个队列对应的构造函数，不再自动推断Bull或BullMQ类型。你需要调整配置结构，给每个队列指定类型和对应的BullMQ构造函数。

修正后的代码示例 #

假设你的bullQueues是队列配置数组，修改如下：

import BullMQ from 'bullmq';
import Arena from 'bull-arena';

// 给每个队列配置添加type和BullMQ构造函数
const bullQueues = [
  {
    name: 'your-queue-name',
    hostId: 'your-worker-id',
    type: 'bullmq', // 声明这是BullMQ类型的队列
    BullMQ, // 传入BullMQ构造函数
    redis: {
      host: 'your-redis-host',
      port: 6379,
      // 按需添加redis密码、数据库等配置
    },
    // 其他队列配置项...
  },
  // 其他队列同理配置
];

const arenaConfig = Arena({
  queues: bullQueues,
});

批量配置简化方案 #

如果有多个BullMQ队列，可以通过queueConstructors全局注册构造函数，再给每个队列指定type：

import BullMQ from 'bullmq';
import Arena from 'bull-arena';

const bullQueues = [
  {
    name: 'queue-1',
    hostId: 'worker-1',
    type: 'bullmq',
    redis: { host: 'localhost', port: 6379 },
  },
  {
    name: 'queue-2',
    hostId: 'worker-2',
    type: 'bullmq',
    redis: { host: 'localhost', port: 6379 },
  },
];

const arenaConfig = Arena({
  // 全局注册BullMQ构造函数
  queueConstructors: {
    bullmq: BullMQ,
  },
  queues: bullQueues,
});

关键注意事项 #

• 每个队列必须显式设置type: 'bullmq'，否则Arena无法匹配对应的构造函数。
• 建议保持BullMQ和Bull Arena的版本为最新稳定版，避免其他兼容性问题。

内容的提问来源于stack exchange，提问作者Vzans