1. 可配置是否启用FMSOCKETHEADER。

fmp_vip_server.cpp

@@ -17,6 +17,7 @@ FMPVipServer::FMPVipServer() :
 {
     Listen(23770);
     connect(this, &QTcpServer::newConnection, this, &FMPVipServer::onNewConnection);
+    isNeedSocketHeader = FMPVipSettings::instance()->getIsNeedSocketHeader();
 }
 
 void FMPVipServer::Listen(quint16 port)
@@ -56,10 +57,19 @@ void FMPVipServer::onReadyRead()
 {
     QByteArray recvData = socket->readAll();
 
+    if(isNeedSocketHeader) {
+        FMSOCKEHEADER header = {0};
+        memcpy(&header, recvData.data(), sizeof(FMSOCKEHEADER));
+        if(header.flag != FMSOCKFLAG) {
+            FMP_WARN() << "Incompatible protocol.";
+            return;
+        }
+        recvData = recvData.mid(sizeof(FMSOCKEHEADER));
+    }
+
     QByteArray rspData;
     dispatcher->doTask(recvData, rspData);
 
-    rspData;
     Write(rspData);
 
     socket->waitForBytesWritten();

fmp_vip_server.h

@@ -34,6 +34,8 @@ private:
 
     QTcpSocket *socket;
     FMVipDispatcher *dispatcher;
+
+    bool isNeedSocketHeader;
 };
 
 #endif // FMP_VIP_SERVER_H

fmp_vip_settings.cpp

@@ -22,6 +22,11 @@ QString FMPVipSettings::getServerUrl()
     return _GetValue(FMP_INIKEY_VIPSERVER).toString();
 }
 
+bool FMPVipSettings::getIsNeedSocketHeader()
+{
+    return _GetValue(FMP_INIKEY_NEEDSOCKETHEADER, false).toBool();
+}
+
 QVariant FMPVipSettings::_GetValue(const QString &key, QVariant defaultValue)
 {
     if (_settings) {

fmp_vip_settings.h

@@ -15,6 +15,7 @@ public:
     void init(FMPSettingsInterface *settings);
 
     QString getServerUrl();
+    bool getIsNeedSocketHeader();
 
 private:
     explicit FMPVipSettings(QObject *parent = 0);