11 个版本
0.2.7 | 2021 年 8 月 21 日 |
---|---|
0.2.6 |
|
0.2.4 | 2021 年 7 月 9 日 |
0.2.3 | 2021 年 5 月 2 日 |
0.1.5 | 2021 年 2 月 22 日 |
#881 在 并发
每月 38 次下载
用于 jotty
25KB
416 行
zkmq.
zkmq 是一个简单的基于 Rust 编写的消息队列,由 Zookeeper(以及其他可能的服务)支持。
zkmq 的主要设计关注点是应用使用的简单性、高可靠性和有限的外部依赖。
zkmq 与...
在我脑海中能想到的所有消息队列解决方案中,与 zkmq 在概念上最接近的是亚马逊 SQS。其主要用例是在异步进程之间发送消息,每个消息只读取一次,然后在后台丢弃。
zkmq 不旨在取代 RabbitMQ、Kafka 或其他灵活的消息队列解决方案。
过滤
zkmq 支持基于任意字段的短信过滤。消费者可以定义过滤器,并仅选择与提供的过滤器匹配的消息。
这样做会有性能影响,因为库必须扫描队列中的消息以找到匹配的消息,然后尝试消费该消息。在多消费者环境中,在此过程中可能会遇到竞争,导致失败者会继续尝试直到成功。
依赖项
~6.5MB
~116K SLoC