From 459900bd914c2b5450a6d1e19071c4c5da6b4500 Mon Sep 17 00:00:00 2001 From: lionel Date: Fri, 18 Sep 2015 17:43:18 +0200 Subject: [PATCH 1/1] initial commit --- client.py | 27 +++++++++++++++++++++++++++ server.py | 28 ++++++++++++++++++++++++++++ 2 files changed, 55 insertions(+) create mode 100755 client.py create mode 100755 server.py diff --git a/client.py b/client.py new file mode 100755 index 0000000..5cd2ab3 --- /dev/null +++ b/client.py @@ -0,0 +1,27 @@ +#!/usr/bin/python3 +# -*- coding: utf8 -*- +# +# Hello World client in Python +# Connects REQ socket to tcp://localhost:5555 +# Sends "Hello" to server, expects "World" back +# + +import zmq + +context = zmq.Context() + +# Socket to talk to server +print("Connecting to hello world server…") +socket = context.socket(zmq.REQ) +#socket.connect("tcp://localhost:5555") +socket.connect("ipc:///home/lionel/work/python/my_prox/0") + +# Do 10 requests, waiting each time for a response +for request in range(10): + print("Sending request %s …" % request) + socket.send(b"Hello") + + # Get the reply. + message = socket.recv() + print("Received reply %s [ %s ]" % (request, message)) + diff --git a/server.py b/server.py new file mode 100755 index 0000000..0de41ee --- /dev/null +++ b/server.py @@ -0,0 +1,28 @@ +#!/usr/bin/python3 +# -*- coding: utf8 -*- +# +# Hello World server in Python +### Binds REP socket to tcp://*:5555 +# Binds REP socket to ipc:///home/lionel/work/python/my_prox/0 +# Expects b"Hello" from client, replies with b"World" +# + +import time +import zmq + +context = zmq.Context() +socket = context.socket(zmq.REP) +#socket.bind("tcp://*:5555") +socket.bind("ipc:///home/lionel/work/python/my_prox/0"); + +while True: + # Wait for next request from client + message = socket.recv() + print("Received request: %s" % message) + + # Do some 'work' + time.sleep(1) + + # Send reply back to client + socket.send(b"World") + -- 2.39.2