利用protobuf和zmq实现网络通信

经过不短时间的调试，终于搞定了protobuf和zmq两个第三方库的编译和使用，并且参考往事前辈的代码编写了两者之间的通信demo。

protobuf的编译和使用，前面有篇博客已经讲了。

zmq的编译我用的是zeromq-4.2.3这个可以在vs2015下面编译通过。

然后在zeromq-4.2.3_test\bin\Win32\Debug\v140\dynamic会生成lib和dll，dll每次用zmq的时候放到代码库，或者放到system32文件下面即可。

完成了protobuf和zmq 的编译就可进行网络通信的代码编写了。

我是参考别人的代码结构，但是我也踩了许多坑，调试成功的

server端：

#include #include"zmq.h" #include"zmq_utils.h" #include"helloworld.pb.h" const int bufflen = 128; using namespace std; int main() { void *context = zmq_ctx_new(); void responder = zmq_socket(context, ZMQ_REP); zmq_bind(responder, "tcp://:5555");

while (1) { zmq_msg_t request; zmq_msg_init(&request); int size = zmq_msg_recv(&request, responder, 0); char buff[bufflen];//这个声明位置的不对会导致程序崩溃，原因见下面的分析。这个是C语言的特性。因为zmq内部实现为C语言。 memcpy(buff, zmq_msg_data(&request), size);

helloworld rec; rec.ParseFromArray(buff, bufflen); cout << "id: " << rec.id() << "\t" << "str: " << rec.str() << "\n"; zmq_msg_close(&request); Sleep(200); memset(buff, 0,bufflen * sizeof(char)); helloworld msg; msg.set_id(303); msg.set_str("how"); msg.SerializeToArray(buff, bufflen); int len = strlen(buff); zmq_msg_t reply; zmq_msg_init_size(&reply, len); /* if (0 != zmq_msg_init_size(&reply, len)); { cout << "zmq_msg_init failed" << endl; break; } */ memcpy(zmq_msg_data(&reply), buff, len); zmq_msg_send(&reply, responder, 0); /* if (len = zmq_msg_send(&reply, responder, 0)) { zmq_msg_close(&reply); cout << "send failed..." << endl; break; } */ cout << "id: " << msg.id() << "\t" << "str: " << msg.str() << "\n"; zmq_msg_close(&reply);

} zmq_close(&responder); zmq_ctx_destroy(context); system(“pause”); return 0; } 由于zmq的实现是C语言的，所以在变量声明中要注意声明的顺序。 最好用的时候再声明。解释是：编译器可能按声明变量顺序安排他们的位置，对字符串操作严重依赖在何处能找到字符串结束标志，如果没有，就用最近的’\0’，而它很可能是你上次赋值的其他变量的值的一部分。 客户端代码： #include #include"zmq.h" #include"zmq_utils.h" #include"helloworld.pb.h" using namespace std; const int bufflen = 128; int main() { void *context = zmq_ctx_new(); void *requester = zmq_socket(context, ZMQ_REQ); zmq_connect(requester, “tcp://127.0.0.1:5555”); cout << “Connect to server success…” << endl;

while (1) { helloworld msg; msg.set_id(101); msg.set_str(“hello”);

char buffer[bufflen]; msg.SerializeToArray(buffer, bufflen); int len = strlen(buffer); zmq_msg_t req; if (0 != zmq_msg_init_size(&req, len)) { cout << "zmq_msg_init failed..." << endl; break; } memcpy(zmq_msg_data(&req), buffer, len); if (len != zmq_msg_send(&req, requester, 0)) { zmq_msg_close(&req); cout << "send failed.." << endl; break; } cout << "id: " << msg.id() << "\t" << "str: " << msg.str() << "\n"; zmq_msg_close(&req); Sleep(200); memset(buffer, 0, bufflen * sizeof(char)); zmq_msg_t reply; zmq_msg_init(&reply); int size = zmq_msg_recv(&reply, requester, 0); memcpy(buffer, zmq_msg_data(&reply), size); helloworld rec; rec.ParseFromArray(buffer, bufflen); cout << "id: " << rec.id() << "\t" << "str: " << rec.str() << "\n"; zmq_msg_close(&reply);

} zmq_close(&requester); zmq_ctx_destroy(context);

system(“pause”); return 0; } 很好用啊。而且很强大。执行结果：