Mein derzeitiger Subscriber sieht so aus:
Code: Alles auswählen
import zmq
context = zmq.Context()
print("Connecting to chatbot...")
socket = context.socket(zmq.SUB)
socket.connect('tcp://127.0.0.1:2000')
socket.setsockopt_string(zmq.SUBSCRIBE, '')
name = "Robin"
while True:
message = input("Message: ")
json_data = {
'name' : name,
'message' : message
}
socket.send_json(json_data)
json_recv = socket.recv_json()
print("{0}".format(json_recv))
Code: Alles auswählen
import time
import zmq
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind('tcp://127.0.0.1:5555')
while True:
json_data = socket.recv_json()
print("{0}".format(json_data))
time.sleep(1)
socket.send_json(json_data)
Leider fand ich im Internet nur Beispiele und Erklärungen für Fälle, in dem lediglich der Publisher Daten versendet, und die Subscriber annehmen.
Gibt es hier eine Möglichkeit, von den Subscribern aus Daten zu verschicken?