- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
在 Ubuntu 16.04 机器上,我使用 Python3 和 pyzmq 通过 ZeroMQ PUB/SUB 套接字将 base64 结尾的 JPEG 发送到 Qt5 应用程序。 Qt5 应用程序使用 QSocketNotifier 来监视 ZMQ 套接字,并且应该在套接字“激活”并读取更多数据时触发。在我的例子中,数据在 Qt5 端被完全接收并且 JPEG 看起来没问题——但是,套接字通知程序只触发一次,即使 Python 发布者一直在发送数据。如果我使用 ctrl-C 退出 Python 应用程序,则会在 Qt5 应用程序端触发套接字通知程序激活槽的另一个实例。我希望每次从 Python 发送 ZMQ 消息时触发插槽。我在下面附上了 Python 和 Qt5 的整个应用程序。我怎样才能使它工作?
-------- Header File ------
#ifndef SOCKETRECEIVER_H
#define SOCKETRECEIVER_H
#include <QObject>
// Debug
#include <QDebug>
#include <QDataStream>
#include <QFile>
#include <unistd.h>
// User ZeroMQ Sockets
#include <QSocketNotifier>
// ZeroMQ Includes
#include <zmq.h>
// Debug prints
static void AppDebug(QString message) {
qDebug() << Q_FUNC_INFO << message;
}
class SocketReceiver : public QObject
{
Q_OBJECT
public:
explicit SocketReceiver(QObject *parent = nullptr);
~SocketReceiver();
private slots:
void readZMQData();
private:
QSocketNotifier *m_SocketNotifier;
void *m_Context;
void *m_Subscriber;
long long int m_RxFrameCounter;
bool m_DidRXFrame;
signals:
public slots:
};
#endif // SOCKETRECEIVER_H
-------- CCP File ------
#include "socketreceiver.h"
SocketReceiver::SocketReceiver(QObject *parent) : QObject(parent) , m_SocketNotifier(nullptr) , m_Context(nullptr) , m_Subscriber(nullptr) , m_RxFrameCounter(0) , m_DidRXFrame(false)
{
/***** ZMQ *****/
int major, minor, patch;
zmq_version (&major, &minor, &patch);
m_Context = zmq_ctx_new();
m_Subscriber = zmq_socket (m_Context, ZMQ_SUB);
int rc = -1;
unsigned int fd = 0;
do {
const char *filter = std::string("").c_str();
rc = zmq_connect (m_Subscriber, "tcp://localhost:5556");
rc = zmq_setsockopt (m_Subscriber, ZMQ_SUBSCRIBE,filter, strlen (filter));
size_t fd_size = sizeof(fd);
rc = zmq_getsockopt(m_Subscriber,ZMQ_FD,&fd,&fd_size);
m_SocketNotifier = new QSocketNotifier(fd, QSocketNotifier::Read, this);
connect(m_SocketNotifier, SIGNAL(activated(int)), this, SLOT(readZMQData()), Qt::DirectConnection);
}
while ( rc < 0 );
AppDebug("Done setting up");
}
SocketReceiver::~SocketReceiver()
{
zmq_close (this->m_Subscriber);
zmq_ctx_destroy (this->m_Context);
}
void SocketReceiver::readZMQData()
{
m_SocketNotifier->setEnabled(false);
AppDebug("Waiting for next frame...");
QByteArray newFrame;
int events = 0;
std::size_t eventsSize = sizeof(events);
zmq_getsockopt(m_Subscriber,ZMQ_EVENTS, &events, &eventsSize);
if(events & ZMQ_POLLIN){
AppDebug("Read Data...");
// Receive data from socket
zmq_msg_t message;
zmq_msg_init(&message);
zmq_recvmsg(m_Subscriber, &message, 0);
size_t size = zmq_msg_size (&message);
AppDebug(QString("Message Size: %1").arg(size));
char *string = static_cast<char*>(malloc(size + 1));
memcpy (string, zmq_msg_data(&message), size);
zmq_msg_close (&message);
string [size] = 0;
if ( string != nullptr ) {
QByteArray newDecodedData = QByteArray::fromBase64(QByteArray(string));
newFrame.append(newDecodedData);
free(string);
if ( !m_DidRXFrame ) {
m_DidRXFrame = true;
}
if ( m_RxFrameCounter == 0 && m_DidRXFrame ) {
AppDebug(QString("Debug RX Frame Size: %1").arg(newFrame.size()));
QFile output("/tmp/abcd.jpeg");
if ( output.open(QIODevice::WriteOnly) ) {
output.write(newFrame);
output.close();
//sleep(86400);
}
}
m_RxFrameCounter++;
}
}
AppDebug("Setting enabled true...");
m_SocketNotifier->setEnabled(true);
}
-------- Python 脚本------------
#!/usr/bin/python3
import zmq
import random
import sys
import time
import base64
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:5556")
time.sleep(1)
while True:
f = open("test.jpg",'rb')
bytes = bytearray(f.read())
print("Encoded Data Length: %s"%(len(bytes)))
strng = base64.b64encode(bytes)
print("Encoded Data Length: %s"%(len(strng)))
socket.send(strng)
f.close()
time.sleep(1)
最佳答案
你必须使用一段时间,因为在读取数据时你可以得到另一个数据:
int SocketReceiver::events(){
int events = 0;
std::size_t eventsSize = sizeof(events);
zmq_getsockopt(m_Subscriber,ZMQ_EVENTS, &events, &eventsSize);
return events;
}
void SocketReceiver::readZMQData()
{
m_SocketNotifier->setEnabled(false);
while (events() & ZMQ_POLLIN) {
zmq_msg_t message;
zmq_msg_init(&message);
zmq_recvmsg(m_Subscriber, &message, 0);
size_t size = zmq_msg_size (&message);
AppDebug(QString("Message Size: %1").arg(size));
char *string = static_cast<char*>(malloc(size + 1));
memcpy (string, zmq_msg_data(&message), size);
zmq_msg_close (&message);
string [size] = 0;
if (string) {
QByteArray frame = QByteArray::fromBase64(QByteArray(string));
free(string);
AppDebug(QString("Debug RX Frame Size: %1").arg(frame.size()));
QFile output("/tmp/abcd.jpeg");
if ( output.open(QIODevice::WriteOnly) ) {
output.write(frame);
output.close();
}
}
}
m_SocketNotifier->setEnabled(true);
}
关于linux - ZeroMQ with Qt 5.12 QSocketNotifier 只触发一次,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53982827/
你能举一些zeromq的例子吗? 最佳答案 假设您想要某种公告板。您希望通过订阅公告板来只允许某些人看到它。 这可以使用 ZeroMQ 的发布者/订阅者模型来完成。 现在,假设您需要发送一些异步消息。
因此,正如我在上一篇文章中所问的那样,我希望能够使用不同语言编写的程序或函数在它们之间进行通信。 我最近遇到了 zeromq,我试图弄清楚这是否可以帮助我,因为它提供了某种套接字。例如,zeromq
与通过 POLLIN 多路复用多个套接字有何不同? while True: socks = dict(poller.poll()) if socks.get(control_recei
我正在设计一个与 ZeroMQ 对话的服务器应用程序。无需深入细节,服务器将存储和服务(来自查询请求)(eventid, eventstring)元组。 我的问题涉及有线协议(protocol)的设计
我有一个服务器(在 Amazon 上运行)和一个连接到它的客户端。建立连接后,客户端和服务器专门相互通信并发送消息。 例如 1. Client -> Server 2. Client -> Serve
我正在开发一个新的客户端-服务器应用程序 (.Net),并且到目前为止一直在使用 WCF,它非常适合应用程序的请求-响应方法。然而,我被要求用基于套接字的解决方案替换它,部分是为了支持非 .Net 客
我正在尝试做一个发布/订阅架构,其中多个发布者和多个订阅者存在于同一总线上。根据我在互联网上阅读的内容,只有一个套接字应该调用 bind(),而所有其他套接字(无论是 pub 还是 sub)都应该调用
使用zeromq,发送者发送10条消息后,发送者崩溃。 场景1:接收方正在一条一条地处理消息,花费了一些明显的时间成本,在这种情况下它还会收到 10 条消息吗? 场景 2:另一种情况是,当接收器崩溃时
我有一个 ZeroMQ 套接字,它正在从不同机器上的多个进程接收数据。在不改变数据内容的情况下,有没有办法识别数据的来源呢?具体来说,我想要发送者的 IP 地址(如果它来自 TCP 连接)。 最佳答案
有人知道在哪里可以找到有关 ZeroMQ 延迟与 29 West LBM 等竞争对手的性能详细信息吗? 看起来便宜得多,但我找不到任何指标来决定哪个更合适。 最佳答案 ZeroMQ 和 29West
有没有办法在不使用转发器概念的情况下使用 zeroMQ 库进行消息广播? 最佳答案 是的,一个 PUB 套接字将广播到所有连接的 SUB 套接字。只有当您想要桥接不同的网络时才需要转发器(代理),例如
几天前我才开始使用zeromq。我的目标是设计一个具有多个代理(代理网络)的发布订阅系统。我已经阅读了 zeromq 指南的相关部分,并为简单的发布子系统编写了代码。如果有人可以帮助我解决以下问题:
我需要编写一个订单管理器,将客户(股票、外汇等)订单发送到适当的交易所。客户想要发送订单,但对 FIX 或其他专有协议(protocol)一无所知,只知道发送订单的内部(规范化)格式。我有应用程序(服
我正在尝试从示例 wuclient/wuserver 在 zeromq 上实现一个惰性订阅者。 客户端比服务器慢得多,因此它必须只获取服务器最后发送的消息。 到目前为止,我发现这样做的唯一方法是连接/
我是 ZeroMQ 的新手并试图找出设计问题。我的情况是我有一个或多个客户端向单个服务器发送请求。服务器将处理请求,做一些事情,并向客户端发送回复。有两个条件: 回复必须发送到发送请求的客户端。 如果
如 docs 中所述在 3.x 版本的 zeromq 中,PUB/SUB 场景中的消息正在被过滤 出版商侧(而不是在订阅者方面,这是微不足道的)。 对我来说,这听起来像是发布者必须持有所有连接的套接字
引自 ZeroMQ 指南 However, with a little extra work, this humble pattern becomes a good basis for real wo
假设我有一个带有 ZeroMQ 接口(interface)的节点(进程、线程等),比方说一个 REP 套接字。这意味着我有一个无限主循环,它在 zmq_recv 或 zmq_poll 函数中休眠。 现
我想以某种方式比较 grpc 与 Zeromq 及其模式的功能:并且我想创建一些比较(功能集) - 不知何故 - 0mq 是“更好”的套接字 - 但无论如何 - 如果我应用 0mq模式 - 我认为我得
我正在试验 ZeroMQ。我发现在 ZeroMQ 中非常有趣,connect 或 bind 先发生并不重要。我试着查看 ZeroMQ 的源代码,但它太大了,找不到任何东西。 代码如下。 # clien
我是一名优秀的程序员,十分优秀!