From 5406d510678cf4b1191f1b9a1838524fe5fa13da Mon Sep 17 00:00:00 2001 From: Bob McElrath Date: Mon, 9 Jan 2017 17:07:13 -0500 Subject: Rewrite to not use Polling wrapper for asyncio, link to python2.7 example --- contrib/zmq/zmq_sub.py | 80 ++++++++++++++++++++++++++++++++------------------ 1 file changed, 51 insertions(+), 29 deletions(-) (limited to 'contrib/zmq/zmq_sub.py') diff --git a/contrib/zmq/zmq_sub.py b/contrib/zmq/zmq_sub.py index 6f57aa47e9..e462198bfe 100755 --- a/contrib/zmq/zmq_sub.py +++ b/contrib/zmq/zmq_sub.py @@ -1,43 +1,65 @@ -#!/usr/bin/env python2 +#!/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. +# A blocking example using python 2.7 can be obtained from the git history: +# https://github.com/bitcoin/bitcoin/blob/37a7fe9e440b83e2364d5498931253937abe9294/contrib/zmq/zmq_sub.py + +import array import binascii -import zmq +import asyncio, zmq, zmq.asyncio +import signal import struct port = 28332 -zmqContext = zmq.Context() -zmqSubSocket = zmqContext.socket(zmq.SUB) -zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "hashblock") -zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "hashtx") -zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "rawblock") -zmqSubSocket.setsockopt(zmq.SUBSCRIBE, "rawtx") -zmqSubSocket.connect("tcp://127.0.0.1:%i" % port) - -try: - while True: - msg = zmqSubSocket.recv_multipart() - topic = str(msg[0]) +class ZMQHandler(): + def __init__(self): + self.loop = zmq.asyncio.install() + self.zmqContext = zmq.asyncio.Context() + + self.zmqSubSocket = self.zmqContext.socket(zmq.SUB) + self.zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "hashblock") + self.zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "hashtx") + self.zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "rawblock") + self.zmqSubSocket.setsockopt_string(zmq.SUBSCRIBE, "rawtx") + self.zmqSubSocket.connect("tcp://127.0.0.1:%i" % port) + + async def handle(self) : + msg = await self.zmqSubSocket.recv_multipart() + topic = msg[0] body = msg[1] sequence = "Unknown"; if len(msg[-1]) == 4: msgSequence = struct.unpack(' Date: Tue, 10 Jan 2017 10:54:07 -0500 Subject: Add python version checks and 3.4 example --- contrib/zmq/zmq_sub.py | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'contrib/zmq/zmq_sub.py') diff --git a/contrib/zmq/zmq_sub.py b/contrib/zmq/zmq_sub.py index e462198bfe..4839f401b1 100755 --- a/contrib/zmq/zmq_sub.py +++ b/contrib/zmq/zmq_sub.py @@ -11,6 +11,11 @@ import binascii import asyncio, zmq, zmq.asyncio import signal import struct +import sys + +if not (sys.version_info.major >= 3 and sys.version_info.minor >= 5): + print("This example only works with Python 3.5 and greater") + exit(1) port = 28332 -- cgit v1.2.3 From b471daf85b07d0ca072a8d7ec482a25401a67399 Mon Sep 17 00:00:00 2001 From: Bob McElrath Date: Thu, 19 Jan 2017 17:06:52 -0500 Subject: Adddress nits, use asyncio signal handling, create_task --- contrib/zmq/zmq_sub.py | 32 +++++++++++++++++++++++--------- 1 file changed, 23 insertions(+), 9 deletions(-) (limited to 'contrib/zmq/zmq_sub.py') diff --git a/contrib/zmq/zmq_sub.py b/contrib/zmq/zmq_sub.py index 4839f401b1..33a6b4ce65 100755 --- a/contrib/zmq/zmq_sub.py +++ b/contrib/zmq/zmq_sub.py @@ -3,12 +3,29 @@ # Distributed under the MIT software license, see the accompanying # file COPYING or http://www.opensource.org/licenses/mit-license.php. -# A blocking example using python 2.7 can be obtained from the git history: -# https://github.com/bitcoin/bitcoin/blob/37a7fe9e440b83e2364d5498931253937abe9294/contrib/zmq/zmq_sub.py +""" + ZMQ example using python3's asyncio + + Bitcoin should be started with the command line arguments: + bitcoind -testnet -daemon \ + -zmqpubhashblock=tcp://127.0.0.1:28332 \ + -zmqpubrawtx=tcp://127.0.0.1:28332 \ + -zmqpubhashtx=tcp://127.0.0.1:28332 \ + -zmqpubhashblock=tcp://127.0.0.1:28332 + + We use the asyncio library here. `self.handle()` installs itself as a + future at the end of the function. Since it never returns with the event + loop having an empty stack of futures, this creates an infinite loop. An + alternative is to wrap the contents of `handle` inside `while True`. + + A blocking example using python 2.7 can be obtained from the git history: + https://github.com/bitcoin/bitcoin/blob/37a7fe9e440b83e2364d5498931253937abe9294/contrib/zmq/zmq_sub.py +""" -import array import binascii -import asyncio, zmq, zmq.asyncio +import asyncio +import zmq +import zmq.asyncio import signal import struct import sys @@ -55,7 +72,8 @@ class ZMQHandler(): asyncio.ensure_future(self.handle()) def start(self): - asyncio.ensure_future(self.handle()) + self.loop.add_signal_handler(signal.SIGINT, self.stop) + self.loop.create_task(self.handle()) self.loop.run_forever() def stop(self): @@ -63,8 +81,4 @@ class ZMQHandler(): self.zmqContext.destroy() daemon = ZMQHandler() -def signal_handler(num, frame): - daemon.stop() - exit(0) -signal.signal(signal.SIGINT, signal_handler) daemon.start() -- cgit v1.2.3