Rust Bitcoin Core ZMQ订阅者

使用示例

fn main() {
    for msg in bitcoincore_zmq::subscribe_receiver(&["tcp://127.0.0.1:28359"]).unwrap() {
        match msg {
            Ok(msg) => println!("Received message: {msg}"),
            Err(err) => println!("Error receiving message: {err}"),
        }
    }
}

更多示例，请查看示例目录。

功能

• 最小依赖：2个crate bitcoin 和 zmq，可选地需要2个额外的crate来支持异步订阅者，async_zmq 和 futures-util。
• 处理Bitcoin Core的所有消息类型：hashblock、hashtx、block、tx 和 sequence。
• 灵活：在带有回调的阻塞函数、从 Receiver 或从异步的 Stream 中读取之间进行选择，而不锁定到特定的异步运行时。

测试

每次推送和拉取请求都会运行测试。集成测试使用最新的5个主要Bitcoin Core版本的最新版本，请参阅integration_tests.yml。

有用资源

• Bitcoin Core ZMQ文档

待办事项

• 本README
• SequenceMessage itest
• 通过使用 getzmqnotifications rpc 获取类似addEventListener的功能
• 原始消息
• zmq发布者
• 在消息中包含源