DeviceClient端:
#include <assert.h> #include <iostream> #include <tchar.h> #include <zmq.h> using namespace std; #pragma comment(lib,"libzmq.lib") void main(int argc,TCHAR*argv[]) { //初始化 void *ctx; ctx = zmq_init(1); assert(ctx); void *reqSock; reqSock = zmq_socket(ctx,ZMQ_REQ); assert(reqSock); int rc; rc = zmq_connect(reqSock,"tcp://127.0.0.1:6000"); assert(0 == rc); zmq_msg_t msg; while(1) { //发送数据 char *sd_string = "client send 0k"; zmq_msg_init_size(&msg,strlen(sd_string)+1); memcpy(zmq_msg_data(&msg),sd_string,strlen(sd_string)+1); zmq_send(reqSock,&msg,0); zmq_msg_close(&msg); //接收数据 char *re_string; zmq_msg_init(&msg); zmq_recv(reqSock,&msg,0); re_string = (char*)zmq_msg_data(&msg); cout<<"client 收到数据:"<<re_string<<endl; zmq_msg_close(&msg); } //关闭 zmq_close(reqSock); zmq_term(ctx); }
DeviceServer端:
#include <assert.h> #include <iostream> #include <tchar.h> #include <zmq.h> using namespace std; #pragma comment(lib,"libzmq.lib") void main(int argc,TCHAR*argv[]) { //初始化 void *ctx; ctx = zmq_init(1); assert(ctx); void *repSock; repSock = zmq_socket(ctx,ZMQ_REP); assert(repSock); int rc; rc = zmq_bind(repSock,"tcp://127.0.0.1:8000"); assert(0 == rc); zmq_msg_t msg; while(1) { //接收数据 char *re_string; zmq_msg_init(&msg); zmq_recv(repSock,&msg,0); re_string = (char*)zmq_msg_data(&msg); cout<<"server 收到数据:"<<re_string<<endl; zmq_msg_close(&msg); Sleep(1000); //发送数据 char *sd_string = "server send 0k"; zmq_msg_init_size(&msg,strlen(sd_string)+1); memcpy(zmq_msg_data(&msg),sd_string,strlen(sd_string)+1); zmq_send(repSock,&msg,0); zmq_msg_close(&msg); } //关闭 zmq_close(repSock); zmq_term(ctx); }
DeviceDevice端:
#include <assert.h> #include <iostream> #include <tchar.h> #include <zmq.h> using namespace std; #pragma comment(lib,"libzmq.lib") void main(int argc,TCHAR*argv[]) { //初始化 void *ctx; ctx = zmq_init(1); assert(ctx); void *reqSock; reqSock = zmq_socket(ctx,ZMQ_XREQ); assert(reqSock); void *repSock; repSock = zmq_socket(ctx,ZMQ_XREP); assert(repSock); int rc; rc = zmq_connect(reqSock,"tcp://127.0.0.1:8000"); assert(0 == rc); rc = zmq_bind(repSock,"tcp://127.0.0.1:6000"); assert(0 == rc); zmq_device(ZMQ_QUEUE,reqSock,repSock); //关闭 zmq_close(reqSock); zmq_close(repSock); zmq_term(ctx); }