NodeJs を使用して RabbitMq を始める-jsチュートリアル-php.cn

ホームページ

ウェブフロントエンド

jsチュートリアル

NodeJs を使用して RabbitMq を始める

王林

Sep 07, 2024 pm 03:00 PM

RabbitMq の概要

RabbitMq は、異なるサービス間でメッセージを送受信できるメッセージブローカーです。これは、Advanced Message Queuing Protocol (AMQP) を実装するメッセージブローカーです。 Erlang プログラミング言語で書かれています。

RabbitMq のインストール

RabbitMq は、それぞれのパッケージマネージャーを使用して、さまざまなオペレーティングシステムにインストールできます。 RabbitMQ を使用するには、事前に Erlang/OTP をインストールする必要があります。詳細については、公式ドキュメントを参照してください。

Linux

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 のセットアップ

NodeJ から RabbitMq と対話するには、amqplib ライブラリを使用できます。次のコマンドを使用してライブラリをインストールできます:

npm install amqplib

ログイン後にコピー

NodeJ から 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 メソッドを使用しました。

キューからメッセージを受信するには、consume メソッドを使用できます。

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

ログイン後にコピー

消費メソッドはコールバック関数を受け取り、メッセージオブジェクトをコールバック関数に渡し、msg.content.toString() を使用してメッセージコンテンツにアクセスします。

メッセージを消費した後、メッセージを確認するか、Nack してキューからメッセージを削除する必要があります。 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

キューからメッセージが正常に送受信されたことがわかります。 Rabbitmq 管理コンソールを使用します。

結論

この記事では、amqplib ライブラリを使用して RabbitMq をセットアップし、NodeJ から RabbitMq と対話する方法を学びました。キューを作成し、キューにメッセージを送信し、キューからメッセージを受信しました。

以上がNodeJs を使用して RabbitMq を始めるの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

このウェブサイトの声明

この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

ホットAIツール

ホットツール

ホットトピック

Gmailメールのログイン入り口はどこですか？

7345

Java チュートリアル

1627

CakePHP チュートリアル

1352

Laravel チュートリアル

1265

PHP チュートリアル

1214

Related knowledge

JavaScriptの文字列文字を交換します Mar 11, 2025 am 12:07 AM

JavaScript文字列置換法とFAQの詳細な説明この記事では、javaScriptの文字列文字を置き換える2つの方法について説明します：内部JavaScriptコードとWebページの内部HTML。 JavaScriptコード内の文字列を交換します最も直接的な方法は、置換（）メソッドを使用することです。 str = str.replace（ "find"、 "置換"）; この方法は、最初の一致のみを置き換えます。すべての一致を置き換えるには、正規表現を使用して、グローバルフラグGを追加します。 str = str.replace（/fi

カスタムGoogle検索APIセットアップチュートリアル Mar 04, 2025 am 01:06 AM

このチュートリアルでは、カスタムGoogle検索APIをブログまたはWebサイトに統合する方法を示し、標準のWordPressテーマ検索関数よりも洗練された検索エクスペリエンスを提供します。驚くほど簡単です！検索をyに制限することができます

例JSONファイルの例 Mar 03, 2025 am 12:35 AM

この記事シリーズは、2017年半ばに最新の情報と新鮮な例で書き直されました。このJSONの例では、JSON形式を使用してファイルに単純な値を保存する方法について説明します。キー価値ペア表記を使用して、あらゆる種類を保存できます

独自のAjax Webアプリケーションを構築します Mar 09, 2025 am 12:11 AM

それで、あなたはここで、Ajaxと呼ばれるこのことについてすべてを学ぶ準備ができています。しかし、それは正確には何ですか？ Ajaxという用語は、動的でインタラクティブなWebコンテンツを作成するために使用されるテクノロジーのゆるいグループ化を指します。 Ajaxという用語は、もともとJesse Jによって造られました

8見事なjQueryページレイアウトプラグイン Mar 06, 2025 am 12:48 AM

楽なWebページレイアウトのためにjQueryを活用する：8本質的なプラグイン jQueryは、Webページのレイアウトを大幅に簡素化します。この記事では、プロセスを合理化する8つの強力なjQueryプラグイン、特に手動のウェブサイトの作成に役立ちます

＆＃x27; this＆＃x27; JavaScriptで？ Mar 04, 2025 am 01:15 AM

コアポイントこれは通常、メソッドを「所有」するオブジェクトを指しますが、関数がどのように呼び出されるかに依存します。現在のオブジェクトがない場合、これはグローバルオブジェクトを指します。 Webブラウザでは、ウィンドウで表されます。関数を呼び出すと、これはグローバルオブジェクトを維持しますが、オブジェクトコンストラクターまたはそのメソッドを呼び出すとき、これはオブジェクトのインスタンスを指します。 call（）、apply（）、bind（）などのメソッドを使用して、このコンテキストを変更できます。これらのメソッドは、与えられたこの値とパラメーターを使用して関数を呼び出します。 JavaScriptは優れたプログラミング言語です。数年前、この文はそうでした