Russian Qt Forum

#ifndef SERVERCLIENT_H
#define SERVERCLIENT_H

#include <QtGui>
class QTcpServer;
class QTcpSocket;

class Widget :public QWidget{
    Q_OBJECT
    public:
    QPushButton* connection;
    QPushButton* opendir;
    QPushButton* send;
    QLabel* label_port;
    QLabel* label_answer;
    QLineEdit* IP;
    QLineEdit* Port;
    QLineEdit* letter;
    QTcpServer* TcpServer;
    QTcpSocket* TcpSocket;
    quint16 blockSize;
    Widget();
    public slots:
              void connection_clicked();
              void send_clicked();
              void opendir_clicked();
      virtual void slotNewConnection();
              void slotReadAnswer();
              void sendAnswerToClient(QString& str);
   protected:
            void send_letter_to_client();
};




#endif // SERVERCLIENT_H

#include "server-client.h"
#include <QDebug>
#include <QFileDialog>
#include <QtNetwork>


Widget::Widget(){
    // кнопка соединения
    connection = new QPushButton(QString("connection"),this);
    QObject::connect(connection,SIGNAL(clicked()),SLOT(connection_clicked()));
    // кнопка отпраки данных
    send = new QPushButton(QString("send"),this);
    QObject::connect(send,SIGNAL(clicked()),SLOT(send_clicked()));
    // кнопка выбора файла
    opendir = new QPushButton(QString("open dir"),this);
    QObject::connect(opendir,SIGNAL(clicked()),SLOT(opendir_clicked()));
    // Label port
    label_port = new QLabel(this);
    label_port->setText("Current Port");
    // Label answer
    label_answer = new QLabel(this);
    label_answer->setText(QString::fromLocal8Bit("Ждём ответа..."));
    // IP
    IP = new QLineEdit(this);
    IP->setText("IP");
    // Port
    Port = new QLineEdit(this);
    Port->setText("Port");
    // Letter
    letter = new QLineEdit(this);
    letter->setText("Enter message");
    // размещение виджетов
    QGridLayout *Layout = new QGridLayout;
    Layout->addWidget(IP,0,0);
    Layout->addWidget(Port,1,0);
    Layout->addWidget(letter,2,0);
    Layout->addWidget(label_port,3,0);
    Layout->addWidget(label_answer,4,0);
    Layout->addWidget(connection,0,1);
    Layout->addWidget(send,1,1);
    Layout->addWidget(opendir,2,1);
    setLayout(Layout);
}


void Widget::connection_clicked(){  //настраиваем сервер на слушание каналов
  TcpServer = new QTcpServer(this);
    if (!TcpServer->listen(QHostAddress::Any,1115)) {
        QMessageBox::critical(this, tr("Server"),
                              tr("Unable to start the server: %1.")
                              .arg(TcpServer->errorString()));
        close();
        return;
    }
    label_port->setText(tr("port %1.\n").arg(TcpServer->serverPort()));  // Выводим порт сервера, если сервер прослушивает соединения, в противном случае выведется 0.
    QObject::connect(TcpServer,SIGNAL(newConnection()),SLOT(slotNewConnection())); // устанавливаем соединение с новым клиентом,который подключился
}

void Widget::send_clicked(){
    TcpSocket = new QTcpSocket(this);
    blockSize = 0;
    TcpSocket->connectToHost(IP->text(),1115);
    send_letter_to_client();
    QObject::connect(TcpSocket, SIGNAL(readyRead()), this, SLOT(slotReadAnswer()));  // читаем ответ сервера
   // посылаем клиенту сообщение
}

void Widget::opendir_clicked(){
  QFileDialog d;
  QString dir_name = d.getExistingDirectory();
}

void Widget::slotNewConnection(){  // создание нового соединения с очередным клиентом
  QString answer="Connected!!!";
  TcpSocket = TcpServer->nextPendingConnection();
  QObject::connect(TcpSocket,SIGNAL(disconnected()),TcpSocket,SLOT(deleteLater()));
  // читаем сообщение клиента,если он что-то нам сообщает
  QObject::connect(TcpSocket, SIGNAL(readyRead()),this,SLOT(slotReadAnswer()));
  sendAnswerToClient(answer);  // отсылаем ответ клиенту
}

void Widget::sendAnswerToClient(QString &str){ // отсылаем сообщение очередному клиенту об успешном соединении
    QByteArray block;
    QDataStream out(&block, QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_4_0);
    out << (quint16)0;
    out << str;
    out.device()->seek(0);
    out << (quint16)(block.size() - sizeof(quint16));
    TcpSocket->write(block);
}

void Widget::slotReadAnswer(){
    TcpSocket = (QTcpSocket*)sender();
    QString str;
    QDataStream in(TcpSocket);
    in.setVersion(QDataStream::Qt_4_5);
    for (;;) {
        if (!blockSize) {
            if (TcpSocket->bytesAvailable() < sizeof(quint16)) {
                break;
            }
            in >> blockSize;
        }

        if (TcpSocket->bytesAvailable() < blockSize) {
            break;
        }
        in >> str;
        blockSize = 0;

    }
  label_answer->setText(str);
}

void Widget::send_letter_to_client(){
    TcpSocket = new QTcpSocket(this);
    QString str;
    str = letter->text();
    QByteArray block;
    QDataStream out(&block, QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_4_0);
    out << (quint16)0;
    out << str;
    out.device()->seek(0);
    out << (quint16)(block.size() - sizeof(quint16));
    TcpSocket->write(block);
}

for (;;) {
        if (!blockSize) {
            if (TcpSocket->bytesAvailable() < sizeof(quint16)) {
                break;
            }
            in >> blockSize;
        }

        if (TcpSocket->bytesAvailable() < blockSize) {
            break;
        }
        in >> str;
        blockSize = 0;
    }