1.创建一个C工程
2.添加链接库
右键工程Properties->C/C++ Build->Settings 添加zeromq安装路径下的include
添加zeromq安装路径下的lib文件,并在Libraries(-l)中添加一项,填入zmq。
3.示例
Server:
#include <stdio.h> #include <stdlib.h> #include <zmq.h> #include <unistd.h> #include <assert.h> int main(void) { void *context=zmq_ctx_new(); void *responder=zmq_socket(context,ZMQ_REP); int rc=zmq_bind(responder,"tcp://*:5555"); assert(rc==0); while(1){ char buffer[10]; zmq_recv(responder,buffer,10,0); printf("Received Hello\n"); sleep(2); zmq_send(responder,"World",5,0); } //puts("!!!Hello World!!!"); /* prints !!!Hello World!!! */ return EXIT_SUCCESS; }
Client:
#include <zmq.h> #include <string.h> #include <stdio.h> #include <unistd.h> int main (void) { printf ("Connecting to hello world server…\n"); void *context = zmq_ctx_new (); void *requester = zmq_socket (context, ZMQ_REQ); zmq_connect (requester, "tcp://localhost:5555"); int request_nbr; for (request_nbr = 0; request_nbr != 10; request_nbr++) { char buffer [10]; printf ("Sending Hello %d…\n", request_nbr); zmq_send (requester, "Hello", 5, 0); zmq_recv (requester, buffer, 10, 0); printf ("Received World %d\n", request_nbr); } zmq_close (requester); zmq_ctx_destroy (context); return 0; }
参考链接
http://zguide.zeromq.org/page:all#header-12