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读取，无需锁定到特定的异步运行时。

测试

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

有用资源

• Bitcoin Core ZMQ文档

待办事项

• 本README
• SequenceMessage itest
• 通过getzmqnotifications rpc（bitcoincore-rpc PR：#295）轻松实现addEventListener-like功能
• 原始消息
• zmq发布者
• 将源代码包含在消息中