generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-01-21 02:00:36 +01:00
Code Issues Projects Releases Wiki Activity

Merge branch 'master' of github.com:zeromq/zeromq2

Browse Source
This commit is contained in:
Martin Lucina 2010-08-05 23:41:49 +02:00
commit 16b43e657b
1 changed files with 22 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
doc/zmq_device.txt
View File

@ -31,16 +31,13 @@ Before calling _zmq_device()_ you must set any socket options, and connect or
bind both frontend and backend sockets. The two conventional device models bind both frontend and backend sockets. The two conventional device models
are: are:
*proxy*:: * proxy model - accept inward connections to frontend socket (by binding it to
bind frontend socket to an endpoint, and connect backend socket to an endpoint), and make onward connections through backend socket (connecting
downstream components. A proxy device model does not require changes to to endpoints on other nodes). A proxy device model can fit well into an
the downstream topology but that topology is static (any changes require existing topology.
reconfiguring the device). * broker model - accept connections on both frontend and backend sockets (by
*broker*:: binding both to endpoints). A broker device model creates a star topology
bind frontend socket to one endpoint and bind backend socket to a second where nodes can come and go at any time.
endpoint. Downstream components must now connect into the device. A
broker device model allows a dynamic downstream topology (components can
come and go at any time).
_zmq_device()_ runs in the current thread and returns only if/when the current _zmq_device()_ runs in the current thread and returns only if/when the current
context is closed. context is closed.
@ -112,6 +109,21 @@ assert (zmq_bind (backend, "tcp://*:5556") == 0);
zmq_device (ZMQ_QUEUE, frontend, backend); zmq_device (ZMQ_QUEUE, frontend, backend);
---- ----
.Creating a pubsub proxy
----
// Create frontend and backend sockets
void *frontend = zmq_socket (context, ZMQ_SUB);
assert (backend);
void *backend = zmq_socket (context, ZMQ_PUB);
assert (frontend);
// Connect frontend to publisher
assert (zmq_bind (frontend, "tcp://192.68.55.112:4444") == 0);
// Bind backend to TCP port
assert (zmq_bind (backend, "tcp://*:5556") == 0);
// Start a forwarder device
zmq_device (ZMQ_FORWARDER, frontend, backend);
----
SEE ALSO SEE ALSO
-------- --------