zmq mysql_【ZeroMQ】轮询zmq_poll()的使用 | 学步园

亦凉 2022-11-01 05:42 199阅读 0赞

注意：此时不可以用ZMQ\_REP ZMQ\_REQ。  因为ZMQ\_REQ发送一次数据后，如果没有收到数据，不能再次发送数据。

ZmqIOServer端：

\#include

using namespace std;

\#pragma comment(lib,"libzmq.lib")

void main(int argc,TCHAR\*argv\[\])

void \*ctx;

ctx = zmq\_init(1);

assert(ctx);

void \*s1;

s1 = zmq\_socket(ctx,ZMQ\_PULL);

assert(s1);

void \*s2;

s2 = zmq\_socket(ctx,ZMQ\_PULL);

assert(s2);

zmq\_bind(s1,"tcp://127.0.0.1:6000");

zmq\_bind(s2,"tcp://127.0.0.1:7000");

while(1)

zmq\_pollitem\_t items\[2\];

items\[0\].socket = s1;

items\[0\].fd = 0;

items\[0\].events = ZMQ\_POLLIN;

items\[1\].socket = s2;

items\[1\].fd = 0;

items\[1\].events = ZMQ\_POLLIN;

int nRet = zmq\_poll(items,2,-1);

if(0 == nRet)

continue;

zmq\_msg\_t msg;

char re\_string\[20\] = \{0\};

if(items\[0\].revents > 0)

zmq\_msg\_init(&msg);

zmq\_recv(s1,&msg,0);

memcpy(re\_string,(char\*)zmq\_msg\_data(&msg),zmq\_msg\_size(&msg));

cout<

zmq\_msg\_close(&msg);

if(items\[1\].revents > 0)

zmq\_msg\_init(&msg);

zmq\_recv(s2,&msg,0);

memcpy(re\_string,(char\*)zmq\_msg\_data(&msg),zmq\_msg\_size(&msg));

cout<

zmq\_msg\_close(&msg);

zmq\_close(s1);

zmq\_close(s2);

zmq\_term(ctx);

ZmqIOClient1端：

\#include

using namespace std;

\#pragma comment(lib,"libzmq.lib")

void main(int argc,TCHAR\*argv\[\])

void \*ctx;

ctx = zmq\_init(1);

assert(ctx);

void \*s1;

s1 = zmq\_socket(ctx,ZMQ\_PUSH);

assert(s1);

zmq\_connect(s1,"tcp://127.0.0.1:6000");

while(1)

char sd\_string\[20\];

cout<

gets(sd\_string);

zmq\_msg\_t msg;zmq\_msg\_init\_size(&msg,strlen(sd\_string)+1);

memcpy(zmq\_msg\_data(&msg),sd\_string,strlen(sd\_string)+1);

zmq\_send(s1,&msg,0);

zmq\_msg\_close(&msg);

zmq\_close(s1);

zmq\_term(ctx);

ZmqIOClient2端：

\#include

using namespace std;

\#pragma comment(lib,"libzmq.lib")

void main(int argc,TCHAR\*argv\[\])

void \*ctx;

ctx = zmq\_init(1);

assert(ctx);

void \*s1;

s1 = zmq\_socket(ctx,ZMQ\_PUSH);

assert(s1);

zmq\_connect(s1,"tcp://127.0.0.1:7000");

while(1)

char sd\_string\[20\];

cout<

gets(sd\_string);

zmq\_msg\_t msg;

zmq\_msg\_init\_size(&msg,strlen(sd\_string)+1);

memcpy(zmq\_msg\_data(&msg),sd\_string,strlen(sd\_string)+1);

zmq\_send(s1,&msg,0);

zmq\_msg\_close(&msg);

zmq\_close(s1);

zmq\_term(ctx);

zmq mysql_【ZeroMQ】轮询zmq_poll()的使用 | 学步园

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 java.library.path在哪？学步园

相关 javascript 轮询_JavaScript轮询

相关 Angular6的轮询及终止轮询

相关轮询、长轮询、长连接、websocket

相关 express 使用SSE轮询

相关 xgettext php,gettext简介 | 学步园

相关 java lrc_读取Lrc-Java | 学步园

相关 zmq mysql_【ZeroMQ】轮询zmq_poll()的使用 | 学步园

相关轮询和长轮询优缺点分析

相关轮询、长轮询、长连接、websocket