Rust的事件驱动消息库

这是一个早期alpha版本，目前尚未准备好用于生产。

项目的目标是创建一个库，该库具有一种模型抽象和多种消息代理（如Kafka、RabbitMQ、Iggy、自定义内存等）的不同实现。理想情况下，该库应能够处理所有可能的事件驱动场景，无论是模块化单体还是分布式应用（通常是微服务）。

发行说明

构建项目

cargobuild

测试项目

cargotest

示例

• 入门
• 内存中
• 内存中多线程
• Kafka
• Kafka多处理程序

运行示例

入门

cargorun --examplegetting-started

内存中的消息

运行示例

cargo run --example in-memory
cargo run --example in-memory-multi-threaded

Kafka消息

在本地机器上安装docker和docker-compose，启动kafka容器

cd tools\kafka
docker-compose up -d

创建主题 'orders'

kafka-topics --bootstrap-servers localhost:9092 --create --topic orders

运行示例

cargo run --example kafka
cargo run --example kafka-many-handlers