10个版本
0.4.0 | 2023年7月30日 |
---|---|
0.3.3 | 2022年11月14日 |
0.3.2 | 2020年5月24日 |
0.3.1 | 2020年4月19日 |
0.0.1 |
|
#283 in 异步
3,095 每月下载量
在 3 crate 中使用
76KB
1K SLoC
ZeroMQ绑定的异步版本
Async-zmq是ZeroMQ的异步级别绑定,与每个异步运行时兼容。无需配置或调整功能。只需连接即可查看其工作方式!
用法
用户可以使用async_zmq::*
初始化任何套接字类型,然后根据场景调用bind()
或connect
。例如,如果有人需要一个发布套接字,那么他可以这样初始化套接字:
let zmq = async_zmq::publish("tcp://127.0.0.1:5555")?.bind();
如果需要在不同套接字之间共享上下文,我们可以在构建套接字时设置它。
let context = Context::new();
let xpub = async_zmq::xpublish("inproc://example")?.with_context(&context).bind();
let sub = subscribe("inproc://example")?.with_context(&context).connect()?;
由于该crate的使用场景主要是用于发送/接收多部分消息,因此它提供了Multipart
,它是用于在实现Stream
类型的类型上的接收消息时的类型别名,以及MultipartIter
,这是一个泛型结构,可以将任何队列转换为迭代器,然后通过实现Sink
类型的类型发送。
有关每个套接字类型的用法,请参阅下面的模块。
依赖关系
~1.7–4.5MB
~74K SLoC