From 5ea5368b3a71ab91032ed08b919a4bf740cd676b Mon Sep 17 00:00:00 2001 From: Bob McElrath Date: Fri, 6 Jan 2017 18:23:44 -0500 Subject: [PATCH] ZMQ example using python3 and asyncio --- contrib/zmq/zmq_sub3.py | 52 +++++++++++++++++++++++++++++++++++++++++ 1 file changed, 52 insertions(+) create mode 100755 contrib/zmq/zmq_sub3.py diff --git a/contrib/zmq/zmq_sub3.py b/contrib/zmq/zmq_sub3.py new file mode 100755 index 000000000..79cb5b484 --- /dev/null +++ b/contrib/zmq/zmq_sub3.py @@ -0,0 +1,52 @@ +#!/usr/bin/env python3 +# Copyright (c) 2014-2016 The Bitcoin Core developers +# Distributed under the MIT software license, see the accompanying +# file COPYING or http://www.opensource.org/licenses/mit-license.php. + +import array +import binascii +import asyncio, zmq, zmq.asyncio +import struct + +port = 28332 + +zmqContext = zmq.asyncio.Context() + +async def recv_and_process(): + zmqSubSocket = zmqContext.socket(zmq.SUB) + zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "hashblock") + zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "hashtx") + zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "rawblock") + zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "rawtx") + zmqSubSocket.connect("tcp://127.0.0.1:%i" % port) + + poller = zmq.asyncio.Poller() + poller.register(zmqSubSocket, zmq.POLLIN) + while True: + s = await poller.poll() + msg = await s[0][0].recv_multipart() + topic = msg[0] + body = msg[1] + sequence = "Unknown"; + if len(msg[-1]) == 4: + msgSequence = struct.unpack('