轮子七：TCP客户端

#ifndef TCPCMDCLIENT_H
#define TCPCMDCLIENT_H

#include <QObject>
#include <QTcpSocket>
#include "CustomFrameBuffer/CustomFrameBufferFor48s.h"

class TcpCmdClient : public QObject
{
    Q_OBJECT
public:
    explicit TcpCmdClient(QObject *parent = nullptr);
    ~TcpCmdClient();
    void setServerIpPort(QString strIp, quint16 port);
signals:
    //将接收到的Tcp数据透传给业务接口类
    void sig_TransferData(QByteArray ba);
public slots:
    void slot_InitSocket();
    void slot_onConnected();
    void slot_onDisconnected();
    void slot_recvData();
    //网络错误
    void slot_networkError(QAbstractSocket::SocketError err);
    void slot_sendData(QByteArray ba);
private:
    void connectTcpServer();
private:
    QTcpSocket *m_pClientSocket;//tcp客户端对象指针
    QString m_strServerIP;//tcp服务端ip
    quint16 m_uServerPort;//tcp服务端端口
    bool m_bConnect;//是否连接标识
    CustomFrameBufferFor48s m_FrameBuffer;
};

#endif // TCPCMDCLIENT_H

#include "TcpCmdClient.h"
#include "Player.h"

TcpCmdClient::TcpCmdClient(QObject *parent) : QObject(parent)
{
    m_bConnect = false;
    m_strServerIP = "";
    m_uServerPort = 0;
    m_pClientSocket = nullptr;
}


TcpCmdClient::~TcpCmdClient()
{
    if(m_pClientSocket)
    {
        m_pClientSocket->abort();
        m_pClientSocket->deleteLater();
    }
}

void TcpCmdClient::setServerIpPort(QString strIp, quint16 port)
{
    m_strServerIP = strIp;
    m_uServerPort = port;
}

void TcpCmdClient::connectTcpServer()
{
    if(nullptr==m_pClientSocket)
    {
        m_pClientSocket = new QTcpSocket;
        connect(m_pClientSocket,&QTcpSocket::readyRead,this,&TcpCmdClient::slot_recvData);
        connect(m_pClientSocket,&QTcpSocket::connected,this,&TcpCmdClient::slot_onConnected);
        connect(m_pClientSocket,&QTcpSocket::disconnected,this,&TcpCmdClient::slot_onDisconnected);
        connect(m_pClientSocket,SIGNAL(error(QAbstractSocket::SocketError)),this,SLOT(slot_networkError(QAbstractSocket::SocketError)));
    }
    m_pClientSocket->abort();

    //m_pClientSocket->setProxy(QNetworkProxy::NoProxy);
    m_pClientSocket->connectToHost(m_strServerIP,m_uServerPort);
    m_bConnect = m_pClientSocket->waitForConnected(5000);
    if(m_bConnect)
    {
        AddLog(QStringLiteral("连接tcp服务端成功"),QString("ip=%1 port=%2").arg(m_strServerIP).arg(m_uServerPort));
    }
    else
    {
        AddLog(QStringLiteral("连接tcp服务端失败"),QString("ip=%1 port=%2").arg(m_strServerIP).arg(m_uServerPort));
    }
}

void TcpCmdClient::slot_InitSocket()
{
    connectTcpServer();
}

void TcpCmdClient::slot_onConnected()
{
    m_bConnect = true;
}

void TcpCmdClient::slot_onDisconnected()
{
    m_bConnect = false;
    AddLog(QStringLiteral("连接tcp服务端断开"),"");
}

void TcpCmdClient::slot_networkError(QAbstractSocket::SocketError err)
{
    AddLog(QStringLiteral("连接tcp服务端发生错误"),QString("err = %1").arg(err));
}

void TcpCmdClient::slot_recvData()
{
    while((m_pClientSocket->bytesAvailable())>0)
    {
        QByteArray readmsg = m_pClientSocket->readAll();
        //qDebug()<<readmsg.size();
        m_FrameBuffer.Write(readmsg.data(),readmsg.size());
        QByteArray baFrame;

        while(1){
            int ret = m_FrameBuffer.GetFrame(baFrame);
            if(ret == 1){
                //将完整一帧发送给businessIf解析处理
                emit sig_TransferData(baFrame);

                //qDebug() << "m_FrameBuffer.GetFrame is complete.";
            }else{
                //qDebug() << "m_FrameBuffer.GetFrame is not complete.";
                break;
            }
        }
    }
}

void TcpCmdClient::slot_sendData(QByteArray ba)
{
    if(m_bConnect)
    {
        m_pClientSocket->write(ba.data(),ba.size());
    }
}