這篇“node中怎么使用消息隊(duì)列”文章的知識(shí)點(diǎn)大部分人都不太理解，所以小編給大家總結(jié)了以下內(nèi)容，內(nèi)容詳細(xì)，步驟清晰，具有一定的借鑒價(jià)值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來看看這篇“node中怎么使用消息隊(duì)列”文章吧。

成都創(chuàng)新互聯(lián)公司服務(wù)項(xiàng)目包括方正網(wǎng)站建設(shè)、方正網(wǎng)站制作、方正網(wǎng)頁制作以及方正網(wǎng)絡(luò)營(yíng)銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，方正網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到方正省份的部分城市，未來相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！

1.消息隊(duì)列

什么是消息隊(duì)列

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

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

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

消息隊(duì)列能做什么

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

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

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

• 應(yīng)用場(chǎng)景游戲活動(dòng)，秒殺活動(dòng)，下單等會(huì)造成瞬時(shí)流量暴增的應(yīng)用。

2.消息隊(duì)列的概念

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

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

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

鏈接，通道與隊(duì)列

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

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

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

總結(jié)一下，鏈接，通道隊(duì)列之間的關(guān)系是這樣的

交換機(jī)(exchange)

消息隊(duì)列發(fā)送消息時(shí)必須要有一個(gè)交換機(jī)，如果沒有指定則用的是默認(rèn)的交換機(jī)。交換機(jī)的作用就是將消息才推到對(duì)應(yīng)的隊(duì)列中。消息隊(duì)列中一共有4種交換機(jī)

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

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

• topic: 模糊匹配模式，通過模糊匹配的方式進(jìn)行相應(yīng)轉(zhuǎn)發(fā)。

• header: 與Direct模式類似。

3.node使用rabbitMQ

安裝rabbitMQ

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

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

  brew install rabbitmq

• 安裝完成后啟動(dòng)rabbitmq服務(wù)

然后再本地中訪問 http://localhost:15672/ 就可以看到rabbitmq服務(wù)的后臺(tái)。初始的賬號(hào)密碼均為 guest

node項(xiàng)目安裝amqplib

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

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

/** product.js 消費(fèi)者 */


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';
    
  // 知道交換機(jī)類型
  await channel.assertExchange(exchangeName, 'fanout', {
    durable: true,
  });
    
  // 指定一個(gè)隊(duì)列
  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();
})();

運(yùn)行后在后臺(tái)可以看到新增了一個(gè)有100條消息的隊(duì)列

創(chuàng)建消費(fèi)者

/** customer.js 消費(fèi)者 */

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)建兩個(gè)通道
  const channel1 = await connection.createChannel();
  const channel2 = await connection.createChannel();
  // 指定一個(gè)交換機(jī)
  await channel1.assertExchange(exchangeName, 'fanout', {
    durable: true,
  });
  // 指定一個(gè)隊(duì)列
  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í)行后可以看到，兩個(gè)通道可以同時(shí)工作接收消息

以上就是關(guān)于“node中怎么使用消息隊(duì)列”這篇文章的內(nèi)容，相信大家都有了一定的了解，希望小編分享的內(nèi)容對(duì)大家有幫助，若想了解更多相關(guān)的知識(shí)內(nèi)容，請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

文章標(biāo)題：node中怎么使用消息隊(duì)列
當(dāng)前URL：http://sd-ha.com/article36/gcjipg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供App設(shè)計(jì)、靜態(tài)網(wǎng)站、網(wǎng)站導(dǎo)航、網(wǎng)站營(yíng)銷、品牌網(wǎng)站建設(shè)、自適應(yīng)網(wǎng)站

廣告

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