메시지 대기열이란 무엇입니까? 노드에서 메시지 큐를 사용하는 방법은 무엇입니까?

• RabbitMQ를 설치하려면 공식 홈페이지, 포털을 통해 다운로드하여 설치하면 됩니다.
• Brew 명령을 사용하여 MAC을 직접 설치할 수 있습니다

   양조 설치 RabbitMQ

• 설치가 완료되면 Rabbitmq 서비스를 시작합니다.

그런 다음 로컬로 http://localhost:15672/를 방문하여 Rabbitmq 서비스의 배경을 확인하세요. 초기 계정 비밀번호는 guest

amqplib는 노드에서 메시지 대기열을 사용하기 위한 도구 세트로, 이를 통해 메시지 대기열을 빠르게 사용할 수 있습니다.

주소: https://www.npmjs.com/package/amqplib

 /** product.js 소비자*/


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

const { connectUrl } = 구성;

(비동기 () => {
  const 연결 = amqplib.connect(connectUrl)를 기다립니다;

  const 채널 = 연결을 기다립니다.createChannel();
  const exchangeName = 'testExchange';
  const 키 = 'testQueue';
  const sendMsg = '안녕하세요 Rabbitmq';
    
  // 스위치 유형을 확인합니다. wait Channel.assertExchange(exchangeName, 'fanout', {
    내구성 : 사실,
  });
    
  //큐 지정 대기 채널.assertQueue(key);

  for (let i = 0; i < 100; i++) {
    Channel.publish(exchangeName, key, Buffer.from(`${sendMsg} ${i}`));
  }

  채널을 기다리고 있습니다.닫기();
  연결을 기다립니다.닫기();
})();

실행 후에는 100개의 메시지가 포함된 새 대기열이 추가된 것을 백그라운드에서 볼 수 있습니다.

 /** customer.js 소비자*/

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

const { connectUrl } = 구성;

(비동기 () => {
  연결 허용 = amqplib.connect(connectUrl) 대기;
  const exchangeName = 'testExchange';
  const 키 = 'testQueue';
  //두 개의 채널을 생성합니다. const 채널1 = 대기 연결.createChannel();
  const 채널2 = 연결을 기다립니다.createChannel();
  //교환 지정 대기 채널1.assertExchange(exchangeName, 'fanout', {
    내구성 : 사실,
  });
  //큐 지정 대기 채널1.assertQueue(key);
  채널1.bindQueue(key, exchangeName, key)를 기다립니다.
  채널1.소비(키, (msg) => {
    console.log('채널 1', msg.content.toString());
  });

  채널2.assertExchange(exchangeName, 'fanout', {를 기다리십시오.
    내구성 : 사실,
  });
  채널2.assertQueue(키)를 기다립니다;
  채널2.bindQueue(key, exchangeName, key)를 기다립니다.
  채널2.소비(키, (msg) => {
    console.log('채널 2', msg.content.toString());
  });
})();

실행 후에는 두 채널이 동시에 작동하여 메시지를 수신할 수 있는 것을 확인할 수 있습니다.