ラビットMQ。 パート 1. はじめに。 アーラン、AMQP

こんにちは、ハブル！ 私が集めた教科書・参考書の知識を共有したい RabbitMQ そして短い推奨事項と結論に凝縮します。

目次

• ラビットMQ。 パート 1. はじめに。 Erlang、AMQP、RPC
• ラビットMQ。 パート 2. 交換について理解する
• ラビットMQ。 パート 3. キューとバインディングについて
• ラビットMQ。 パート 4. メッセージとフレームとは何かを理解する
• ラビットMQ。 パート 5: メッセージのパブリッシュと消費のパフォーマンス
• ラビットMQ。 パート 6. Federation および Shovel モジュールのレビュー
• ラビットMQ。 パート 7. コネクションとシャネルについての詳細
• ラビットMQ。 パート 8. .NET の RabbitMQ
• ラビットMQ。 パート 9. モニタリング

AMQP について簡単に説明します

AMQP (Advanced Message Queuing Protocol) は、システム コンポーネント間でメッセージを送信するためのオープン プロトコルです。 基本的な考え方は、個々のサブシステム (または独立したアプリケーション) が AMQP ブローカーを介して任意の方法でメッセージを交換できるというものです。AMQP ブローカーは、ルーティングを実行し、場合によっては配信を保証し、データ ストリームを配布し、必要なメッセージ タイプをサブスクライブします。

プロトコル AMQP では XNUMX つの概念が導入されています。

• exchange (交換ポイントまたは交換) - メッセージが送信されます。 交換ポイント メッセージを配布します XNUMX つ以上のキューにあります。 彼女 メッセージをキューにルーティングする 作成されたリンクに基づいて (binding) 彼と列の間
• queue (キュー) - ディスクまたは RAM 内のデータ構造。 メッセージへのリンクを保存し、メッセージのコピーを提供します consumers （消費者の皆様へ）
• binding (バインディング) - というルール 交換ポイントにこれらのメッセージをどのキューに入れるかを指示します。

プロトコルは最上位で実行されます TCP / IP.

Erlang について簡単に説明します

プロジェクトのソース コードは次のリポジトリにあります。 GitHubの。 建築 RabbitMQ サーバー に基づく アーラン そしてビーム。

Erlang 同社が開発した Ericsson 1980 年代半ばには、99,999% の稼働時間を必要とするアプリケーション向けの分散型、耐障害性、リアルタイム システムとして使用されました。 Erlang さまざまな産業や最新のアプリケーションで使用されています。 WhatsApp。 記事で詳しく読むことができます Facebookが19億ドルで買収したWhatsAppアーキテクチャ

RabbitMQ について簡単に説明します

RabbitMQの はオープンソースのメッセージブローカーです。 プロトコルのすべての基本原則に沿ってメッセージをルーティングします。 AMQP に記載されている 仕様書. RabbitMQ プロトコルを実装および補足します AMQP.

のメッセージング モデルの主なアイデア RabbitMQ 事は producer (パブリッシャー) はメッセージをキューに直接送信しません。 実際、非常に多くの場合、発行者は、メッセージがキューに配信されるかどうかさえ知りません。

代わりに、発行者はメッセージを交換に送信することしかできません。 一方では、エクスチェンジはパブリッシャーからメッセージを受信し、他方ではメッセージをキューに送信します。 交換側は、受信したメッセージをどう処理するかを正確に把握している必要があります。 特定のキューに追加する必要がありますか? 複数のキューに追加する必要がありますか? または、メッセージを無視する必要があります。

簡単な作業 RabbitMQ は次のように説明できます。

1. パブリッシャーは特定のエクスチェンジにメッセージを送信します
2. メッセージを受信した交換機は、メッセージとキューの間のバインディング ルールに従って、メッセージを XNUMX つ以上のキューにルーティングします。
3. キューには、このメッセージへの参照が保存されます。 メッセージ自体は RAM またはディスクに保存されます
4. コンシューマーがキューからメッセージを受信する準備ができると、サーバーはリンク経由でメッセージのコピーを作成し、
5. コンシューマーはメッセージを受信し、ブローカーに確認を送信します。
6. ブローカーは確認を受け取ると、メッセージのコピーをキューから削除します。 その後、RAMとディスクから削除します

RPC

プロセス RPC（リモートプロシージャコール） 核とのほぼすべての相互作用の根底にある RabbitMQ。 たとえば、クライアントとの条件に関する最初の話し合い。 RabbitMQ、特定のプロセスを示します RPC。 この一連の流れが完了すると、 RabbitMQ クライアントからのリクエストを受け入れる準備が整います。

仕様にもあります AMQP クライアントとサーバーの両方がコマンドを発行できます。 これは、クライアントがサーバーとの通信を待機していることを意味します。 コマンドはクラスとメソッドです。 例えば、 Connection.Start – メソッド呼び出し Start クラス Connection.

接続とチャネル

このようなクライアントとサーバー間の情報交換のために、 チャンネル。 チャネルは内部で作成されます 特定の接続。 各チャンネルは他のチャンネルから隔離されています。 同期の場合、応答を受信するまで次のコマンドを実行できません。

コマンドを並行して送信できるようにするには、複数のチャネルを開く必要があります。 各チャネルは個別に作成されます Erlang プロセス。 XNUMX つの接続に複数のチャネルを含めることができます (多重化）。 チャネルごとに、メモリ内に特定の構造とオブジェクトが存在します。 したがって、接続内のチャネルが多いほど、 RabbitMQ はより多くのメモリを使用します そのような接続を管理します。

を使用して接続とチャネルを作成する簡単な例 RabbitMQ.クライアント:

// ...
private void TryConnect()
{
    var factory = new ConnectionFactory() 
    {
        HostName = "host_name",
        UserName = "user_name",
        Password = "p@ssword",
        // Включение автоматичекого восстановления
        // соединения после сбоев сети 
        AutomaticRecoveryEnabled = true
    };
    _connection = factory.CreateConnection();
}
// ...
public void CreateChanel()
{
    _channel = _connection.CreateModel();
    // other options 
}

操作ごとに新しい接続を開くことは強くお勧めしません。 コスト高につながる。 チャネルも永続的である必要がありますが、多くのプロトコル エラーによりチャネルが閉じられるため、チャネルの存続期間は接続の存続期間よりも短くなる可能性があります。

RabbitMQ はどこで使用されますか?

マイクロサービスのコンテキストでは、プロトコル AMQP とその実装 RabbitMQ よく使われるのは 非同期対話 サービス間。

コンテキストで IIOT プロトコル AMQP とその実装 RabbitMQ サーバー間 (サーバー間) のデータ交換に使用されます。 プラグインも利用する MQTT プラグイン RabbitMQ これはプロトコルの実装です MQTT 低速、高遅延の環境でセンサーとサーバーの間でデータを送信する場合 (サポートされているプロトコルの完全なリストは、次の URL にリストされています) プロジェクトサイト).

次の記事では、Exchange についてさらに詳しく理解していきます。

リファレンス

• RabbitMQ プロジェクトの Web サイト

出所： habr.com