Question

qtcpsocket是不是多线程

Answer 1

C/C++ code?

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

class FileRecvThread : public QThread
{
Q_OBJECT
public:
explicit FileRecvThread(QObject *parent = 0);
FileRecvThread(quint32, QObject *parent = 0);
~FileRecvThread();

void initSignalSlots();

void setPort(quint32 port);
quint32 getPort();

void dealShackHand(QByteArray *);
void replyExpectShackHand();

protected:
void run();

private:
quint32 port;
QTcpServer *pTcpServer;
QTcpSocket *pTcpSocket;

public slots:
void startTcpServer();
void dealNewConnection();
void dealDatagram();

FileRecvThread::FileRecvThread(quint32 port, QObject *parent) :
QThread(parent)
{
this->port = port;
}

void FileRecvThread::startTcpServer()
{
if (!this->pTcpServer)
{
this->pTcpServer = new QTcpServer;
this->pTcpServer->listen(QHostAddress::Any, this->port);
}
else
{
this->pTcpServer->listen(QHostAddress::Any, this->port);
}
}

void FileRecvThread::run()
{
this->startTcpServer();
this->initSignalSlots();
this->exec();

}
void FileRecvThread::initSignalSlots()
{
connect(this->pTcpServer, SIGNAL(newConnection()), this, SLOT(dealNewConnection()));
}

void FileRecvThread::dealNewConnection()
{
this->pTcpSocket = this->pTcpServer->nextPendingConnection();
connect(this->pTcpSocket, SIGNAL(readyRead()), this, SLOT(dealDatagram()));
}

void FileRecvThread::dealDatagram()
{
QByteArray byteArray = this->pTcpSocket->readAll();
//这里出现问题
<span style="color: #FF0000;">this->pTcpSocket->write(QByteArray("deal"));</span>
}