Ein Artikel, der kurz analysiert, wie die Nachrichtenwarteschlange im Knoten verwendet wird

Was ist eine Nachrichtenwarteschlange? Der folgende Artikel führt Sie durch die Grundkonzepte von Nachrichtenwarteschlangen und stellt Ihnen die Verwendung von Nachrichtenwarteschlangen im Knoten vor. Ich hoffe, er wird Ihnen hilfreich sein!

1. Nachrichtenwarteschlange

Was ist eine Nachrichtenwarteschlange?

Eine Nachrichtenwarteschlange ist ein Container, der Nachrichten während des Nachrichtenübertragungsprozesses speichert. Zuerst raus)

Nachricht bezieht sich auf die Daten, die übertragen werden müssen, bei denen es sich um Text, Zeichenfolgen, Objekte und andere Informationen handeln kann. 消息指的是需要传输的数据，可以是一些文本，字符串，或者是对象等信息。

消息队列则是两个应用间的通信服务，消息的产生者将数据存放到消息队列中就可以立即返回，不需要等待消息的接收者应答。即：生产者保证数据插入队列，谁来取这条消息不需要管。消息的接收者则只专注于接受消息并处理。【相关教程推荐：nodejs视频教程、编程教学】

消息队列能做什么

• 解耦 上面介绍了，消息队列将消息的生产者和消息的接收者分开，彼此都不受影响。

• 异步 异步就是为了减少请求的响应时间，消息的生产者只需要处理简单的逻辑，并将数据放到消息队列中即可返回，复杂的逻辑，比如：数据库操作，IO操作由消息的接收者处理。

• 削峰 消息队列应用在服务时，能将瞬时大量涌入的请求信息保存到消息队列中，并立即返回。再由消息的接收者根据数据处理请求。

• 应用场景 游戏活动，秒杀活动，下单等会造成瞬时流量暴增的应用。

2.消息队列的概念

介绍完消息队列的基本信息，在开发消息队列之前先介绍一下消息队列的一些基本概念~

消息的生产者(producer)与消费者(customer)

上文提到的生产者与消费者，提供的是

链接，通道与队列

• 链接(connection)：表示服务程序与消息队列之间的一条链接。一个服务程序可以创建多条链接。

• 通道(channel)：消息队列链接之间的一个通，一个链接可以有多个通道。

• 队列(queue)：消息队列中存放数据的队列，一个消息队列服务可以有多个队列。

总结一下，链接，通道队列之间的关系是这样的

交换机(exchange)

消息队列发送消息时必须要有一个交换机，如果没有指定则用的是默认的交换机。交换机的作用就是将消息才推到对应的队列中。消息队列中一共有4种交换机

• Direct: 指定队列模式，消息来了，只发给指定的Queue，其他Queue都收不到。

• fanout: 广播模式，消息来了，就会发送给所有的队列。

• topic: 模糊匹配模式，通过模糊匹配的方式进行相应转发。

• header: 与Direct模式类似。

3.node使用rabbitMQ

安装rabbitMQ

• 安装rabbitMQ可以通过官网上进行下载安装，传送门
• MAC可以直接用brew命令安装

  brew install rabbitmq

• 安装完成后启动rabbitmq服务

然后再本地中访问 http://localhost:15672/ 就可以看到rabbitmq服务的后台。初始的账号密码均为 guest

Nachrichtenwarteschlange ist ein Kommunikationsdienst zwischen zwei Anwendungen. Der Generator der Nachricht kann sofort nach dem Speichern der Daten in der Nachrichtenwarteschlange zurückkehren, ohne auf den Nachrichtencode warten zu müssen >Empfänger antwortet. Das heißt: Produzent stellt sicher, dass die Daten in die Warteschlange eingefügt werden, und es spielt keine Rolle, wer die Nachricht erhält. Der Empfänger der Nachricht konzentriert sich nur auf den Empfang und die Verarbeitung der Nachricht. [Empfohlene verwandte Tutorials: nodejs-Video-Tutorial, Programmierunterricht】

Was kann die Nachrichtenwarteschlange tun? von Nachrichten Die Empfänger der Nachricht sind getrennt und voneinander unberührt.

Asynchron🎜 Asynchron bedeutet, die Antwortzeit von Anforderungen zu verkürzen. Der Nachrichtenproduzent muss nur einfache Logik verarbeiten und die Daten in die Nachrichtenwarteschlange stellen, um sie zurückzugeben, z. B. Datenbankoperationen und E/A-Operationen werden vom 🎜Empfänger der Nachricht🎜 abgewickelt. 🎜

🎜🎜Peak Shaving🎜 Wenn die Nachrichtenwarteschlangenanwendung bedient, kann sie den sofortigen Zustrom von Anforderungsinformationen in die Nachrichtenwarteschlange speichern und sofort zurückgeben. Die Anfrage wird dann vom Empfänger der Nachricht auf Basis der Daten bearbeitet. 🎜

🎜🎜Anwendungsszenarien🎜 Anwendungen wie Spielaktivitäten, Flash-Sale-Aktivitäten, Bestellungen usw., die einen sofortigen Traffic-Anstieg verursachen. 🎜

🎜2. Das Konzept der Nachrichtenwarteschlange🎜🎜🎜Nachdem wir die grundlegenden Informationen der Nachrichtenwarteschlange vorgestellt haben, stellen wir die Nachrichtenwarteschlange vor, bevor wir die Nachricht entwickeln Warteschlange. Einige grundlegende Konzepte~🎜🎜🎜🎜Der Produzent und Verbraucher der Nachricht🎜🎜🎜🎜Der oben erwähnte Produzent und Verbraucher. Es werden 🎜🎜🎜🎜-Links bereitgestellt. Kanäle und Warteschlangen 🎜🎜🎜

• 🎜Link (Verbindung): Stellt eine Verbindung zwischen dem Dienstprogramm und der Nachrichtenwarteschlange dar. 🎜Ein Serviceprogramm kann mehrere Links erstellen🎜. 🎜
• 🎜Kanal (Kanal): Ein Kanal zwischen Nachrichtenwarteschlangen-Links. 🎜Ein Link kann mehrere Kanäle haben. 🎜
• 🎜Warteschlange (Warteschlange): Die Warteschlange, die Daten in der Nachrichtenwarteschlange speichert. Ein Nachrichtenwarteschlangendienst kann mehrere Warteschlangen haben. 🎜

🎜Zusammenfassend ist die Beziehung zwischen Links und Kanalwarteschlangen wie folgt:🎜🎜🎜🎜🎜🎜Schalter (Austausch)🎜🎜🎜🎜Nachrichtenwarteschlange🎜Beim Senden einer Nachricht🎜 muss ein Schalter vorhanden sein. Wenn nicht angegeben, wird der Standardschalter verwendet. Die Rolle des Switches besteht darin, Nachrichten in die entsprechende Warteschlange zu verschieben. Es gibt insgesamt 4 Arten von Schaltern in der Nachrichtenwarteschlange🎜

• 🎜Direkt: Geben Sie den Warteschlangenmodus an. Wenn eine Nachricht eingeht, wird sie nur an die angegebene Warteschlange gesendet und andere Warteschlangen empfangen sie nicht . 🎜
• 🎜Fanout: Broadcast-Modus, wenn eine Nachricht eintrifft, wird sie an alle Warteschlangen gesendet. 🎜
• 🎜Thema: Fuzzy-Matching-Modus, entsprechend weiterleiten durch Fuzzy-Matching. 🎜
• 🎜Header: ähnlich dem Direktmodus. 🎜

🎜3.node verwendet RabbitMQ🎜🎜🎜🎜🎜RabbitMQ installieren🎜🎜🎜

• Die Installation von RabbitMQ kann über erfolgen Laden Sie die offizielle Website herunter und installieren Sie sie, Portal
• MAC kann direkt Verwenden Sie den Befehl brew, um

  /** 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();
  })();

  zu installieren
• Starten Sie nach Abschluss der Installation den Rabbitmq-Dienst

🎜🎜🎜Dann besuchen Sie http://localhost:15672/ lokal, um den Hintergrund des Rabbitmq-Dienstes zu sehen. Das anfängliche Kontopasswort lautet guest🎜🎜🎜🎜🎜🎜🎜Knotenprojektinstallation 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 教程！

Das obige ist der detaillierte Inhalt vonEin Artikel, der kurz analysiert, wie die Nachrichtenwarteschlange im Knoten verwendet wird. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!