从Qt上的UNIX域套接字(QLocalSocket)读取
Reading from a UNIX domain socket (QLocalSocket) on Qt
我在从UNIX域套接字读取时遇到问题,服务器应用程序是基于Python的,我需要实现IPC以作为客户端与Qt应用程序进行通信。服务器应用程序经过测试,并使用 Python 客户端应用程序。这是我在Qt客户端拥有的内容:
优尼克斯.cpp
#include "unixsocket.h"
#include <stdio.h>
UnixSocket::UnixSocket(QObject *parent) :
QObject(parent)
{
this->socket = new QLocalSocket (this);
}
UnixSocket::~UnixSocket(){}
void UnixSocket::Test ()
{
connect (this->socket, SIGNAL(connected()), this, SLOT(connected_callback()));
connect (this->socket, SIGNAL(disconnected()), this, SLOT(disconnected_callback()));
connect (this->socket, SIGNAL(readyRead()), this, SLOT(readyRead_callback()));
connect (this->socket, SIGNAL(bytesWritten(qint64)), this, SLOT(bytesWritten_callback(qint64)));
qDebug() << "Connecting...";
socket->connectToServer(ADAPTER_SOCKET);
if (!socket->waitForConnected(1000))
{
qDebug() << "Error: " << this->socket->errorString();
}
else
{
in.setDevice(socket);
in.setVersion(QDataStream::Qt_5_8);
this->blockSize = 0;
}
}
void UnixSocket::connected_callback()
{
qDebug() << "Connected to " << socket->fullServerName();
}
void UnixSocket::disconnected_callback()
{
qDebug() << "Disconnected!";
}
void UnixSocket::bytesWritten_callback(qint64 bytes)
{
qDebug() << "We wrote: " << bytes;
}
void UnixSocket::readyRead_callback()
{
qDebug() << "Reading...";
qDebug() << "Block Size: " << this->blockSize;
if (this->blockSize == 0) {
// Relies on the fact that QDataStream serializes a quint32 into
// sizeof(quint32) bytes
if (socket->bytesAvailable() < (int)sizeof(quint32))
return;
in >> this->blockSize;
}
if (socket->bytesAvailable() < this->blockSize || in.atEnd())
return;
QString recvd_data;
in >> recvd_data;
qDebug() << recvd_data;
}
Unixsocket.h
#ifndef UNIXSOCKET_H
#define UNIXSOCKET_H
#include <QObject>
#include <QAbstractSocket>
#include <QLocalSocket>
#include <QtNetwork>
#include <QIODevice>
#include <QDebug>
#include <QTextStream>
#include <QDataStream>
#define ADAPTER_SOCKET "/opt/adapter/socket"
class UnixSocket: public QObject
{
Q_OBJECT
public:
explicit UnixSocket(QObject *parent = 0);
~UnixSocket();
void Test ();
signals:
public slots:
void connected_callback();
void disconnected_callback();
void bytesWritten_callback (qint64 bytes);
void readyRead_callback();
private:
QLocalSocket *socket;
QDataStream in;
quint32 blockSize;
};
#endif // UNIXSOCKET_H
和主.cpp到火类:
int main(int argc, char* argv[])
{
UnixSocket mUnixSocket;
mUnixSocket.Test();
while (1);
return 1;
}
现在,Unix域套接字连接工作正常。所以,我收到"连接"消息。而且我确定服务器正在异步发送一些数据,但由于某种原因,我的程序根本没有进入readyRead_callback
。我需要有关如何解决此问题的指示。任何帮助都非常感谢。
qt信号需要存在于Qt事件循环中,在您的情况下,您没有任何信号,因此它对您不起作用,因此请将代码更改为:
int main(int argc, char *argv[]) {
QCoreApplication a(argc, argv);
UnixSocket mUnixSocket;
mUnixSocket.Test();
return a.exec();
}
如何在服务器中侦听Unix域套接字? 使用QLocalServer
,但不调用onNewConnection
mServer = new QLocalServer;
connect(mServer, SIGNAL(newConnection()), this, SLOT(onNewConnection()));
相关文章:
- 理解boost::asio-async_read在无需读取内容时的行为
- 使用新行和不使用新行读取文件
- 读取文件并输入到矢量中
- 用c++从输入文件中读取另一行
- 读取文件的最后一行并输入到链接列表时出错
- 在进程中对同一管道进行读取和写入时C++管道出现问题
- 无法找到/读取配置文件.conf-FileIOException
- 如何使用Luacneneneba API正确读取字符串和表参数
- C++将文本文件中的数据读取到结构数组中
- 正在将csv文件读取为双精度矢量
- 为什么 sscanf 无法从一个字符串中读取uint64_t和字符?
- 为什么在读取文件大小时文件IO速度会发生变化
- 正在读取二进制文件(is_open)
- 如何在c++中从文本文件中逐行读取整数
- SSH通过/sbin/SSH无法读取RSA密钥文件(从控制台运行)
- 独立读取-修改-写入顺序
- 从文本文件中读取时钟时间和事件时间并进行处理
- 从Qt上的UNIX域套接字(QLocalSocket)读取
- 应该如何读取QLocalSocket/QDataStream以避免死锁
- 从QLocalSocket读取的字节数超过2048