tokio nsq:基于Tokio的Rust NSQ客户端 源码

东京NSQ 基于Rust 客户端。 Tokio NSQ旨在成为功能完善的NSQ客户端实现。 Tokio NSQ可作为,API文档可在上。 版本控制 该项目遵循严格的语义版本控制。 在1.0.0之前的版本中,重大更改只有次要版本。 基本消费者示例 let topic = NSQTopic :: new ( "names" ). unwrap (); let channel = NSQChannel :: new ( "first" ). unwrap (); let mut addresses = HashSet :: new (); addresses. insert ( "http://127.0.0.1:4161" . to_string ()); let mut consumer = NSQConsumerConfig :: new (topic, channel)