肚子里有料 异步socket

fmp_vip_server.cpp

@@ -59,11 +59,54 @@ void FMPVipServer::onReadyRead()
     QByteArray rspData;
     dispatcher->doTask(recvData, rspData);
 
+    if(socket->isValid()){
         rspData;
         Write(rspData);
-
+    }
+    else{
+        //向23771发送数据
+        SendToMonitor(rspData);
+    }
     socket->waitForDisconnected();
 
     socket->deleteLater();
     socket = nullptr;
+
+}
+
+void FMPVipServer::SendToMonitor(const QByteArray &data)
+{
+    QTcpSocket client;
+
+    int jsonLength=data.length();
+    char* m_pFmPackage = new char[jsonLength + sizeof(FMSOCKEHEADER)];
+    FMSOCKEHEADER header = { 0, 0, 0 };
+    header.flag = 0x4d46;
+    header.len = jsonLength;
+    header.ver = 0x1;
+
+    memcpy(m_pFmPackage, &header, sizeof(FMSOCKEHEADER));
+    memcpy(m_pFmPackage+sizeof(FMSOCKEHEADER), data, jsonLength);
+
+
+    int toSendLength = jsonLength + sizeof(FMSOCKEHEADER);
+    int curSendLength = 0;
+
+    client.connectToHost("127.0.0.1", 23771);
+    if (client.waitForConnected()){
+        while(curSendLength < toSendLength)
+        {
+            int rlt= client.write(m_pFmPackage+curSendLength,toSendLength - curSendLength);
+            client.waitForBytesWritten();
+            if(rlt==-1){
+                FMP_DEBUG() << "发送数据失败：" << data;
+                break;
+            }
+            curSendLength += rlt;
+        }
+    }
+    else{
+        FMP_DEBUG() << "socket 连接失败！";
+    }
+    client.close();
 }

fmp_vip_server.h

@@ -28,7 +28,7 @@ private slots:
     void onNewConnection();
     void onDisconnected();
     void onReadyRead();
-
+    void SendToMonitor(const QByteArray &data);
 private:
     explicit FMPVipServer();