Red Hat Summit Red Hat Summitサポートコンソール開発者トライアルの開始お問い合わせ

第4章 例

本章では、サンプルプログラムで AMQ .NET を使用する方法について説明します。

その他の例については、AMQ .NET サンプルスイート を参照してください。

4.1. メッセージの送信
リンクのコピー

このクライアントプログラムは <connection-url> を使用してサーバーに接続し、ターゲット <address> の送信者を作成し、<message-body> を含むメッセージを送信して接続を切断して終了します。

例: メッセージの送信

namespace SimpleSend
{
    using System;
    using Amqp;
1 


    class SimpleSend
    {
        static void Main(string[] args)
        {
            string    url = (args.Length > 0) ? args[0] :
2 

                "amqp://guest:guest@127.0.0.1:5672";
            string target = (args.Length > 1) ? args[1] : "examples";
3 

            int     count = (args.Length > 2) ? Convert.ToInt32(args[2]) : 10;
4 


            Address      peerAddr = new Address(url);
5 

            Connection connection = new Connection(peerAddr);
6 

            Session       session = new Session(connection);
            SenderLink     sender = new SenderLink(session, "send-1", target);
7 


            for (int i = 0; i < count; i++)
            {
                Message msg = new Message("simple " + i);
8 

                sender.Send(msg);
9 

                Console.WriteLine("Sent: " + msg.Body.ToString());
            }

            sender.Close();
10 

            session.Close();
            connection.Close();
        }
    }
}
Copy to Clipboard Toggle word wrap

1
using Amqp; Amqp ネームスペースで定義されたタイプをインポートします。Amqp は、ライブラリーファイル Amqp.Net.dll へのプロジェクト参照によって定義され、AMQ .NET に関連するすべてのクラス、インターフェイス、および値タイプを提供します。
2
コマンドライン arg[0] url は、AMQP 接続のホストまたは仮想ホストのネットワークアドレスです。この文字列は、接続トランスポート、ユーザーとパスワードの認証情報、およびリモートホストの接続のポート番号を説明します。url はブローカー、スタンドアロンピア、またはルーターネットワークの Ingress ポイントに対応できます。
3
コマンドライン arg[1] target は、リモートホストのメッセージ先エンドポイントまたはリソースの名前です。
4
コマンドライン arg[2] count は送信するメッセージ数です。
5
peerAddr は AMQP コネクションの作成に必要な構造です。
6
AMQP コネクションを作成します。
7
sender は、メッセージが送信されることができるクライアント SenderLink です。リンクは、任意に send-1 と命名されます。お使いの環境で意味を持ち、ビジーなシステムでトラフィックを特定するのに役立つリンク名を使用します。リンク名は制限されませんが、同じセッション内で一意である必要があります。
8
メッセージ送信ループでは、新しいメッセージが作成されます。
9
メッセージは AMQP ピアに送信されます。
10
すべてのメッセージが送信されると、プロトコルオブジェクトは正しい順序でシャットダウンされます。

サンプルの実行

<install-dir>\bin\Debug>simple_send "amqp://guest:guest@localhost" service_queue
Sent: simple 0
Sent: simple 1
Sent: simple 2
Sent: simple 3
Sent: simple 4
Sent: simple 5
Sent: simple 6
Sent: simple 7
Sent: simple 8
Sent: simple 9

<install-dir>\amqpnetlite\bin\Debug>
Copy to Clipboard Toggle word wrap
トップに戻る
Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。 最新の更新を見る.

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

Theme

© 2025 Red Hat