Russian Qt Forum

void ClientSocket::slotSendData_pod(QByteArray arr)
{
    int sz=0;
    if(socket_out->state()!=QAbstractSocket::ConnectedState)
        return;

      sz=socket_out->write(arr);

    if(sz!=arr.size())
    {
        qDebug()<<"SV_P: not all information writes to protocol";
    }
}

{
    QTcpSocket  *socket_in=(QTcpSocket *)sender();
    QByteArray arrData;
    arrData.resize(0);
    QDataStream in(socket_in);
    in.setVersion(QDataStream::Qt_4_2);
    quint64 NextBlockSize=0;
    for(;;)
    {
        if(!NextBlockSize)
        {
            if((unsigned)socket_in->bytesAvailable()<sizeof(quint16))
                break;
            NextBlockSize=socket_in->bytesAvailable();
        }
        if((unsigned)socket_in->bytesAvailable()<=NextBlockSize)
            break;
    }
        arrData= socket_in->read(NextBlockSize);

        if(arrData.size()>1)
        {
            QString pak=(QString)(arrData);
            QStringList Lst=pak.split(packetSeparator);
            qDebug()<<"IN"<<Lst;
....
}

tripserver.h

#ifndef TRIPSERVER_H
#define TRIPSERVER_H


#include <QTcpServer>
#include <QTcpSocket>
#include <QApplication>

#include "clientsocket.h"
#include "common_gs.h"

#define port_pod 1111
//#define port_out_pod 1112

class QTcpServer;
class QTcpSocket;

class TripServer :  public QTcpServer

{
    Q_OBJECT

public:
    TripServer(QObject *parent = 0 );
     QTcpSocket   *socket_pod;
     QTcpSocket   *socket_2d_8d;
     QTcpSocket   *socket_sord_16KP;
     QTcpSocket   *socket_sord_toACHVO;
     QTcpSocket   *socket_sord_fromACHVO;
     ClientSocket *soc;

  signals:
     void sendData_pod();
     void sendData_sord();
     void sendData_2d_8d();
     void sendData_16KP(QString);
     void OTMData(int,int);
     void SignalRezim16KP(unsigned short,unsigned short);
     void BufferForSend(QByteArray);
     void IzzlOn(QByteArray);
public slots:
     void slotDisconnected_pod();
     void slotDisconnected_2d_8d();
     void slotDisconnected_16KP();
     void slotDisconnected_toACHVO();
     void slotDisconnected_fromACHVO();


private:
    void incomingConnection(int socketId);

tripserver.cpp


#include "tripserver.h"
TripServer::TripServer(QObject *parent)
    : QTcpServer(parent)
{
   soc=new ClientSocket(this);
   socket_pod=new QTcpSocket(this);
   socket_2d_8d= new QTcpSocket(this);
   socket_sord_16KP= new QTcpSocket(this);
   socket_sord_toACHVO= new QTcpSocket(this);
   socket_sord_fromACHVO= new QTcpSocket(this);
}

void TripServer::incomingConnection(int socketId)
{
    qDebug()<<this->serverPort();
   if( this->serverPort()==port_pod)// обмен СЃ "Подыгрышем РЎРІСЏР·Рё"
   {
        socket_pod->setSocketDescriptor(socketId);
        if(socket_pod)
        {
          soc->socket_out=socket_pod;
          connect(socket_pod,SIGNAL(readyRead()),soc,SLOT(readClient()));
          connect(socket_pod,SIGNAL(disconnected()),this,SLOT(slotDisconnected_pod()));
        }
   }

   if(this->serverPort()==_PORT_2D_8D)//обмен СЃ РЎРћР Р” РїРѕ протоколу 2Р”-8Р” РїСЂРёР±РѕСЂРѕРІ
   {
       socket_2d_8d->setSocketDescriptor(socketId);
       if(socket_2d_8d)
       {
            soc->socket_out=socket_2d_8d;
            connect(socket_2d_8d,SIGNAL(disconnected()),this,SLOT(slotDisconnected_2d_8d()));
            connect(this,SIGNAL(sendData_2d_8d()),soc,SLOT(slotsendData_2d_8d()));
            connect(socket_2d_8d,SIGNAL(readyRead()),soc,SLOT(readClientSord_2d_8d()));
            connect(soc,SIGNAL(SendData_2d_8d()),soc,SLOT(slotsendData_2d_8d()));
            connect(soc,SIGNAL(Radiation_on(QByteArray)),this,SIGNAL(IzzlOn(QByteArray)));
       }
   }
   if(this->serverPort()==_PORT_16KP) //обмен СЃ РЎРћР Р” РїРѕ протоколу 16РљРџ РїСЂРёР±РѕСЂР°
   {
       socket_sord_16KP->setSocketDescriptor(socketId);
       if(socket_sord_16KP)
       {
           soc->socket_out=socket_sord_16KP;
           connect(socket_sord_16KP,SIGNAL(disconnected()),this,SLOT(slotDisconnected_16KP()));
           connect(socket_sord_16KP,SIGNAL(readyRead()),soc,SLOT(readClientSord_16KP()));
           connect(soc,SIGNAL(SignalRezim(unsigned short,unsigned short)),this,SIGNAL(SignalRezim16KP(unsigned short,unsigned short)));
           connect(soc,SIGNAL(SignBufferForSend(QByteArray)),this,SIGNAL(BufferForSend(QByteArray)));
       }
   }
   if(this->serverPort()==_PORT_FROM_ACHVO) // обмен СЃ РЎРћР Р” РїРѕ протоколу АЧВО(отправка данных РІ АЧВО)
   {
       socket_sord_toACHVO->setSocketDescriptor(socketId);
       if(socket_sord_toACHVO)
       {
           soc->socket_out=socket_sord_toACHVO;
           connect(socket_sord_toACHVO,SIGNAL(disconnected()),this,SLOT(slotDisconnected_toACHVO()));
       }
   }
   if(this->serverPort()==_PORT_TO_ACHVO) // обмен СЃ РЎРћР Р” РїРѕ протоколу АЧВО(прием данных РѕС‚ АЧВО)
   {
       socket_sord_fromACHVO->setSocketDescriptor(socketId);
       if(socket_sord_fromACHVO)
       {
           soc->socket_out=socket_sord_fromACHVO;
           connect(socket_sord_fromACHVO,SIGNAL(disconnected()),this,SLOT(slotDisconnected_fromACHVO()));
           bool nn=connect(socket_sord_fromACHVO,SIGNAL(readyRead()),soc,SLOT(readClientSord_Achvo()));
           qDebug()<<"nn"<<nn;
       }
   }

}

void TripServer::slotDisconnected_pod()
{
    if(socket_pod)
       {
            socket_pod->disconnectFromHost();
            disconnect(socket_pod,SIGNAL(readyRead()),soc,SLOT(readClient()));
            disconnect(socket_pod,SIGNAL(disconnected()),this,SLOT(slotDisconnected_pod()));
            //disconnect(this,SIGNAL(sendData_pod()),soc,SLOT(slotsendData_pod()));
       }
}
void TripServer::slotDisconnected_2d_8d()
{
    if(socket_2d_8d)
    {
        socket_2d_8d->disconnectFromHost();
        disconnect(this,SIGNAL(sendData_2d_8d()),soc,SLOT(slotsendData_2d_8d()));
        disconnect(socket_2d_8d,SIGNAL(disconnected()),this,SLOT(slotDisconnected_2d_8d()));
        disconnect(socket_2d_8d,SIGNAL(readyRead()),soc,SLOT(readClientSord_2d_8d()));
        disconnect(soc,SIGNAL(SendData_2d_8d()),soc,SLOT(slotsendData_2d_8d()));
    }
}
void TripServer::slotDisconnected_16KP()
{
    if(socket_sord_16KP)
    {
        disconnect(socket_sord_16KP,SIGNAL(disconnected()),this,SLOT(slotDisconnected_16KP()));
        disconnect(socket_sord_16KP,SIGNAL(readyRead()),soc,SLOT(readClientSord_16KP()));
    }
}
void TripServer::slotDisconnected_toACHVO()
{
    if(socket_sord_toACHVO)
    {
       disconnect(socket_sord_toACHVO,SIGNAL(disconnected()),this,SLOT(slotDisconnected_toACHVO()));
    }
}
void TripServer::slotDisconnected_fromACHVO()
{
    if(socket_sord_fromACHVO)
    {
        disconnect(socket_sord_fromACHVO,SIGNAL(disconnected()),this,SLOT(slotDisconnected_fromACHVO()));
        disconnect(socket_sord_fromACHVO,SIGNAL(readyRead()),soc,SLOT(readClientSord_Achvo()));
    }
}

 serv=new TripServer(this);
    servSord_2d_8d=new TripServer(this);
    serverSord_16KP= new TripServer(this);
    serverSord_toAchvo=new TripServer(this);
    serverSord_fromAchvo=new TripServer(this);
    qDebug()<<"PORT_client_16KP"<<PORT_client_16KP;
    serv->listen(QHostAddress::Any,PORT_client_16KP);
    servSord_2d_8d->listen(QHostAddress::Any,_PORT_2D_8D);
    serverSord_16KP->listen(QHostAddress::Any,_PORT_16KP);
    serverSord_toAchvo->listen(QHostAddress::Any,_PORT_TO_ACHVO);
    serverSord_fromAchvo->listen(QHostAddress::Any,_PORT_FROM_ACHVO);

    //связь сигналов по пришедшим из теста данным с обработкой инф-и
    connect(serv->soc,SIGNAL(Sign_Sinhr(QString,QString,QString,QString,QString)),this,SLOT(slotATGS_Sinhr(QString,QString,QString,QString,QString)));
    connect(serv->soc,SIGNAL(Sign_NT()),this,SLOT(slotATGS_NT()));
    connect(serv->soc,SIGNAL(Sign_TLG(QString)),this,SLOT(slotATGS_TLG(QString)));
    connect(serv->soc,SIGNAL(Sign_KT()),this,SLOT(slotATGS_KT()));
    connect(serv->soc,SIGNAL(Sign_Pilot(QString,QString,QString)),this,SLOT(slotPilot(QString,QString,QString)));
    connect(serv->soc,SIGNAL(Sign_KK(QString)),this,SLOT(slotKK(QString)));
    connect(serv->soc,SIGNAL(Sign_SR()),this,SLOT(slotSR()));
............

#include <QtNetwork>
#include "clientsocket.h"

QString packetSeparator="|";
unsigned char numb_packet=0;
float oldPeriod=0.f;

QFile fp("1.txt");
QByteArray str_send;
ClientSocket::ClientSocket(QObject *parent)
    : QTcpSocket(parent)
{
    flag_write_data=true;
    nextBlockSize = 0;
    socket_out=new QTcpSocket(this);
    head.resize(4);
    head[0]=0xe0;
    head[1]=0xe3;
    head[2]=0xe5;
    head[3]=0xe7;
    count_packet_to16KP=0;
}

void ClientSocket::readClient() 
{
    QTcpSocket  *socket_in=(QTcpSocket *)sender();
    QByteArray arrData;
    arrData.resize(0);
    QDataStream in(socket_in);
    in.setVersion(QDataStream::Qt_4_2);
    quint64 NextBlockSize=0;
    for(;;)
    {
        if(!NextBlockSize)
        {
            if((unsigned)socket_in->bytesAvailable()<sizeof(quint16))
                break;
            NextBlockSize=socket_in->bytesAvailable();
        }
        if((unsigned)socket_in->bytesAvailable()<=NextBlockSize)
            break;
    }
        arrData= socket_in->read(NextBlockSize);
        qDebug()<<"arrData"<<arrData;
        if(arrData.size()>=1)
        {
            QString pak=(QString)(arrData);
            qDebug()<<"arrData"<<arrData;
            QStringList List=pak.split(packetSeparator);
           ......
}
void ClientSocket::slotSendData_pod(QByteArray arr)
{
    int sz=0;
    if(socket_out->state()!=QAbstractSocket::ConnectedState)
        return;

      sz=socket_out->write(arr);
      socket_out->flush();

    if(sz!=arr.size())
    {
        qDebug()<<"SV_P: not all information writes to protocol";
    }
}



void ClientSocket::readClientSord_2d_8d()
{

    QTcpSocket  *socket_in=(QTcpSocket *)sender();
    QByteArray arrData;
    QDataStream in(socket_in);
    in.setVersion(QDataStream::Qt_4_2);
    quint64 NextBlockSize=0;
    NextBlockSize=socket_in->bytesAvailable();
    while(NextBlockSize>0)
    {
       arrData.append(socket_in->readAll());
       NextBlockSize=socket_in->bytesAvailable();
    }
    qDebug()<<"IN_Data_2D_8D"<<arrData;
   
    QString pak=(QString)(arrData);
    QStringList lst=pak.split('*');
    if(lst.size()>0)
         packetFrom2d_8d(lst);
}

ExchangeConnection::ExchangeConnection(QObject *parent) :
    QObject(parent)
{
 tcpServer = new QTcpServer(this);
    connect(tcpServer,SIGNAL(newConnection()),this,SLOT(slot_new_connection()));
}
void ExchangeConnection::slot_new_connection()
{
    tcpClient = tcpServer->nextPendingConnection();
    connect(tcpClient,SIGNAL(disconnected()),this,SLOT(slot_disconnect()));
    connect(tcpClient,SIGNAL(readyRead()),this,SLOT(on_readyRead()));
}
void ExchangeConnection::slot_disconnect()
{
    tcpClient->deleteLater();
}
void ExchangeConnection::on_readyRead()
{
    if(!tcpClient)
        return;
    QByteArray arrData;
    QDataStream in(tcpClient);
    in.setVersion(QDataStream::Qt_4_2);
    quint64 NextBlockSize=0;
    NextBlockSize=socket_in->bytesAvailable();
// вопрос про правильность организации чтения????????
    while(NextBlockSize>0)
    {
       arrData.append(tcpClient->readAll());
       NextBlockSize=tcpClient>bytesAvailable();
    }

}