QT-TCP通信一对多实例

待我称王封你为后i 2022-05-10 03:44 255阅读 0赞

pro 文件里要加一句： QT += network  
**服务器端：**

**1、 声明 QTcpServer、 QTcpSocket**  
QTcpServer \*tcpServer; //监听套接字  
QTcpSocket \*tcpSocket; //通信套接字

**2、 定义、 实例化**  
tcpServer = NULL;  
tcpSocket = NULL;  
tcpServer = new QTcpServer(this);  
tcpServer->listen(QHostAddress::Any,8888);//监听所有  
connect(tcpServer,SIGNAL(newConnection()),this,SLOT(getSocket()));  
socket\_list = new QList<QTcpSocket\*>;//zy 服务器一对多客户端用到

**3、 作为服务器通过 TCP 协议接收数据**  
void MainWidget::getSocket()  
\{  
tcpSocket = tcpServer->nextPendingConnection();//获取已经建立的连接  
的子套接字  
socket\_list->append(tcpSocket);//添加到 socket\_list 中  
QString ip = tcpSocket->peerAddress().toString();//此处是通过通信  
的套接字进行获取，也可以获取对方的 IPv6 和 IPv4，但是此处转换为 QString  
型  
qint16 port = tcpSocket->peerPort();//直接获取端口，不需要进行转换  
QString temp = QString::fromLocal8Bit("\[%1:%2\]:成功连接  
“).arg(ip).arg(port);  
qDebug() << temp;//打印 ip,port  
connect(tcpSocket,&QTcpSocket::readyRead, //先取出了tcpSocket 之后才能有调取 readyRead  
=  
\{  
//这种只能 1 对 1  
//从通信套接字中取出内容//array = @i00009 装备 9 请求帮助$  
//array = tcpSocket->readAll();//readAll（）函数是比较方便的取出  
tcpSocket 中的所有的内容  
// array\_str = QString(array);  
// qDebug() << QString(array)<< array\_str.size();  
// //array\_str = QString::fromLocal8Bit(”@i00009 装备 9  
请求帮助KaTeX parse error: Expected 'EOF', got '&' at position 276: …id(0,1) == "@" &̲& array\_str.mi…")//帧头帧尾  
\{  
if(array\_str.mid(1,1) == “i”)//功能码  
\{ui->information->setText(array\_str.mid(7,array\_str.size()-8));  
\}  
if(array\_str.mid(1,1) == “j”)//功能码  
\{  
ui->information->setText(array\_str.mid(7,array\_str.size()-8));  
\}  
\}  
//将读到的数据插入到数据库中  
QString insert\_tcp\_text = “insert into message\_tcp\_receive  
values(null,?,?,now())”;  
QSqlQuery sql\_insert\_tcp\_text;  
sql\_insert\_tcp\_text.prepare(insert\_tcp\_text);  
sql\_insert\_tcp\_text.bindValue(0, array\_str.mid(0,5));  
sql\_insert\_tcp\_text.bindValue(0, array\_str);  
sql\_insert\_tcp\_text.exec();  
if(array\_str.mid(0,1) == “0”)//功能码  
\{  
QString select\_data = “select car\_id from realtime\_data  
limit 1”;  
QSqlQuery sql\_select\_data;  
sql\_select\_data.prepare(select\_data);  
sql\_select\_data.exec();  
QString  
id=QString::number(sql\_select\_data.value(0).toInt()+1);  
QString insert\_data = “insert into realtime\_data  
values(null,?,?,?,?,?,0,0,0,0,0,0,0,0,0,0,0,0,now(),now())”;  
QSqlQuery sql\_insert\_data;  
sql\_insert\_data.prepare(insert\_data);  
sql\_insert\_data.bindValue(0, id);  
sql\_insert\_data.bindValue(1, “401158”);  
sql\_insert\_data.bindValue(2, array\_str.mid(2,5));  
sql\_insert\_data.bindValue(3, “192.168.1.4”);  
sql\_insert\_data.bindValue(4, “192.168.1.108”);  
sql\_insert\_data.exec();  
QString back\_id=id.sprintf("%05d",id);;  
writeCmd("@0"+back\_id+"$");  
\}  
\}

**4、 作为服务器发送数据信息**  
void MainWidget::writeCmd(QString cmd)  
\{  
//这种只能 1 对 1  
// //qDebug() << “writeCmd” << cmd;  
// if(NULL == tcpSocket)  
// \{  
// return;  
// \}//如果最开始没有建立连接，那么 tcpSocket 就为一个空的值，这时不  
能进行发送数据的操作  
// //发送数据给对方，使用套接字 tcpSocket  
// tcpSocket->write(cmd.toUtf8().data());  
//这种能 1 对多  
for (int i = 0;i < socket\_list->length();i ++)  
\{  
socket\_list->at(i)->write(cmd.toUtf8().data());//注意接收和发  
送的编码要一致  
//m\_tcpsocket->write(infomation.toUtf8().data());  
\}  
\}

**客户器端：**

**1、 声明， 定义 QTcpSocket**  
QTcpSocket \*socket;

**2、 实例化， 建立 TCP 连接**  
//TCP 连接  
socket = new QTcpSocket();  
connect(socket, SIGNAL(connected()), this, SLOT(OnConnected()));  
connect(socket, SIGNAL(disconnected()), this, SLOT(OnDisconnected()));  
connect(socket, SIGNAL(readyRead()), this, SLOT(socket\_Read\_Data()));  
int port = 8888;//获取端口号， 与服务器端口一致  
socket->abort();//取消已有的连接  
socket->connectToHost(IP, port);//连接服务器  
if(!socket->waitForConnected(1000))//等待连接成功  
\{  
qDebug() << QString::fromLocal8Bit("指挥中心连接失败！ "));  
\}else  
\{  
qDebug() << QString::fromLocal8Bit(“指挥中心连接成功！”));  
\}

**3、 作为客户端通过 TCP 协议接收数据**  
//从服务器端获取控制信号  
void MainWindow::socket\_Read\_Data()  
\{  
QByteArray signal;  
//读取缓冲区数据  
signal = socket->readAll();  
QString signaldata;  
signaldata = QString(signal);  
\}

**4、 作为客户端发送数据信息**  
void MainWidget::writeCmd(QString cmd)  
\{  
//qDebug() << “writeCmd” << cmd;  
if(NULL == tcpSocket)  
\{  
return;  
\}//如果最开始没有建立连接，那么 tcpSocket 就为一个空的值，这时不能  
进行发送数据的操作  
//发送数据给对方，使用套接字 tcpSocket  
tcpSocket->write(cmd.toUtf8().data());  
\}