Я очень новичок в программировании как на Qt, так и на сокетах.
Я пытаюсь написать простое приложение TCP-сервер / чат, но часть readyRead() или "получение" находится в своем собственном потоке.Я получил эту «работу», используя UDP, но по какой-то причине сокеты TCP не работают так же.
Я очень открыт для других предложений, так как я могу решить это неправильно.В конечном итоге у меня будет это приложение, слушающее непрерывный ввод от встроенной системы, чтение и запись команд, а также получение «сердцебиения» от системы.
Я следую инструкциям YouTube от Voidrealms и внедряютемы "Правильный путь".Но теперь я не могу запустить qThread::exec(), поскольку он защищен.
Так что в основном я хотел бы sender и receiver в различных потоках , чтобы sender не блокировал receiver и наоборот.
Я опубликую только код сервера TCP и рабочий код UDP для справки.
tcpserver.h
#ifndef TCPSERVER_H
#define TCPSERVER_H
#include <QObject>
#include <QDebug>
#include <QTcpServer>
#include <QTcpSocket>
#include <QThread>
class TCPServer : public QObject
{
Q_OBJECT
public:
explicit TCPServer(QObject *parent = nullptr);
void SendData();
void DoSetup(QThread &cThread);
// void readyRead();
bool conn;
signals:
public slots:
void newConnection();
void readyRead();
void DoWork();
private:
QTcpServer *server;
QTcpSocket *socket;
};
#endif // TCPSERVER_H
tcpserver.cpp
#include "tcpserver.h"
#include <QThread>
TCPServer::TCPServer(QObject *parent) : QObject(parent)
{
this->conn =0;
server = new QTcpServer(this);
connect(server,SIGNAL(newConnection()),this,SLOT(newConnection()));
//telnet 169.254.55.237 1234
if(!server->listen(QHostAddress("169.254.55.237"),1234)){
qDebug() << "Server not started";
}
else{
qDebug() << "server started";
}
}
void TCPServer::DoSetup(QThread &cThread){
connect(&cThread,SIGNAL(started()),this,SLOT(DoWork()));
}
void TCPServer::DoWork(){
qDebug() << "Running Thread";
connect(this->socket, SIGNAL(readyRead()), this, SLOT(readyRead()));
}
void TCPServer::SendData(){
while(1){
QByteArray Data;
Data.append("Server: ");
QTextStream s(stdin);
QString value = s.readLine();
Data.append(value);
this->socket->write(Data);
//this->socket->write("hello client\r\n");
this->socket->flush();
this->socket->waitForBytesWritten(3000);
}
}
void TCPServer::newConnection(){
this->socket = server->nextPendingConnection();
//connect(this->socket,SIGNAL(readyRead()),this,SLOT(readyRead()));
this->conn =1;
this->SendData();
//this->socket->close();
}
void TCPServer::readyRead(){
// while(1){
if(this->conn){
qDebug()<< "Reading...";
qDebug()<< this->socket->readAll();
}
}
main.cpp
#include <QCoreApplication>
#include "tcpserver.h"
int main(int argc, char *argv[])
{
QCoreApplication a(argc, argv);
QThread cThread;
TCPServer mServer;
mServer.DoSetup(cThread);
mServer.moveToThread(&cThread);
cThread.start();
return a.exec();
}
РАБОЧИЙ УАРТ.myudp.h
// myudp.h
#ifndef MYUDP_H
#define MYUDP_H
#include <QObject>
#include <QUdpSocket>
#include <QDebug>
#include <QThread>
class MyUDP : public QObject
{
Q_OBJECT
public:
explicit MyUDP(QObject *parent = nullptr);
void HelloUDP();
void DoSetup(QThread &cThread);
//void readyRead();
signals:
public slots:
void readyRead();
void DoWork();
private:
QUdpSocket *socket;
};
#endif // MYUDP_H
myudp.cpp
// myudp.cpp
#include "myudp.h"
MyUDP::MyUDP(QObject *parent) :
QObject(parent)
{
// create a QUDP socket
socket = new QUdpSocket(this);
socket->bind(QHostAddress(" 169.254.55.237"), 1234);
//connect(socket, SIGNAL(readyRead()), this, SLOT(readyRead()));
}
void MyUDP::DoSetup(QThread &cThread){
connect(&cThread,SIGNAL(started()),this,SLOT(DoWork()));
}
void MyUDP::DoWork(){
qDebug() << "Running Thread";
connect(socket, SIGNAL(readyRead()), this, SLOT(readyRead()));
}
void MyUDP::HelloUDP()
{
while(1){
QByteArray Data;
Data.append("Server: ");
QTextStream s(stdin);
QString value = s.readLine();
Data.append(value);
socket->writeDatagram(Data, QHostAddress("169.254.55.237"), 4321);
//socket->writeDatagram(Data, QHostAddress("127.0.0.1"), 1234);
}
}
void MyUDP::readyRead()
{
// if(socket->hasPendingDatagrams()){
// when data comes in
QByteArray buffer;
buffer.resize(socket->pendingDatagramSize());
QHostAddress sender;
quint16 senderPort;
socket->readDatagram(buffer.data(), buffer.size(),&sender, &senderPort);
qDebug() << "Message from: " << sender.toString();
qDebug() << "Message port: " << senderPort;
qDebug() << "Message: " << buffer;
// }
}
main.cpp
#include <QCoreApplication>
#include <QThread>
#include "myudp.h"
int main(int argc, char *argv[])
{
QCoreApplication a(argc, argv);
qDebug() << "Server";
QThread cThread;
MyUDP client;
client.DoSetup(cThread);
client.moveToThread(&cThread);
cThread.start();
client.HelloUDP();
return a.exec();
}