#事件 #消息

rust_transit

无代理的异步事件库

1 个不稳定版本

0.1.0 2020年4月11日

#205 in #异步


2 个crate 使用

MIT 许可证

19KB
380

Rust Events

这是一个在消息API之上增加一层抽象的小实验。该项目受 Mass Transit 启发:对底层消息架构的拓扑结构做出一些决策,使其易于创建消息类型("事件")。

主要特性

多租户

每个事件都可以选择性地附加一个租户,它只是一个任意字符串。消费者可以监听所有或特定租户的事件。

支持的后端

RabbitMQ

通过 lapin 支持RabbitMQ。

目前您不能选择拓扑结构,但希望在未来某个阶段,我们可以添加自定义它的方法。

Kafka

通过 rust-rdkafka 支持Kafka。

其他

许可证

MIT 许可证下授权。

运行测试

由于它们是集成测试,请禁用并行测试:RUST_LOG=info cargo test -- --nocapture --test-threads=1


lib.rs:

rust_transit 库

在统一的通用接口下抽象底层消息技术

依赖

~5–14MB
~179K SLoC