美文网首页
openGauss修改记录# 2020.11.17

openGauss修改记录# 2020.11.17

作者: upup果 | 来源:发表于2020-11-17 16:17 被阅读0次

1.安装zeroMQ:
参考:[https://blog.csdn.net/xiaoyezi_1834/article/details/51298408]
安装包地址失效:[https://github.com/zeromq/zeromq4-1/releases]在这个地址选择任意版本下载
2.上传zmq.hpp,需要用c++版本的接口,写一个发送接受的小demo
在zmq的安装目录下创建server.cpp和client.cpp了两个文件
server代码:

include <iostream>

include <zmq.hpp>

include <string>

using namespace std;
int main()
{
zmq::context_t context(1);
//zmq_ctx_set(&context, ZMQ_IO_THREADS, 3);
// 负责pull request
zmq::socket_t response_puller(context, ZMQ_PULL);
//response_puller.setsockopt(ZMQ_RCVTIMEO, &timeout, sizeof(timeout));
response_puller.bind("tcp://:5555");//bind监听端口
zmq::message_t message;
for(;;){
const auto ret = response_puller.recv(&message);
string res=string(static_cast<const char
>(message.data()), message.size());
if (!ret)
return 1;
cout << "I Got " << res << " messages" << std::endl;
}
return 0;
}

client代码:

include <iostream>

include <zmq.hpp>

include <string>

using namespace std;
int main()
{
zmq::context_t context(1);
//zmq_ctx_set(&context, ZMQ_IO_THREADS, 3);
// 负责push request
zmq::socket_t request_pusher(context, ZMQ_PUSH);
request_pusher.connect("tcp://172.16.181.128:5555");
string s = "hello zeromq!";
zmq::message_t msg(s.size());
memcpy(msg.data(), s.c_str(), s.size());
request_pusher.send(msg);
std::cout << "I sent " << s
<< " messages" << std::endl;
return 0;
}

编译(参考上面教程的)
g++ server.cpp -o server -lzmq -I./include -L./lib
g++ client.cpp -o client -lzmq -I./include -L./lib

相关文章

网友评论

      本文标题:openGauss修改记录# 2020.11.17

      本文链接:https://www.haomeiwen.com/subject/zrgabktx.html