這篇文章主要介紹“node消息隊列怎么使用”，在日常操作中，相信很多人在node消息隊列怎么使用問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”node消息隊列怎么使用”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！

你所需要的網(wǎng)站建設服務，我們均能行業(yè)靠前的水平為你提供.標準是產(chǎn)品質(zhì)量的保證，主要從事成都網(wǎng)站制作、成都做網(wǎng)站、企業(yè)網(wǎng)站建設、移動網(wǎng)站建設、網(wǎng)頁設計、品牌網(wǎng)站設計、網(wǎng)頁制作、做網(wǎng)站、建網(wǎng)站。創(chuàng)新互聯(lián)建站擁有實力堅強的技術研發(fā)團隊及素養(yǎng)的視覺設計專才。

1.消息隊列

什么是消息隊列

消息隊列就是消息的傳輸過程中保存消息的容器，本質(zhì)是一個隊列(先進先出)

消息指的是需要傳輸?shù)臄?shù)據(jù)，可以是一些文本，字符串，或者是對象等信息。

消息隊列則是兩個應用間的通信服務，消息的產(chǎn)生者將數(shù)據(jù)存放到消息隊列中就可以立即返回，不需要等待消息的接收者應答。即：生產(chǎn)者保證數(shù)據(jù)插入隊列，誰來取這條消息不需要管。消息的接收者則只專注于接受消息并處理。

消息隊列能做什么

• 解耦上面介紹了，消息隊列將消息的生產(chǎn)者和消息的接收者分開，彼此都不受影響。

• 異步異步就是為了減少請求的響應時間，消息的生產(chǎn)者只需要處理簡單的邏輯，并將數(shù)據(jù)放到消息隊列中即可返回，復雜的邏輯，比如：數(shù)據(jù)庫操作，IO操作由消息的接收者處理。

• 削峰消息隊列應用在服務時，能將瞬時大量涌入的請求信息保存到消息隊列中，并立即返回。再由消息的接收者根據(jù)數(shù)據(jù)處理請求。

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

2.消息隊列的概念

介紹完消息隊列的基本信息，在開發(fā)消息隊列之前先介紹一下消息隊列的一些基本概念~

消息的生產(chǎn)者(producer)與消費者(customer)

上文提到的生產(chǎn)者與消費者，提供的是

鏈接，通道與隊列

• 鏈接(connection)：表示服務程序與消息隊列之間的一條鏈接。一個服務程序可以創(chuàng)建多條鏈接。

• 通道(channel)：消息隊列鏈接之間的一個通，一個鏈接可以有多個通道。

• 隊列(queue)：消息隊列中存放數(shù)據(jù)的隊列，一個消息隊列服務可以有多個隊列。

總結一下，鏈接，通道隊列之間的關系是這樣的

交換機(exchange)

消息隊列發(fā)送消息時必須要有一個交換機，如果沒有指定則用的是默認的交換機。交換機的作用就是將消息才推到對應的隊列中。消息隊列中一共有4種交換機

• Direct: 指定隊列模式，消息來了，只發(fā)給指定的Queue，其他Queue都收不到。

• fanout: 廣播模式，消息來了，就會發(fā)送給所有的隊列。

• topic: 模糊匹配模式，通過模糊匹配的方式進行相應轉發(fā)。

• header: 與Direct模式類似。

3.node使用rabbitMQ

安裝rabbitMQ

• 安裝rabbitMQ可以通過官網(wǎng)上進行下載安裝，傳送門

• MAC可以直接用brew命令安裝

  brew install rabbitmq
  

• 安裝完成后啟動rabbitmq服務

然后再本地中訪問 http://localhost:15672/ 就可以看到rabbitmq服務的后臺。初始的賬號密碼均為 guest

node項目安裝amqplib

amqplib是node中使用消息隊列的一套工具，可以讓我們快速地使用消息隊列

創(chuàng)建生產(chǎn)者

/** 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條消息的隊列

創(chuàng)建消費者

/** customer.js 消費者 */

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

const { connectUrl } = config;

(async () => {
  let connection = await amqplib.connect(connectUrl);
  const exchangeName = 'testExchange';
  const key = 'testQueue';
  // 創(chuàng)建兩個通道
  const channel1 = await connection.createChannel();
  const channel2 = await connection.createChannel();
  // 指定一個交換機
  await channel1.assertExchange(exchangeName, 'fanout', {
    durable: true,
  });
  // 指定一個隊列
  await channel1.assertQueue(key);
  await channel1.bindQueue(key, exchangeName, key);
  channel1.consume(key, (msg) => {
    console.log('channel 1', msg.content.toString());
  });

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

執(zhí)行后可以看到，兩個通道可以同時工作接收消息

到此，關于“node消息隊列怎么使用”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續(xù)學習更多相關知識，請繼續(xù)關注創(chuàng)新互聯(lián)網(wǎng)站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>

本文名稱：node消息隊列怎么使用
當前URL：http://chinadenli.net/article38/ipcosp.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站營銷、小程序開發(fā)、網(wǎng)站制作、外貿(mào)網(wǎng)站建設、全網(wǎng)營銷推廣、虛擬主機

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)