Fixing the Networking World
How to make messaging work without a central server
while not just use the low level Berkeley socket interface?
It's not a message system;
It is a messaging / communication library to be used programmatically.
Zero
ØMQ comes with the low-level C API. High-level bindings exist in 40+ languages including:
Probably the most impressive binding is PyZMQ:-)
Python, Perl, PHP, Ruby, Go, Erlang, Node.js, Java, Scala, Clojure, C/C++, Objective-C, C#, F#, Delphi, Basic, Haskell, Lua , Racket CL, Felix, Q, Tcl, Ada, Haxe, ooc, ...
On RHEL, Cent OS, Fedora
$ yum install -y pkgconfig libtool gcc-c++ uuid
$ wget http://download.zeromq.org/zeromq-4.0.4.tar.gz
$ tar xvf zeromq-4.0.4.tar.gz
$ cd zeromq-4.0.4/
$ ./configure
$ make
$ make install
$ echo /usr/local/lib > /etc/ld.so.conf.d/local.conf
$ ldconfigPyZMQ
$ pip install pyzmq GoZMQ:
$ export PKG_CONFIG_PATH=/usr/local/lib/pkgconfig
$ go get -tags zmq_4_x github.com/alecthomas/gozmq...
Three-step approach:
Before using any ØMQ library functions, the caller must initialize a ØMQ context:
import zmq
context = zmq.Context()Contexts are thread safe unlike sockets. An application can create and manage multiple contexts.
ØMQ sockets are created from the initialized context:
socket = context.socket(zmq.REP)
ØMQ provides 4 different transports:
As a general rule of thumb,
import zmq
context = zmq.Context()
print("Connecting to hello world server...")
socket = context.socket(zmq.REQ)
socket.connect("tcp://localhost:5555")
for request in range(10):
print("Sending request %s ..." % request)
socket.send(b"Hello")
message = socket.recv()
print("Received reply %s [ %s ]" % (request, message))import time
import zmq
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://*:5555")
while True:
message = socket.recv()
print("Received request: %s" % message)
time.sleep(1)
socket.send(b"World")
