Java API 開発における非同期メッセージ処理のための RabbitMQ の使用-＆＃＆チュートリアル-php.cn

Java API 開発における非同期メッセージ処理のための RabbitMQ の使用

WBOY

リリース： 2023-06-18 11:04:40

オリジナル

1734 人が閲覧しました

インターネットの急速な発展に伴い、分散システムでは非同期メッセージ処理が重要な役割を果たし、システムの信頼性と同時実行性を向上させることができます。 RabbitMQ は、メッセージを迅速かつ確実に配信できるオープンソースのメッセージキューシステムであり、インターネット分野で広く使用されています。この記事では、Java API 開発における非同期メッセージ処理に RabbitMQ を使用する方法を紹介します。

1. RabbitMQ の概要

RabbitMQ は、AMQP (Advanced Message Queuing Protocol) に基づくオープンソースのメッセージキューミドルウェアです。 Erlang 言語で書かれており、高速、信頼性、スケーラブルという特徴があります。 RabbitMQ は Java、Python、Ruby などを含む複数のプログラミング言語をサポートしているため、開発者は便利に使用できます。

2. RabbitMQ の基本概念

1. メッセージキュー

メッセージキューは、メッセージの保存と送信に使用される FIFO (先入れ先出し) データ構造です。 RabbitMQ では、メッセージキューを「キュー」と呼びます。

2. メッセージ

メッセージは情報伝達の媒体であり、あらゆる種類のデータを含めることができます。 RabbitMQ では、メッセージを「メッセージ」と呼びます。

3. スイッチ

スイッチはメッセージルーティングの中心であり、ルールに従ってメッセージを対応するキューに送信します。 RabbitMQ では交換のことを「Exchange」と呼びます。

4. バインディング

バインディングはキューとスイッチを接続する操作であり、特定のルーティングルールを指定できます。通常、バインディングとキューはルーティングキーを指定し、スイッチがメッセージを正しいキューにルーティングできるようにします。

5. Consumer

Consumer はメッセージを受信して処理するプログラムで、キューからメッセージを取り出し、いくつかの操作を実行できます。 RabbitMQ では、消費者のことを「コンシューマ」と呼びます。

3. RabbitMQ の利用手順

RabbitMQ を利用する前に、RabbitMQ サーバーをセットアップする必要がありますので、インストール手順については公式ドキュメントを参照してください。基本的なプロセスは次のとおりです:

1. 接続ファクトリオブジェクトを作成し、RabbitMQ サーバーのアドレスとポート番号を設定します。

ConnectionFactory Factory = new ConnectionFactory();
factory.setHost("localhost");
factory.setPort(5672);

2. 接続オブジェクトを作成します。

Connection 接続 = Factory.newConnection();

3. チャネル (Channel) オブジェクトを作成します。

Channel チャネル = connection.createChannel();

4. Exchange オブジェクトを作成します。

channel.exchangeDeclare("exchange_name", "direct", true);

5. キュー (Queue) オブジェクトを作成します。

channel.queueDeclare("queue_name", true, false, false, null);

6. キューをバインドして切り替えます。

channel.queueBind("queue_name", "exchange_name", "routing_key");

7. コンシューマー (Consumer) オブジェクトを作成し、消費コールバック関数を設定します。

Consumer Consumer = new DefaultConsumer(channel) {

@Override
public void handleDelivery(String consumerTag, Envelope envelope,
                           AMQP.BasicProperties properties, byte[] body) throws IOException {
    // 处理消息
}

ログイン後にコピー

};
channel.basicConsume("queue_name", true, Consumer);

8.Publish message 。

channel.basicPublish("exchange_name", "routing_key", null, message.getBytes());

4. 非同期メッセージ処理に RabbitMQ を使用する

Java API の場合開発中には、非同期メッセージ処理に RabbitMQ を使用するシナリオが数多くあります。たとえば、ユーザーがシステムにタスク要求を送信すると、その要求をメッセージにパッケージ化して RabbitMQ キューに送信できます。その後、システムはアイドル時間中にタスクを処理し、処理結果を別のキューに送信できます。最後に、プログラムの別の部分がキューから処理結果を取得してユーザーに返すことができます。

1. コネクションファクトリオブジェクトを作成し、RabbitMQ サーバーのアドレスとポート番号を設定します。

ConnectionFactory Factory = new ConnectionFactory();
factory.setHost("localhost");
factory.setPort(5672);

2. 接続オブジェクトを作成します。

Connection 接続 = Factory.newConnection();

3. チャネル (Channel) オブジェクトを作成します。

Channel チャネル = connection.createChannel();

4. Exchange オブジェクトを作成します。

channel.exchangeDeclare("exchange_name", "direct", true);

5. リクエストキュー (Queue) オブジェクトを作成します。

channel.queueDeclare("request_queue", true, false, false, null);

6. リクエストキューをバインドして切り替えます。

channel.queueBind("request_queue", "exchange_name", "request_routing_key");

7. コンシューマー (Consumer) オブジェクトを作成し、消費コールバック関数を設定します。

Consumer Consumer = new DefaultConsumer(channel) {

@Override
public void handleDelivery(String consumerTag, Envelope envelope,
                           AMQP.BasicProperties properties, byte[] body) throws IOException {
    // 处理请求消息
    String response = processMessage(new String(body));
    // 将处理结果发送到响应队列
    channel.basicPublish("exchange_name", "response_routing_key", null, response.getBytes());
}

ログイン後にコピー

};
channel.basicConsume("request_queue", true, Consumer);

8. を作成します。応答キューオブジェクト。

channel.queueDeclare("response_queue", true, false, false, null);

9. 応答キューをバインドして切り替えます。

channel.queueBind("response_queue", "exchange_name", "response_routing_key");

10. リクエストメッセージをリクエストキューに送信します。

channel.basicPublish("exchange_name", "request_routing_key", null, requestMessage.getBytes());

11. 応答メッセージを待ちます。

コンシューマ responseConsumer = new DefaultConsumer(channel) {

@Override
public void handleDelivery(String consumerTag, Envelope envelope,
                           AMQP.BasicProperties properties, byte[] body) throws IOException {
    // 处理响应消息
}

ログイン後にコピー

};
channel.basicConsume("response_queue", true, responseConsumer);

5. 概要

この記事では、Java API 開発における非同期メッセージ処理に RabbitMQ を使用する基本プロセスを紹介します。 RabbitMQ は信頼性の高いメッセージ配信を実現し、システムに効率的な非同期メッセージ処理方法を提供します。実際の開発では、システムの信頼性とパフォーマンスを確保するために、さまざまなビジネスシナリオに応じてさまざまな構成を選択する必要があります。

以上がJava API 開発における非同期メッセージ処理のための RabbitMQ の使用の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。