首頁  >  文章  >  web前端  >  一文淺析node中如何使用訊息佇列

一文淺析node中如何使用訊息佇列

青灯夜游
青灯夜游轉載
2023-01-17 19:48:312271瀏覽

什麼是訊息隊列?以下這篇文章帶大家了解一下訊息佇列的基本概念,介紹一下node中如何使用訊息佇列,希望對大家有幫助!

一文淺析node中如何使用訊息佇列

1.訊息佇列

什麼是訊息佇列

#訊息佇列就是訊息的傳送過程中保存訊息的容器,本質是一個佇列(先進先出)

一文淺析node中如何使用訊息佇列

訊息指的是需要傳輸的數據,可以是一些文本,字串,或是物件等資訊。

訊息佇列則是兩個應用程式間的通訊服務,訊息的產生者將資料存放到訊息佇列中就可以立即返回,不需要等待訊息的接收者應答。即:生產者保證資料插入佇列,誰來取這則訊息不需要管。訊息的接收者則只專注於接受訊息並處理。 【相關教學推薦:nodejs影片教學程式教學

一文淺析node中如何使用訊息佇列

##訊息佇列能做什麼

  • 解耦 上面介紹了,訊息佇列將訊息的生產者和訊息的接收者分開,彼此都不受影響。

  • 非同步 非同步就是為了減少請求的回應時間,訊息的生產者只需要處理簡單的邏輯,並將資料放到訊息佇列中即可返回,複雜的邏輯,例如:資料庫操作,IO操作由訊息的接收者處理。

  • 削峰 訊息佇列應用在服務時,能將瞬時大量湧入的請求資訊儲存到訊息佇列中,並立即回傳。再由訊息的接收者根據資料處理請求。

  • 應用場景 遊戲活動,秒殺活動,下單等會造成瞬時流量暴增的應用。

2.訊息佇列的概念

介紹完訊息佇列的基本訊息,在開發訊息佇列之前先介紹一下訊息佇列的一些基本概念~

訊息的生產者(producer)與消費者(customer)

上文提到的

生產者消費者,提供的是

鏈接,通道與隊列

    # #連結(connection):表示服務程序與訊息佇列之間的一條連結。
  • 一個服務程式可以建立多個連結

  • 通道(channel):訊息佇列連結之間的一個通,
  • 一個連結可以有多個通道

  • 隊列(queue):訊息佇列中存放資料的佇列,一個訊息佇列服務可以有多個佇列。
  • 總結一下,鏈接,通道隊列之間的關係是這樣的

一文淺析node中如何使用訊息佇列

交換器(exchange )訊息佇列

傳送訊息

必須要有一個交換機,如果沒有指定則用的是預設的交換器。交換器的作用就是將訊息才推到對應的佇列中。訊息佇列中一共有4種交換器

    Direct: 指定佇列模式,訊息來了,只發給指定的Queue,其他Queue都收不到。
  • fanout: 廣播模式,訊息來了,就會傳送給所有的佇列。
  • topic: 模糊匹配模式,透過模糊匹配的方式進行對應轉送。
  • header: 與Direct模式類似。
3.node使用rabbitMQ

#安裝rabbitMQ

  • ##安裝rabbitMQ可以透過官網上進行下載安裝,
  • 傳送門

一文淺析node中如何使用訊息佇列MAC可以直接用brew指令安裝

brew install rabbitmq

安裝完成後啟動rabbitmq服務

一文淺析node中如何使用訊息佇列

然後再在本地存取http://localhost:15672/ 就可以看到rabbitmq服務的後台。初始的帳號密碼皆為

guest

##########node專案安裝amqplib#################################################################################

amqplib是node中使用消息队列的一套工具,可以让我们快速地使用消息队列

地址:https://www.npmjs.com/package/amqplib

创建生产者

/** product.js 消费者 */


const amqplib = require('amqplib');
const config = require('./config');

const { connectUrl } = config;

(async () => {
  const connection = await amqplib.connect(connectUrl);

  const channel = await connection.createChannel();
  const exchangeName = 'testExchange';
  const key = 'testQueue';
  const sendMsg = 'hello rabbitmq';
    
  // 知道交换机类型
  await channel.assertExchange(exchangeName, 'fanout', {
    durable: true,
  });
    
  // 指定一个队列
  await channel.assertQueue(key);

  for (let i = 0; i < 100; i++) {
    channel.publish(exchangeName, key, Buffer.from(`${sendMsg} ${i}`));
  }

  await channel.close();
  await connection.close();
})();

运行后在后台可以看到新增了一个有100条消息的队列

一文淺析node中如何使用訊息佇列

创建消费者

/** customer.js 消费者 */

const amqplib = require(&#39;amqplib&#39;);
const config = require(&#39;./config&#39;);

const { connectUrl } = config;

(async () => {
  let connection = await amqplib.connect(connectUrl);
  const exchangeName = &#39;testExchange&#39;;
  const key = &#39;testQueue&#39;;
  // 创建两个通道
  const channel1 = await connection.createChannel();
  const channel2 = await connection.createChannel();
  // 指定一个交换机
  await channel1.assertExchange(exchangeName, &#39;fanout&#39;, {
    durable: true,
  });
  // 指定一个队列
  await channel1.assertQueue(key);
  await channel1.bindQueue(key, exchangeName, key);
  channel1.consume(key, (msg) => {
    console.log(&#39;channel 1&#39;, msg.content.toString());
  });

  await channel2.assertExchange(exchangeName, &#39;fanout&#39;, {
    durable: true,
  });
  await channel2.assertQueue(key);
  await channel2.bindQueue(key, exchangeName, key);
  channel2.consume(key, (msg) => {
    console.log(&#39;channel 2&#39;, msg.content.toString());
  });
})();

执行后可以看到,两个通道可以同时工作接收消息

一文淺析node中如何使用訊息佇列

更多node相关知识,请访问:nodejs 教程

以上是一文淺析node中如何使用訊息佇列的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文轉載於:juejin.cn。如有侵權,請聯絡admin@php.cn刪除