Qt网络编程-ZMQ的使用

#include "mainwindow.h" #include "ui_mainwindow.h" #include "zmqpublisher.h" #include "zmqsubscriber.h" #include <QThread> MainWindow::MainWindow(QWidget *parent) : QMainWindow(parent), ui(new Ui::MainWindow) { ui->setupUi(this); qRegisterMetaType<QTextCursor>("QTextCursor"); m_PubThread = new QThread; m_SubThread = new QThread; m_Publisher = new ZmqPublisher; m_Subscriber = new ZmqSubscriber; m_Publisher->moveToThread(m_PubThread); m_Subscriber->moveToThread(m_SubThread); connect(this, &MainWindow::publishData, m_Publisher, &ZmqPublisher::publishData); connect(m_Subscriber, &ZmqSubscriber::dataReceived, [=](const QByteArray &data) { QDataStream stream(data); QString msg = QString(); stream >> msg; ui->textEdit->append(msg); }); m_PubThread->start(); m_SubThread->start(); QMetaObject::invokeMethod(m_Subscriber, &ZmqSubscriber::procesMessage); } MainWindow::~MainWindow() { delete ui; } void MainWindow::on_pub_clicked() { if (m_Publisher->bind(ui->pubPort->value())) ui->textEdit->append("bind success"); else ui->textEdit->append("bind failed"); } void MainWindow::on_sub_clicked() { if (m_Subscriber->connectTo(ui->subPort->value())) ui->textEdit->append("connect success"); else ui->textEdit->append("connect failed"); } void MainWindow::on_send_clicked() { QString msg = ui->message->text(); QByteArray data; QDataStream stream(&data, QIODevice::WriteOnly); stream << msg; emit publishData(data); }