metalmq 客户端架构

客户端架构遵循六边形架构，以便我们能够轻松描述业务逻辑，或者说协议逻辑。

+-----------------------------------------------------------+
| Infrastructure                                            |
|                                                           |
| --> client_api                +----------+                |
|                 --> processor |  state   | --> processor  |
|                               |  error   |                |
| --> channel_api               |  model   |                |
|                               +----------+                |
|                                                           |
+-----------------------------------------------------------+

lib.rs:

基于 Tokio 的 AMQP 0.9 兼容异步客户端。

使用方法

将以下内容添加到您的 Cargo.toml

[dependencies]
metalmq-client = "0.2.2"

然后，您可以从异步函数连接到 AMQP 服务器。

use metalmq_client::Client;

async fn send_message() {
    let mut client = Client::connect("localhost:5672", "guest", "guest").await.unwrap();

    client.channel_open(1).await.unwrap();
    client.close().await.unwrap();
}