2010-02-10 16:18:46 +01:00
|
|
|
zmq(7)
|
|
|
|
======
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-02-10 16:18:46 +01:00
|
|
|
|
|
|
|
NAME
|
|
|
|
----
|
|
|
|
zmq - 0MQ lightweight messaging kernel
|
|
|
|
|
|
|
|
|
|
|
|
SYNOPSIS
|
|
|
|
--------
|
2010-03-09 18:47:31 +01:00
|
|
|
*#include <zmq.h>*
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
*cc* ['flags'] 'files' *-lzmq* ['libraries']
|
2009-12-04 10:06:46 +01:00
|
|
|
|
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
DESCRIPTION
|
|
|
|
-----------
|
|
|
|
The 0MQ lightweight messaging kernel is a library which extends the standard
|
|
|
|
socket interfaces with features traditionally provided by specialised
|
|
|
|
_messaging middleware_ products. 0MQ sockets provide an abstraction of
|
|
|
|
asynchronous _message queues_, multiple _messaging patterns_, message
|
|
|
|
filtering (_subscriptions_), seamless access to multiple _transport protocols_
|
|
|
|
and more.
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
This documentation presents an overview of 0MQ concepts, describes how 0MQ
|
|
|
|
abstracts standard sockets and provides a reference manual for the functions
|
|
|
|
provided by the 0MQ library.
|
2009-12-04 10:06:46 +01:00
|
|
|
|
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Context
|
|
|
|
~~~~~~~
|
|
|
|
Before using any 0MQ library functions the caller must initialise a 0MQ
|
|
|
|
'context' using _zmq_init()_. The following functions are provided to handle
|
|
|
|
initialisation and termination of a 'context':
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-02-10 16:18:46 +01:00
|
|
|
Initialise 0MQ context::
|
|
|
|
linkzmq:zmq_init[3]
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Terminate 0MQ context::
|
2010-02-10 16:18:46 +01:00
|
|
|
linkzmq:zmq_term[3]
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-02-10 16:18:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Thread safety
|
|
|
|
^^^^^^^^^^^^^
|
|
|
|
A 0MQ 'context' is thread safe and may be shared among as many application
|
|
|
|
threads as the application has requested using the _app_threads_ parameter to
|
|
|
|
_zmq_init()_, without any additional locking required on the part of the
|
|
|
|
caller. Each 0MQ socket belonging to a particular 'context' may only be used
|
|
|
|
by *the thread that created it* using _zmq_socket()_.
|
|
|
|
|
|
|
|
|
|
|
|
Multiple contexts
|
|
|
|
^^^^^^^^^^^^^^^^^
|
|
|
|
Multiple 'contexts' may coexist within a single application. Thus, an
|
|
|
|
application can use 0MQ directly and at the same time make use of any number of
|
|
|
|
additional libraries or components which themselves make use of 0MQ as long as
|
|
|
|
the above guidelines regarding thread safety are adhered to.
|
|
|
|
|
|
|
|
|
|
|
|
Messages
|
|
|
|
~~~~~~~~
|
|
|
|
A 0MQ message is a discrete unit of data passed between applications or
|
|
|
|
components of the same application. 0MQ messages have no internal structure and
|
2010-03-10 12:19:39 +01:00
|
|
|
from the point of view of 0MQ itself they are considered to be opaque binary
|
|
|
|
data.
|
2010-03-09 18:47:31 +01:00
|
|
|
|
|
|
|
The following functions are provided to work with messages:
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-02-10 16:18:46 +01:00
|
|
|
Initialise a message::
|
|
|
|
linkzmq:zmq_msg_init[3]
|
2010-03-09 18:47:31 +01:00
|
|
|
linkzmq:zmq_msg_init_size[3]
|
|
|
|
linkzmq:zmq_msg_init_data[3]
|
2010-02-10 16:18:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Release a message::
|
2010-02-10 16:18:46 +01:00
|
|
|
linkzmq:zmq_msg_close[3]
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-02-10 16:18:46 +01:00
|
|
|
Access message content::
|
|
|
|
linkzmq:zmq_msg_data[3]
|
|
|
|
linkzmq:zmq_msg_size[3]
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-02-10 16:18:46 +01:00
|
|
|
Message manipulation::
|
|
|
|
linkzmq:zmq_msg_copy[3]
|
|
|
|
linkzmq:zmq_msg_move[3]
|
2009-12-04 10:06:46 +01:00
|
|
|
|
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Sockets
|
|
|
|
~~~~~~~
|
|
|
|
Standard sockets present a _synchronous_ interface to either connection-mode
|
|
|
|
reliable byte streams (SOCK_STREAM), or connection-less unreliable datagrams
|
|
|
|
(SOCK_DGRAM). In comparison, 0MQ sockets present an abstraction of a
|
|
|
|
asynchronous _message queue_, with the exact queueing semantics depending on
|
2010-05-28 00:49:13 +02:00
|
|
|
the socket type in use. See linkzmq:zmq_socket[3] for the socket types
|
|
|
|
provided.
|
2010-03-09 18:47:31 +01:00
|
|
|
|
|
|
|
0MQ sockets being _asynchronous_ means that the timings of the physical
|
|
|
|
connection setup and teardown, reconnect and effective delivery are organized
|
|
|
|
by 0MQ itself, and that messages may be _queued_ in the event that a peer is
|
|
|
|
unavailable to receive them.
|
|
|
|
|
|
|
|
The following functions are provided to work with sockets:
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-02-10 16:18:46 +01:00
|
|
|
Creating a socket::
|
|
|
|
linkzmq:zmq_socket[3]
|
|
|
|
|
|
|
|
Closing a socket::
|
|
|
|
linkzmq:zmq_close[3]
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-05-31 14:13:41 +02:00
|
|
|
Manipulating socket options::
|
|
|
|
linkzmq:zmq_getsockopt[3]
|
2010-02-10 16:18:46 +01:00
|
|
|
linkzmq:zmq_setsockopt[3]
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-02-10 16:18:46 +01:00
|
|
|
Establishing a message flow::
|
|
|
|
linkzmq:zmq_bind[3]
|
|
|
|
linkzmq:zmq_connect[3]
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Sending and receiving messages::
|
2010-02-10 16:18:46 +01:00
|
|
|
linkzmq:zmq_send[3]
|
|
|
|
linkzmq:zmq_recv[3]
|
2009-12-04 10:06:46 +01:00
|
|
|
|
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Input/output multiplexing
|
|
|
|
^^^^^^^^^^^^^^^^^^^^^^^^^
|
|
|
|
0MQ provides a mechanism for applications to multiplex input/output events over
|
|
|
|
a set containing both 0MQ sockets and standard sockets. This mechanism mirrors
|
|
|
|
the standard _poll()_ system call, and is described in detail in
|
|
|
|
linkzmq:zmq_poll[3].
|
2010-02-10 16:18:46 +01:00
|
|
|
|
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Transports
|
|
|
|
~~~~~~~~~~
|
|
|
|
A 0MQ socket can use multiple different underlying transport mechanisms.
|
|
|
|
Each transport mechanism is suited to a particular purpose and has its own
|
|
|
|
advantages and drawbacks.
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
The following transport mechanisms are provided:
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Unicast transport using TCP::
|
2010-02-10 16:18:46 +01:00
|
|
|
linkzmq:zmq_tcp[7]
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Reliable multicast transport using PGM::
|
2010-02-10 16:18:46 +01:00
|
|
|
linkzmq:zmq_pgm[7]
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Local inter-process communication transport::
|
2010-02-10 16:18:46 +01:00
|
|
|
linkzmq:zmq_ipc[7]
|
2010-01-15 14:11:39 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Local in-process (inter-thread) communication transport::
|
2010-02-10 16:18:46 +01:00
|
|
|
linkzmq:zmq_inproc[7]
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-02-10 16:18:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Devices
|
|
|
|
~~~~~~~
|
|
|
|
Apart from the 0MQ library the 0MQ distribution includes 'devices' which are
|
|
|
|
building blocks intended to serve as intermediate nodes in complex messaging
|
|
|
|
topologies.
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
The following devices are provided:
|
|
|
|
|
|
|
|
Forwarder device for request-response messaging::
|
|
|
|
linkzmq:zmq_queue[1]
|
|
|
|
|
|
|
|
Forwarder device for publish-subscribe messaging::
|
2010-02-10 16:18:46 +01:00
|
|
|
linkzmq:zmq_forwarder[1]
|
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Streamer device for parallelized pipeline messaging::
|
2010-02-10 16:18:46 +01:00
|
|
|
linkzmq:zmq_streamer[1]
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-02-10 16:18:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
ERROR HANDLING
|
|
|
|
--------------
|
|
|
|
The 0MQ library functions handle errors using the standard conventions found on
|
|
|
|
POSIX systems. Generally, this means that upon failure a 0MQ library function
|
|
|
|
shall return either a NULL value (if returning a pointer) or a negative value
|
|
|
|
(if returning an integer), and the actual error code shall be stored in the
|
|
|
|
'errno' variable.
|
|
|
|
|
|
|
|
A _zmq_strerror()_ function is provided to translate 0MQ-specific error codes
|
|
|
|
into error message strings. For further details refer to
|
|
|
|
linkzmq:zmq_strerror[3].
|
|
|
|
|
|
|
|
|
2010-03-09 19:29:41 +01:00
|
|
|
MISCELLANEOUS
|
|
|
|
-------------
|
|
|
|
The following miscellaneous functions are provided:
|
|
|
|
|
|
|
|
Report 0MQ library version::
|
|
|
|
linkzmq:zmq_version[3]
|
|
|
|
|
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
LANGUAGE BINDINGS
|
|
|
|
-----------------
|
|
|
|
The 0MQ library provides interfaces suitable for calling from programs in any
|
|
|
|
language; this documentation documents those interfaces as they would be used
|
|
|
|
by C programmers. The intent is that programmers using 0MQ from other languages
|
|
|
|
shall refer to this documentation alongside any documentation provided by the
|
|
|
|
vendor of their language binding.
|
2010-02-10 16:18:46 +01:00
|
|
|
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
C++ language binding
|
|
|
|
~~~~~~~~~~~~~~~~~~~~
|
|
|
|
The 0MQ distribution includes a $$C++$$ language binding, which is documented
|
|
|
|
separately in linkzmq:zmq_cpp[7].
|
2009-12-04 10:06:46 +01:00
|
|
|
|
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
Other language bindings
|
|
|
|
~~~~~~~~~~~~~~~~~~~~~~~
|
|
|
|
Other language bindings (Python, Ruby, Java and more) are provided by members
|
|
|
|
of the 0MQ community and pointers can be found on the 0MQ website.
|
2009-12-04 10:06:46 +01:00
|
|
|
|
2010-03-09 18:47:31 +01:00
|
|
|
|
|
|
|
AUTHORS
|
|
|
|
-------
|
|
|
|
The 0MQ documentation was written by Martin Sustrik <sustrik@250bpm.com> and
|
|
|
|
Martin Lucina <mato@kotelna.sk>.
|
|
|
|
|
|
|
|
|
|
|
|
RESOURCES
|
|
|
|
---------
|
|
|
|
Main web site: <http://www.zeromq.org/>
|
|
|
|
|
|
|
|
Report bugs to the 0MQ development mailing list: <zeromq-dev@lists.zeromq.org>
|
|
|
|
|
|
|
|
|
|
|
|
COPYING
|
|
|
|
-------
|
|
|
|
Free use of this software is granted under the terms of the GNU Lesser General
|
|
|
|
Public License (LGPL). For details see the files `COPYING` and `COPYING.LESSER`
|
|
|
|
included with the 0MQ distribution.
|