NodeJ를 사용하여 RabbitMq 시작하기-JS 튜토리얼-php.cn

NodeJ를 사용하여 RabbitMq 시작하기

王林

풀어 주다： 2024-09-07 15:00:37

원래의

377명이 탐색했습니다.

RabbitMq 소개

RabbitMq는 서로 다른 서비스 간에 메시지를 주고받을 수 있는 메시지 브로커입니다. AMQP(Advanced Message Queuing Protocol)를 구현하는 메시지 브로커입니다. Erlang 프로그래밍 언어로 작성되었습니다.

RabbitMq 설치

RabbitMq는 해당 패키지 관리자를 사용하여 다른 운영 체제에 설치할 수 있습니다. RabbitMQ를 사용하려면 사전에 Erlang/OTP 설치가 필요합니다. 자세한 내용은 공식 문서를 참조하세요.

리눅스

sudo apt-get install rabbitmq-server

로그인 후 복사

brew install rabbitmq

로그인 후 복사

설치가 완료되면 다음 명령을 사용하여 RabbitMq 서버를 시작할 수 있습니다.

sudo rabbitmq-server

로그인 후 복사

Getting started with RabbitMq using NodeJs

서버가 시작되면 기본 포트 5672를 사용하여 애플리케이션에서 Rabbitmq에 액세스할 수 있습니다.

RabbitMq 관리 콘솔을 활성화하려면 다음 명령을 실행하세요.

sudo rabbitmq-plugins enable rabbitmq_management

로그인 후 복사

브라우저에서 http://localhost:15672/를 방문하면 RabbitMq 관리 콘솔에 액세스할 수 있습니다. 기본 사용자 이름과 비밀번호는 guest입니다.

Getting started with RabbitMq using NodeJs

NodeJs로 RabbitMq 설정하기

NodeJs에서 RabbitMq와 상호작용하려면 amqplib 라이브러리를 사용할 수 있습니다. 다음 명령을 사용하여 라이브러리를 설치할 수 있습니다.

npm install amqplib

로그인 후 복사

NodeJs에서 RabbitMq에 연결하고 RabbitMq와 상호작용하는 채널을 생성하려면 다음 코드를 사용할 수 있습니다.

const amqp = require("amqplib");

const connect = async (url) => {
  const connection = await amqp.connect(url);
  const channel = await connection.createChannel();

  return channel;
};

connect("amqp://localhost:5672").then((channel) => {
  console.log("Connected to RabbitMQ");
  channel.close();
  process.exit(0);
});

로그인 후 복사

이제 RabbitMq와 소통할 수 있는 채널이 생겼습니다. 이 채널을 사용하여 RabbitMq에서 메시지를 보내고 받을 수 있습니다. 대기열 이름을 mq-test-queue로 지정하고 대기열에 메시지를 보내겠습니다.

connect("amqp://localhost:5672").then((channel) => {
  console.log("Connected to RabbitMQ");
  channel.assertQueue("mq-test-queue");
  console.log("Queue created");
  channel.sendToQueue("mq-test-queue", Buffer.from("Hello World!"));
  console.log("Message sent");
});

로그인 후 복사

큐 mq-test-queue를 생성하고 Hello World! 메시지를 보냈습니다. 대기열에. 대기열을 생성하기 위해 AssertQueue 메소드를 사용하고 대기열에 메시지를 보내기 위해 sendToQueue 메소드를 사용했습니다.

큐에서 메시지를 받으려면 소비 메소드를 사용할 수 있습니다.

connect("amqp://localhost:5672").then((channel) => {
  console.log("Connected to RabbitMQ");
  channel.assertQueue("mq-test-queue");
  console.log("Queue created");
  channel.sendToQueue("mq-test-queue", Buffer.from("Hello World!"));
  console.log("Message sent");
  channel.consume("mq-test-queue", (msg) => {
    console.log("Message received", msg.content.toString());
  });
});

로그인 후 복사

consum 메서드는 콜백 함수를 사용하고 메시지 객체를 콜백 함수에 전달하여 msg.content.toString()을 사용하여 메시지 콘텐츠에 액세스합니다.

메시지를 사용한 후 메시지를 확인하거나 확인하여 대기열에서 메시지를 제거해야 합니다. ack 메소드를 사용하여 메시지를 승인하고 nack 메소드를 사용하여 메시지를 거부할 수 있습니다.

이 예에서는 메시지를 소비한 후 메시지를 확인합니다.

const amqp = require("amqplib");

const connect = async (url) => {
  const connection = await amqp.connect(url);
  const channel = await connection.createChannel();

  return channel;
};

connect("amqp://localhost:5672").then((channel) => {
  console.log("Connected to RabbitMQ");
  channel.assertQueue("mq-test-queue");
  console.log("Queue created");
  channel.sendToQueue("mq-test-queue", Buffer.from("Hello World!"));
  console.log("Message sent");
  channel.consume("mq-test-queue", (msg) => {
    console.log("Message received", msg.content.toString());
    channel.ack(msg);
  });
});

로그인 후 복사

Getting started with RabbitMq using NodeJs