简介
Feathers-bee-queue 是一个对 Bee-queue 消息队列的封装，能够在 Feathers 框架中使用。它提供了一个可扩展的 Job Service，可以与您的 Feathers 服务一起使用，为您的应用程序提供异步任务的机制。
安装
使用 npm 安装：
npm install feathers-bee-queue --save
或者使用 yarn 安装：
yarn add feathers-bee-queue
使用
在您的 Feathers 应用程序中创建一个 Job Service：
-- -------------------- ---- ------- -- --------------- ----- -------- - --------------------- ----- - ------- - - ------------------------------ ----- ----- - --- --------------------- -------------- - ----- ----------- ------- ------- - -------------------- - --------------- ---------- - ------ - --展开代码
然后，在您的 Feathers 应用程序中使用 Job Service：
-- -------------------- ---- ------- -- ------ ----- -------- - -------------------------------- ----- ------- - ------------------------------- ----- ----------- - -------------------------- ----- --- - -------------------- ------------------------ ------------------------------ ---------------- --- --------------- -----------------展开代码
现在，您可以在您的客户端应用程序中使用 Rest API 调用 Job Service方法：
-- -------------------- ---- ------- -- --------- ----- -------- - -------------------------------- ----- ---- - ----------------------------------- ----- -------------- - ----------- ----- ---------- - ------------------------------ --------------------------------------------------------- --------------------------------------- ----- -------- -- --- -- ----- - --- ----------------- ----- ------------------- -------- ------- -------- ----- ----- -- -- ------- -- --------- - -- --- -- --------- -- -------------------- ------ ------展开代码
深入学习
每个 Job 都需要一个类型（type）和数据（data）。类型用于指定执行此任务的 worker（工作者），而数据则是传递给该 worker 的数据。
Worker 函数可以是一个异步函数，它将执行您想要的任何代码，但是当完成任务时，它必须调用 job.done()，以便队列系统可以更新任务的状态：
// job-worker.js async function jobWorker(job) { console.log('Processing job:', job.id); await sendEmail(job.data.to, job.data.from, job.data.subject, job.data.text); console.log('Completed job:', job.id); job.done(); }
您还可以使用 job.progress(value) 方法发送进度更新：
-- -------------------- ---- ------- -- --------------------------- ----- -------- -------------- - ----------------------- ------ -------- --- ---- - - -- - - ---- ---- - ----- --------- ---------------- - ---------------------- ------ -------- ----------- -展开代码
指导意义
Feathers-bee-queue 可以帮助您构建一个可伸缩的应用程序，它可以处理大量的异步任务。它的灵活性使得您可以轻松地与您的现有 Feathers 服务集成，它还提供了可扩展的 worker 函数，并轻松地设置载荷均衡。您可以使用它来为您的应用程序提供自动化任务，例如发送邮件、生成报告或上传文件。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/108421
