第 4 章 例子


本章演示了通过示例程序使用 AMQ .NET。

如需了解更多示例,请参阅 AMQ .NET 示例套件和 AMQP.Net Lite 示例

4.1. 发送消息

此客户端程序使用 < connection-url > 连接到服务器,为目标 <address& gt; 创建发件人,发送一条消息,包含 <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
使用 Amqp; 导入 Amqp 命名空间中定义的类型。AMQP 由项目引用 Amqp.Net.dll 定义,并提供与 AMQ .NET 关联的所有类、接口和值类型。
2
命令行 arg[0] url 是 AMQP 连接的主机或虚拟主机的网络地址。这个字符串描述了连接传输、用户和密码凭证,以及远程主机上连接的端口号。URL 可以处理路由器网络的代理、独立对等点或入口点。
3
命令行 arg[1] 目标是远程主机上消息目标端点或资源的名称。
4
命令行 arg[2] 计数 是要发送的消息数。
5
peerAddr 是创建 AMQP 连接所需的结构。
6
创建 AMQP 连接。
7
sender 是发送邮件的客户端 SenderLink。链接是任意命名的 send-1。使用环境中有意义的链接名称,并有助于识别忙碌系统中的流量。链接名称不受到限制,但在同一会话中必须唯一。
8
在消息中,发送循环将创建一个新消息。
9
该消息发送到 AMQP 对等点。
10
在所有消息发送后,协议对象将按顺序关闭。

运行示例

要运行示例程序,请编译程序并从命令行执行它。如需更多信息,请参阅 第 3 章 开始使用

<install-dir>\bin\Debug>simple_send "amqp://guest:guest@localhost" service_queue
Copy to Clipboard Toggle word wrap
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2025 Red Hat