const queue = [];
queue.push('item 1');
queue.push('item 2');
console.log(queue.shift()); // item 1
console.log(queue.shift()); // item 2

>對于復(fù)雜的服務(wù)器應(yīng)用程序，專用消息經(jīng)紀(jì)人提供：

class Queue {
  constructor() { this.q = []; }
  send(item) { this.q.push(item); }
  receive() { return this.q.shift(); }
}

數(shù)據(jù)持久性

多個(gè)訪問協(xié)議 多個(gè)隊(duì)列

延遲消息

類似交易的支持
> Publish-subscribe模式 >
• 使用mongodb作為消息經(jīng)紀(jì)：
>
• 我們將使用
>模塊進(jìn)行健壯的，易于實(shí)現(xiàn)的節(jié)點(diǎn)任務(wù)隊(duì)列。
• >節(jié)點(diǎn)任務(wù)隊(duì)列項(xiàng)目設(shè)置：
>
1. > install node.js 14。
2. 創(chuàng)建一個(gè)項(xiàng)目文件夾（queue-test）。
3. 創(chuàng)建package.json：

const queue = [];
queue.push('item 1');
queue.push('item 2');
console.log(queue.shift()); // item 1
console.log(queue.shift()); // item 2

4. >安裝依賴項(xiàng)：npm install
5. >使用mongodb連接詳細(xì)信息創(chuàng)建.env>文件（例如，QUEUE_DB_HOST，QUEUE_DB_PORT，等）。
6. （可選）使用docker為mongodb實(shí)例組成。
>

send.js（添加到隊(duì)列）：

>

class Queue {
  constructor() { this.q = []; }
  send(item) { this.q.push(item); }
  receive() { return this.q.shift(); }
}

<> receive.js（從隊(duì)列進(jìn)行處理）：

>

{
  "name": "queue-test",
  "version": "1.0.0",
  "type": "module",
  "scripts": {
    "send": "node ./send.js",
    "receive": "node ./receive.js"
  },
  "dependencies": {
    "@craigbuckler/queue-mongodb": "^1.0.0", // Adjust version as needed
    "dotenv": "^16.0.3" // Add dotenv for environment variables
  }
}

queue-mongodb模塊詳細(xì)信息：

>模塊使用mongoDB進(jìn)行存儲。 該方法添加了文檔，send()>檢索并刪除了最古老的項(xiàng)目。 receive()，remove()和purge()>提供其他隊(duì)列管理功能。 count()

結(jié)論：

本教程展示了一種使用mongoDB在node.js中實(shí)現(xiàn)任務(wù)隊(duì)列的實(shí)用和有效方法。 這種方法平衡了簡單性和可擴(kuò)展性，使其適用于廣泛的應(yīng)用。 請記住，將代碼和配置調(diào)整為您的特定需求和環(huán)境。 完整的代碼可在GitHub上找到（如果可用的GitHub存儲庫可用）。>）。

以上是隊(duì)列數(shù)據(jù)結(jié)構(gòu)：如何構(gòu)建節(jié)點(diǎn)任務(wù)隊(duì)列的詳細(xì)內(nèi)容。更多信息請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！