什麼是訊息隊列？以下這篇文章帶大家了解一下訊息佇列的基本概念，介紹一下node中如何使用訊息佇列，希望對大家有幫助！
1.訊息佇列
什麼是訊息佇列
#訊息佇列就是訊息的傳送過程中保存訊息的容器，本質是一個佇列(先進先出)
訊息指的是需要傳輸的數據，可以是一些文本，字串，或是物件等資訊。
訊息佇列則是兩個應用程式間的通訊服務，訊息的產生者將資料存放到訊息佇列中就可以立即返回，不需要等待訊息的接收者應答。即：生產者保證資料插入佇列，誰來取這則訊息不需要管。訊息的接收者則只專注於接受訊息並處理。 【相關教學推薦：nodejs影片教學、程式教學】
##訊息佇列能做什麼
解耦 上面介紹了，訊息佇列將訊息的生產者和訊息的接收者分開，彼此都不受影響。
非同步 非同步就是為了減少請求的回應時間，訊息的生產者只需要處理簡單的邏輯，並將資料放到訊息佇列中即可返回，複雜的邏輯，例如：資料庫操作，IO操作由訊息的接收者處理。
削峰 訊息佇列應用在服務時，能將瞬時大量湧入的請求資訊儲存到訊息佇列中，並立即回傳。再由訊息的接收者根據資料處理請求。
應用場景 遊戲活動，秒殺活動，下單等會造成瞬時流量暴增的應用。
2.訊息佇列的概念
介紹完訊息佇列的基本訊息，在開發訊息佇列之前先介紹一下訊息佇列的一些基本概念~
訊息的生產者(producer)與消費者(customer)
上文提到的
生產者與消費者，提供的是
鏈接，通道與隊列
# #連結(connection)：表示服務程序與訊息佇列之間的一條連結。 - 一個服務程式可以建立多個連結
。
通道(channel)：訊息佇列連結之間的一個通，- 一個連結可以有多個通道
。
隊列(queue)：訊息佇列中存放資料的佇列，一個訊息佇列服務可以有多個佇列。
交換器(exchange )訊息佇列
傳送訊息
時必須要有一個交換機，如果沒有指定則用的是預設的交換器。交換器的作用就是將訊息才推到對應的佇列中。訊息佇列中一共有4種交換器
Direct: 指定佇列模式，訊息來了，只發給指定的Queue，其他Queue都收不到。
3.node使用rabbitMQ
#安裝rabbitMQ
-
- ##安裝rabbitMQ可以透過官網上進行下載安裝，
傳送門
MAC可以直接用brew指令安裝
brew install rabbitmq
登入後複製
安裝完成後啟動rabbitmq服務
然後再在本地存取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条消息的队列
创建消费者
/** 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';
// 创建两个通道
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());
});
})();登入後複製
执行后可以看到，两个通道可以同时工作接收消息
更多node相关知识，请访问：nodejs 教程！
以上是一文淺析node中如何使用訊息佇列的詳細內容。更多資訊請關注PHP中文網其他相關文章！
