🐰 kanin

基于 lapin 的 AMQP 框架，使用 Protobuf 在 Rust 中轻松创建 RPC 微服务 🦀。

用法

运行 cargo add kanin 将 kanin 添加到您的 Cargo.toml。

mod protobuf;

use kanin::{extract::Msg, App};
use protobuf::echo::{EchoRequest, EchoResponse};

async fn echo(Msg(request): Msg<EchoRequest>) -> EchoResponse {
    EchoResponse::success(request.value)
}

#[tokio::main]
async fn main() -> kanin::Result<()> {
    App::new(())
        .handler("my_routing_key", echo)
        .run("amqp_addr")
        .await
}

请参阅文档以获取示例和更具体的用法，或查看本仓库中的 /minimal_example 文件夹。

测试

要运行测试，请安装 just 和 Docker（您需要 docker-compose）。

然后，只需运行 just test，它将在容器中启动 RabbitMQ 实例，测试将连接到该实例。