[C++知识库]转发ubuntu qt使用ZMQ

1、安装libzmp
sudo apt-get install libzmq3-dev
1
2、下载官网demo
git clone git://github.com/imatix/zguide.git
1
3、使用qt创建c++文件
发布者文件部分：
.pro文件:文件最后一行添加LIBS += -lzmq

TEMPLATE = app
CONFIG += console c++11
CONFIG -= app_bundle
CONFIG -= qt

SOURCES += main.cpp
LIBS += -lzmq
1
2
3
4
5
6
7
直接从官网下载的demo不能用，编译出错call of overloaded s_send is ambiguous，原因是发送的字符串没有声明类型，编译器以为是const char类型，所以在发送前声明一次函数规定的const std::string类型就ok了
main.cpp

#include <thread>
#include <chrono>
#include "../zguide/examples/C++/zhelpers.hpp"

int main (int argc, char *argv [])
{
? ? zmq::context_t context(1);
? ? zmq::socket_t publisher(context, ZMQ_PUB);

? ? if (argc == 2)
? ? ? ? publisher.bind(argv [1]);
? ? else
? ? ? ? publisher.bind("tcp://*:5556");

? ? // ?Ensure subscriber connection has time to complete
? ? std::this_thread::sleep_for(std::chrono::seconds(1));

? ? // ?Send out all 1,000 topic messages
? ? for (int topic_nbr = 0; topic_nbr < 1000; topic_nbr++) {
? ? ? ? std::stringstream ss;
? ? ? ? ss << std::dec << std::setw(3) << std::setfill('0') << topic_nbr;
? ? ? ? s_sendmore (publisher, ss.str());

? ? ? ? const std::string s1 = "Save Roger";
? ? ? ? std::cout << "I send " << s1 << std::endl;
? ? ? ? s_send (publisher, s1);
? ? ? ? std::this_thread::sleep_for(std::chrono::seconds(1));
? ? }

? ? return 0;
}

33
订阅者文件部分类似：
.pro文件:文件最后一行添加LIBS += -lzmq

TEMPLATE = app
CONFIG += console c++11
CONFIG -= app_bundle
CONFIG -= qt

SOURCES += main.cpp
LIBS += -lzmq
1
2
3
4
5
6
7
main.cpp

#include "../zguide/examples/C++/zhelpers.hpp"

int main (int argc, char *argv [])
{
? ? zmq::context_t context(1);
? ? zmq::socket_t subscriber (context, ZMQ_SUB);

? ? if (argc == 2)
? ? ? ? subscriber.connect(argv [1]);
? ? else
? ? ? ? subscriber.connect("tcp://localhost:5556");

? ? std::stringstream ss;

? ? subscriber.setsockopt( ZMQ_SUBSCRIBE, ss.str().c_str(), ss.str().size());

? ? while (1) {
? ? ? ? std::string topic = s_recv (subscriber);
? ? ? ? std::string data = s_recv (subscriber);

? ? ? ? std::cout << "Received topic:" << topic << std::endl;
? ? ? ? std::cout << "Received data:" << data << std::endl;
? ? }
? ? return 0;
}

————————————————
版权声明：本文为CSDN博主「古德古德古德」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/qq_34743874/article/details/107611618