メッセージキューのメッセージ送受信デモ

空のセミはこんな感じです · 掲載地 2019/05/30 22:58:30

前書き

場所によっては、情報処理の正確性を確保するためにメッセージキューが使用されています。例えば、高並行性の状況では、ウェブサイトがデータ処理を行います。本記事ではRabbitMQの簡単なデモを紹介します。この記事に入る前に、RbMQ環境は事前にインストールしておく必要があります(以前ローカルのRbMQ環境をインストールしたため、アンインストールするとレジストリがクリーンでない問題が起きるのではと心配しているため、ここでは環境のインストール記録はしません)。

環境とツール

>Windows 10システム
>RabbitMQ環境サービス
>VS 2017

テキスト

1: 新しいコンソールアプリケーション「RabbitMQClient」と「RabbitMQServer」を作成する。

2: 「RabbitMQ.Client」dll を参照してください

3: RabbitMQClientプロジェクトで、Program.cs 以下のコードを貼り付けてください

ログインが見えます。

4: RabbitMQServerプロジェクトで、Program.cs、以下のコードを貼り付けてください

ログインが見えます。

5: F5でRabbitMQServerプロジェクトを開始、コンソールで情報を入力し、エンターキーを押します。

6: RabbitMQServerプロジェクトコンソールを閉じず、RabbitMQClientプロジェクトを右クリックして「デバッグ」>「新しいインスタンスを起動」>

右側のRabbitMQServerコンソールに情報を入力すると、左側に表示できます。 RabbitMQServerプロジェクトはメッセージを生成します。 RabbitMQClientプロジェクトはメッセージを処理(消費)します。これはメッセージキュー内の生産者と消費者です。コードにはルーティングやチャネルも含まれます。

メッセージプロデューサー側では、処理する情報をメッセージキューに入力します。メッセージを受け取った後、消費者はこのデータを適切に処理できます。

環境がインストールされている場合、ローカルのデフォルトポートアドレスは http://localhost:15672/#/queues されるはずです。ゲストアカウントに直接アクセスすることも、コマンドラインをタップしてアカウントや対応する権限を設定することもできます。

RabbitMQServerコンソールに入力した情報は、まずメッセージキューに存在します。まずRabbitMQClientウィンドウを閉じてから、ウィンドウにいくつかの情報を入力し、メッセージキューを観察すると、キューに3つのデータがあるのがわかります。

RabbitMQClientウィンドウが始まると、通常通りメッセージを受け取った後、メッセージは自動的にメッセージキューから消えます。これはメッセージキューの確認メカニズムであり、必要な情報が正確に受信されると、消費者はメッセージキューに状態を返してメッセージを破棄します。もし消費者がメッセージを受け取らなかったり、例外があってこのステータス値を返さない場合、メッセージは通常通り消費されるまでキューに残り、メッセージの正確性が保証されます。

エピローグ

残念ながら、私のプロジェクトでメッセージキューを使う場所は非常に少ないです。深い理解がなければ、基本だけが使われます。

上記のデモには穴があり、RabbitMQClientでのRbMQ接続には使用層があります。非同期スレッドであるため、プログラムはメッセージの受信を完了する前にRbMQ接続を実行・リサイクルし、エラーが報告されます。対処法は、使用をやめて手動で放すことです。

クズども · 掲載地 2019/05/31 9:12:21

記事のデモソースコードを以下にアップロードするのが最善です:https://down.itsvse.com/

[プラグインライブラリ] メッセージキューのメッセージ送受信デモ

閲覧したセクション