Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- CLIENT:
- #include <czmq.h>
- int main (void)
- {
- zsock_t *pub, *sub;
- pub = zsock_new_pub(">tcp://localhost:5555");
- zmsg_t *send = zmsg_new();
- zframe_t *f1, *f2;
- f1 = zframe_new("/test/test2",strlen("/test/test2"));
- f2 = zframe_new("Hello, world",strlen("Hello, world"));
- zmsg_append(send,&f1);
- zmsg_append(send,&f2);
- zmsg_send(&send,pub);
- sub = zsock_new_sub(">tcp://localhost:5556", "/test/test2");
- sleep(1);
- zmsg_t *msg = zmsg_recv(sub);
- zmsg_print(msg);
- zmsg_destroy(&msg);
- zsock_destroy(&pub);
- zsock_destroy(&sub);
- return 0;
- }
- SERVER:
- #include <czmq.h>
- int main (void)
- {
- zactor_t *proxy = zactor_new(zproxy, NULL);
- zstr_send (proxy, "VERBOSE");
- zsock_wait (proxy);
- zstr_sendx(proxy, "FRONTEND", "XSUB", "tcp://*:5555", NULL);
- zsock_wait(proxy);
- zstr_sendx(proxy, "BACKEND", "XPUB", "tcp://*:5556", NULL);
- zsock_wait(proxy);
- zsock_t *capture = zsock_new_pull ("inproc://capture");
- zstr_sendx (proxy, "CAPTURE", "inproc://capture", NULL);
- zsock_wait (proxy);
- while (true) {
- zmsg_t *msg = zmsg_recv(capture);
- if (!msg)
- break;
- printf("C: ");
- zmsg_print(msg);
- }
- zsock_destroy(&capture);
- zactor_destroy(&proxy);
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement