快速启动

安装

Install using npm:

Text Only

$ npm install bullmq

Install using yarn:

Text Only

$ yarn add bullmq

{% hint style="info" %} Bull is written in TypeScript, and although it can be used in vanilla JavaScript, all examples in this guide will be written in TypeScript. {% endhint %}

Import into your project and add some jobs:

TypeScript

import { Queue } from "bullmq";

const myQueue = new Queue("foo");

async function addJobs() {
  await myQueue.add("myJobName", { foo: "bar" });
  await myQueue.add("myJobName", { qux: "baz" });
}

await addJobs();

{% hint style="danger" %} You need to have a Redis service running in your local computer to run these examples successfully. You can read more about Redis connections here. {% endhint %}

Jobs are added to the queue and can be processed at any time, with at least one Node.js process running a worker:

TypeScript

import { Worker } from "bullmq";

const worker = new Worker(queueName, async (job) => {
  // Will print { foo: 'bar'} for the first job
  // and { qux: 'baz' } for the second.
  console.log(job.data);
});

{% hint style="info" %} You can have as many worker processes as you want, BullMQ will distribute the jobs across your workers in a round robin fashion. {% endhint %}

You can listen to completed (or failed) jobs by attaching listeners to the workers:

TypeScript

worker.on("completed", (job) => {
  console.log(`${job.id} has completed!`);
});

worker.on("failed", (job, err) => {
  console.log(`${job.id} has failed with ${err.message}`);
});

{% hint style="info" %} There are many other events available, check the Guide or the API reference for more information. {% endhint %}

Sometimes you need to listen to all the workers events in a given place, for this you need to use a special class QueueEvents:

TypeScript

import { QueueEvents } from "bullmq";

const queueEvents = new QueueEvents();

queueEvents.on("waiting", ({ jobId }) => {
  console.log(`A job with ID ${jobId} is waiting`);
});

queueEvents.on("active", ({ jobId, prev }) => {
  console.log(`Job ${jobId} is now active; previous status was ${prev}`);
});

queueEvents.on("completed", ({ jobId, returnvalue }) => {
  console.log(`${jobId} has completed and returned ${returnvalue}`);
});

queueEvents.on("failed", ({ jobId, failedReason }) => {
  console.log(`${jobId} has failed with reason ${failedReason}`);
});

You may also access the timestamp of the event, which looks like "1580456039332-0".

TypeScript

import { QueueEvents } from "bullmq";

const queueEvents = new QueueEvents();

queueEvents.on("progress", ({ jobId, data }, timestamp) => {
  console.log(`${jobId} reported progress ${data} at ${timestamp}`);
});

{% hint style="danger" %} For performance reasons the events emited by a QueueEvents instance do not contain the Job instance, only the jobId. Use the Job#fromId method if you need the Job instance. {% endhint %}