代码拉取完成,页面将自动刷新
//#pragma once
#ifndef TEST_H
#define TEST_H
#include <QTcpServer>
#include <QObject>
#include <QDebug>
#include <QTcpSocket>
#include <QMap>
#include <queue>
#include <string>
#include <vector>
#include <iostream>
#include "dbProcess.h"
#include "Tcp_tools.h"
class TcpSocket : public QTcpSocket
{
Q_OBJECT
public:
static QMap<QString,TcpSocket*> tcpTree;
TcpSocket(QObject *parent = nullptr)
: QTcpSocket (parent)
{
connect(this, &QTcpSocket::readyRead, [this](){
QString strCode=this->readAll();
processObject sReadData_Object=Tcp_tools::string_to_processObject(strCode.toStdString());
string userid=sReadData_Object.getUser();
if(TcpSocket::tcpTree.count(QString::fromStdString(userid))==0){
TcpSocket::tcpTree[QString::fromStdString(userid)]=this;
}
dbProcess::processQueue.push(sReadData_Object);
});
connect(this, &QTcpSocket::disconnected, [this](){
emit emit_disConnected(this->socketDescriptor());
});
}
signals:
void emit_disConnected(qintptr);
};
class TcpSocketServer:public QTcpServer
{
Q_OBJECT
public:
QList<TcpSocket*> socList;
TcpSocketServer();
virtual void incomingConnection(qintptr handle);
void show_map();
public slots:
void response_handle(processObject);
};
class ServerResponseThread : public QThread
{
Q_OBJECT
public:
virtual void run() override;
signals:
void db_response_signal(processObject);
};
#endif
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。