Commit 06b4e37d authored by Kei Tsuji's avatar Kei Tsuji

add Pipfile and pub-sub examples

parents
[[source]]
url = "https://pypi.org/simple"
verify_ssl = true
name = "pypi"
[packages]
pyzmq = "*"
[dev-packages]
[requires]
python_version = "3.8"
python_full_version = "3.8.12"
import signal
import time
import zmq
signal.signal(signal.SIGINT, signal.SIG_DFL)
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind('tcp://*:5555')
for i in range(5):
socket.send(b'status 5')
socket.send(b'All is well')
time.sleep(1)
import signal
import zmq
signal.signal(signal.SIGINT, signal.SIG_DFL)
context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect('tcp://localhost:5555')
socket.setsockopt(zmq.SUBSCRIBE, b'status')
while True:
message = socket.recv_multipart()
print(f'Received: {message}')
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment