while(true){ if(mIsSend){ qDebug() << "msg:"<< mMsg; //发送 ::send(mSocket,mMsg.toUtf8().data(),mMsg.length() +1,0); int errorCode = WSAGetLastError(); //连接超时 if( errorCode == WSAECONNABORTED){ emit isClose(); return; } //等待服务端回应 int ret = ::recv(mSocket,buf,1024,0); //服务端关闭 if( ret == 0){ emit isClose(); return; } QTime time = QTime::currentTime(); QString str = time.toString("hh:mm:ss"); qDebug() << "buf:" << buf ; QString msg = QString("%1 收到消息[%2]").arg(str).arg(buf); emit isMsg(msg); mIsSend = false; } }
时间: 2024-02-10 15:21:41 浏览: 55
Qt:串口通信代码,QT6,需要包含SerialPort模块
这段代码是 MsgThread 线程对象的主体函数,用于接收和发送网络消息,并在收到消息后进行处理。
具体来说,这段代码使用了一个无限循环 while(true),不断地接收和发送网络消息。如果 mIsSend 为 true,表示需要发送消息,此时会使用 send 函数将消息发送给远程主机,并使用 recv 函数等待远程主机的回应。在接收到回应后,会将回应的内容发送给主线程,并将 mIsSend 设置为 false。
在发送或接收网络消息时,还针对可能出现的网络异常情况进行了处理。例如,如果发送消息时发生连接超时错误(WSAECONNABORTED),则会发出 isClose 信号,表示需要关闭连接。如果接收时发现服务端已经关闭连接(ret == 0),也会发出 isClose 信号。同时,在收到消息后,还会获取当前时间,并将时间和收到的消息一起发送给主线程。
需要注意的是,这段代码中使用了一个 buf 数组来存储接收到的网络消息。在实际使用时,需要根据具体的需求和协议规范,对消息的格式和长度进行合理的控制和处理。
阅读全文