文件名称：tmq:Tokio的Rust ZeroMQ绑定
文件大小：33KB
文件格式：ZIP
更新时间：2024-06-12 22:13:02
Rust
TMQ-Tokio的Rust ZeroMQ绑定 此板条箱桥接了Tokio和ZeroMQ，以允许异步世界中使用ZeroMQ。 变更日志 0.3.0-Tokio 1.0支持 感谢 0.3.0添加了对tokio 1.0的支持！ 当前实现的套接字 请求/回复 发布/订阅 经销商/路由器 推拉 例子 请参阅examples目录以获取完整的示例集。 它们根据套接字类型配对在一起。 用法 用法很简单，但是很自以为是。 请参阅示例以获取工作代码，但一般来说，您需要导入tokio和tmq::* 发布 要将消息发布给所有连接的订户，可以使用publish功能： use tmq :: {publish, Context, Result }; use futures :: SinkExt; use log :: info; use std :: env; use std :: time :: Duration
【文件预览】：
tmq-master
----.gitignore(18B)
----benches()
--------poll.rs(3KB)
----src()
--------comm.rs(2KB)
--------poll.rs(8KB)
--------socket.rs(5KB)
--------error.rs(520B)
--------socket_types()
--------socket_builder.rs(5KB)
--------macros.rs(7KB)
--------message.rs(3KB)
--------lib.rs(2KB)
----Cargo.toml(727B)
----.github()
--------workflows()
----examples()
--------pull.rs(600B)
--------reply.rs(663B)
--------client_worker.rs(5KB)
--------subscribe.rs(656B)
--------push.rs(674B)
--------publish.rs(686B)
--------request.rs(863B)
----README.md(2KB)
----tests()
--------pull.rs(2KB)
--------reply.rs(2KB)
--------utils.rs(6KB)
--------pair.rs(2KB)
--------subscribe.rs(1KB)
--------dealer.rs(6KB)
--------push.rs(3KB)
--------publish.rs(708B)
--------request.rs(2KB)
--------router.rs(7KB)