使用 AMQ .NET 客户端

SSL/TLS 身份验证依赖于受信任的证书颁发机构(CA)发布的数字证书。当客户端建立 SSL/TLS 连接时，AMQP 对等点向客户端发送服务器证书。此服务器证书必须由客户端 受信任的根证书颁发机构 证书存储中的其中一个 CA 签名。

如果用户为 Red Hat AMQ Broker 创建自签名证书，则用户必须创建一个 CA 为证书签名。然后，用户可以通过安装自签名 CA 文件 ca.crt 来启用客户端 SSL/TLS 握手。

有关安装证书的更多信息，请参阅管理 Microsoft 证书服务和 SSL。

要使用 SSL/TLS 和客户端证书，必须将含有客户端私钥的证书导入到客户端系统上的正确证书存储中。

在客户端将证书返回到代理之前，必须告知 AMQ .NET 库要使用的证书。客户端证书文件 client.crt 添加到要在 SChannel 连接启动过程中使用的证书列表中。

factory.SSL.ClientCertificates.Add(
    X509Certificate.CreateFromCertFile(certfile)
    );

在本例中，certfile 是个人证书 存储 中安装的 client.p12 证书的完整路径。在 HelloWorld-client-certs.cs 中找到一个完整的示例。SDK 中提供了此源文件和支持的项目文件。

所有示例都从 <install-dir>\bin\Debug 运行。

helloworld-simple 是一个简单的示例，它为同一地址创建 Sender 和 Receiver，发送消息到该地址，从地址读取消息，然后打印结果。

helloworld-simple 命令行选项

 Command line:
   HelloWorld-simple [brokerUrl [brokerEndpointAddress]]
 Default:
   HelloWorld-simple amqp://localhost:5672 amq.topic

helloworld-simple 示例调用

$ HelloWorld-simple
Hello world!

默认情况下，该程序连接到 localhost:5672 上运行的代理。在命令行中明确指定主机和端口，以及 AMQP 端点地址：

$ HelloWorld-simple amqp://someotherhost.com:5672 endpointname

默认情况下，该程序将其消息发送到 amq.topic。在某些 Amqp 代理中，amq.topic 是一个预定义的端点地址，它立即可用，没有代理配置。如果代理中没有这个地址，则使用代理管理工具创建它。

helloworld-robust 通过附加选项和处理共享简单示例的所有功能：

helloworld-robust 命令行选项

 Command line:
   HelloWorld-robust [brokerUrl [brokerEndpointAddress [payloadText [enableTrace]]]]
 Default:
   HelloWorld-robust amqp://localhost:5672 amq.topic "Hello World"

helloworld-robust 示例调用

$ HelloWorld-robust
Broker: amqp://localhost:5672, Address: amq.topic, Payload: Hello World!
body:Hello World!

helloworld-robust 允许用户指定有效负载字符串并启用追踪协议日志记录。

$ HelloWorld-robust amqp://localhost:5672 amq.topic "My Hello" loggingOn

AMQ .NET 示例 Interop.Drain 和 Interop.Spout 演示了与红帽 AMQ 互连的交互。在这种情况下没有消息代理。相反，Red Hat AMQ Interconnect 注册客户端程序请求的地址，并在它们之间路由消息。

Interop.Drain 命令行选项

 $ Interop.Drain.exe --help
 Usage: interop.drain [OPTIONS] --address STRING
 Create a connection, attach a receiver to an address, and receive messages.

 Options:
  --broker [amqp://guest:guest@127.0.0.1:5672] - AMQP 1.0 peer connection address
  --address STRING     []      - AMQP 1.0 terminus name
  --timeout SECONDS    [1]     - time to wait for each message to be received
  --forever            [false] - use infinite receive timeout
  --count INT          [1]     - receive this many messages and exit; 0 disables count based exit
  --initial-credit INT [10]    - receiver initial credit
  --reset-credit INT   [5]     - reset credit to initial-credit every reset-credit messages
  --quiet              [false] - do not print each message's content
  --help                       - print this message and exit

 Exit codes:
  0 - successfully received all messages
  1 - timeout waiting for a message
  2 - other error

Interop.Spout 命令行选项

 $ interop.spout --help
 Usage: Interop.Spout [OPTIONS] --address STRING
 Create a connection, attach a sender to an address, and send messages.

 Options:
  --broker [amqp://guest:guest@127.0.0.1:5672] - AMQP 1.0 peer connection address
  --address STRING  []      - AMQP 1.0 terminus name
  --timeout SECONDS [0]     - send for N seconds; 0 disables timeout
  --durable         [false] - send messages marked as durable
  --count INT       [1]     - send this many messages and exit; 0 disables count based exit
  --id STRING       [guid]  - message id
  --replyto STRING  []      - message ReplyTo address
  --content STRING  []      - message content
  --print           [false] - print each message's content
  --help                    - print this message and exit

 Exit codes:
  0 - successfully received all messages
  2 - other error

Interop.Spout 和 Interop.Drain 示例调用

在一个窗口中运行 Interop.drain。排空会永远等待一条消息到达。

$ Interop.Drain.exe --broker amqp://10.10.2.2:5672 --forever --count 1 --address amq.topic

在另一个窗口中运行 Interop.spout。spout 将消息发送到代理地址并退出。

$ interop.spout --broker amqp://10.10.2.2:5672 --address amq.topic
$

现在，在第一个窗口中排空将收到来自 spout 的消息，然后退出。

$ Interop.Drain.exe --broker amqp://10.10.2.2:5672 --forever --count 1 --address amq.topic
Message(Properties=properties(message-id:9803e781-14d3-4fa7-8e39-c65e18f3e8ea:0), ApplicationProperties=, Body=
$

这个示例显示了一个基于代理的简单服务器，它将接受来自客户端的字符串，将它们转换为大写，并将它们发回到客户端。它有两个组成部分：

在本例中，服务器和客户端在名为 service_queue 的代理中共享服务端点。服务器在服务端点侦听消息。客户端创建临时动态 ReplyTo 队列，将临时名称嵌入请求中，然后将请求发送到服务器。在收到和处理每个请求后，服务器会将回复发送到客户端的临时 ReplyTo 地址。

Interop.Client 命令行选项

 Command line:
   Interop.Client [peerURI [loopcount]]
 Default:
   Interop.Client amqp://guest:guest@localhost:5672 1

Interop.Server 命令行选项

 Command line:
   Interop.Server [peerURI]
 Default:
   Interop.Server amqp://guest:guest@localhost:5672

Interop.Client, Interop.Server 示例调用

可使用以下命令行启动程序：

$ Interop.Server.exe amqp://guest:guest@localhost:5672
$ Interop.Client.exe amqp://guest:guest@localhost:5672

peertopeer.Server 在命令行中提供的地址上创建一个侦听器。此地址初始化侦听传入连接的 ContainerHost 类对象。收到的消息异步转发到 RequestProcessor 类对象。

peertopeer.Client 打开与服务器的连接，并开始向服务器发送消息。

peertopeer.Client 命令行选项

 Command line:
   PeerToPeer.Client [peerURI]
 Default:
   PeerToPeer.Client amqp://guest:guest@localhost:5672

peertopeer.Server 命令行选项

 Command line:
   PeerToPeer.Server [peerURI]
 Default:
   PeerToPeer.Server amqp://guest:guest@localhost:5672

peertopeer.Client、PeerToPeer.Server 示例调用

在一个窗口中运行 PeerToPeer.Server

$ PeerToPeer.Server.exe
Container host is listening on 127.0.0.1:5672
Request processor is registered on request_processor
Press enter key to exist...
Received a request hello 0
...

在另一个窗口中，运行 PeerToPeer.Client。peertopeer.Client 发送消息，并在收到消息时打印响应。

$ PeerToPeer.Client.exe
Running request client...
Sent request properties(message-id:command-request,reply-to:client-57db8f65-6e3d-474c-a05e-8ca63b69d7c0) body hello 0
Received response:  body reply0
Received response:  body reply1
^C

要访问 .zip、.tar.gz 和其他发布文件，请使用客户门户查找要下载的相关文件。如果您使用 RPM 软件包或 Red Hat Maven 存储库，则不需要这一步。

要在 Red Hat Enterprise Linux 上安装此产品的 RPM 软件包，必须注册您的系统。如果您使用下载的发行文件，则不需要这一步。

有关注册您的系统的更多信息，请参阅以下资源之一：

按照 AMQ Broker 入门 以 安装代理 并创建代理 实例 中的内容进行操作。启用匿名访问。

以下步骤将代理实例的位置称为 <broker-instance-dir>。

在新终端中，使用 artemis queue 命令创建名为 amq.topic 的队列。

$ <broker-instance-dir>/bin/artemis queue create --name amq.topic --address amq.topic --auto-create-address --anycast

系统将提示您回答一系列"是"或无问题。对所有设备回答 N。

队列创建后，代理就可与示例程序配合使用。

运行完示例后，使用 artemis stop 命令停止代理。

$ <broker-instance-dir>/bin/artemis stop

2021-08-31 15:46:35 +1000 修订