คิวข้อความคืออะไร? จะใช้คิวข้อความในโหนดได้อย่างไร?

• หากต้องการติดตั้ง rabbitMQ คุณสามารถดาวน์โหลดและติดตั้งผ่านทางเว็บไซต์พอร์ทัลอย่างเป็นทางการ
• สามารถติดตั้ง MAC ได้โดยตรงโดยใช้คำสั่งชง

   ชงติดตั้ง rabbitmq

• หลังจากการติดตั้งเสร็จสมบูรณ์ ให้เริ่มบริการ rabbitmq

จากนั้นไปที่ http://localhost:15672/ ในเครื่องเพื่อดูพื้นหลังของบริการ rabbitmq รหัสผ่านบัญชีเริ่มต้นคือ guest

amqplib เป็นชุดเครื่องมือสำหรับการใช้คิวข้อความในโหนด ซึ่งช่วยให้เราใช้คิวข้อความได้อย่างรวดเร็ว

ที่อยู่: https://www.npmjs.com/package/amqplib

 /** product.js ผู้บริโภค*/


const amqplib = ต้องการ('amqplib');
const config = need('./config');

const { เชื่อมต่อUrl } = กำหนดค่า;

(ไม่ตรงกัน () => {
  การเชื่อมต่อ const = รอ amqplib.connect (connectUrl);

  const channel = รอการเชื่อมต่อ createChannel();
  const exchangeName = 'testExchange';
  ปุ่ม const = 'testQueue';
  const sendMsg = 'สวัสดี rabbitmq';
    
  // ทราบประเภทสวิตช์ที่รอคอย channel.assertExchange(exchangeName, 'fanout', {
    ทนทาน: จริง,
  -
    
  //ระบุคิวที่รอ channel.assertQueue(key);

  สำหรับ (ให้ i = 0; i < 100; i++) {
    channel.publish(ชื่อการแลกเปลี่ยน, คีย์, Buffer.from(`${sendMsg} ${i}`));
  -

  รอช่อง.ปิด();
  รอการเชื่อมต่อ.ปิด();
-

หลังจากรันแล้ว คุณจะเห็นได้ว่ามีการเพิ่มคิวใหม่ที่มีข้อความถึง 100 ข้อความในพื้นหลัง

 /** customer.js ผู้บริโภค*/

const amqplib = ต้องการ('amqplib');
const config = need('./config');

const { เชื่อมต่อUrl } = กำหนดค่า;

(ไม่ตรงกัน () => {
  ให้การเชื่อมต่อ = รอ amqplib.connect (connectUrl);
  const exchangeName = 'testExchange';
  ปุ่ม const = 'testQueue';
  //สร้างสองช่อง const channel1 = รอการเชื่อมต่อ createChannel();
  const channel2 = รอการเชื่อมต่อ createChannel();
  //ระบุการแลกเปลี่ยนที่รอ channel1.assertExchange (exchangeName, 'fanout', {
    ทนทาน: จริง,
  -
  //ระบุคิวที่รอ channel1.assertQueue(key);
  รอ channel1.bindQueue (คีย์, exchangeName, คีย์);
  channel1.consume (คีย์ (ข้อความ) => {
    console.log('ช่อง 1', msg.content.toString());
  -

  รอ channel2.assertExchange (exchangeName, 'fanout', {
    ทนทาน: จริง,
  -
  รอ channel2.assertQueue (คีย์);
  รอ channel2.bindQueue (คีย์, exchangeName, คีย์);
  channel2.consume (คีย์ (ข้อความ) => {
    console.log('ช่อง 2', msg.content.toString());
  -
-

หลังจากดำเนินการ คุณจะเห็นว่าทั้งสองช่องทางสามารถรับข้อความพร้อมกันได้