第 4 章 例子
本章演示了通过示例程序使用 AMQ .NET。
如需了解更多示例,请参阅 AMQ .NET 示例套件和 AMQP.Net Lite 示例。
4.1. 发送消息 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
此客户端程序使用 < connection-url
> 连接到服务器,为目标 <address& gt;
创建发件人,发送一条消息,包含 <message-body
>、关闭连接并退出。
示例:发送消息
- 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
<install-dir>\bin\Debug>simple_send "amqp://guest:guest@localhost" service_queue