Russian Qt Forum

#ifndef MAINWINDOW_H
#define MAINWINDOW_H

#include <QtGui/QMainWindow>
#include <QTcpServer>
#include <QTcpSocket>
#include <QBuffer>
#include <QMessageBox>

namespace Ui
{
    class MainWindowClass;
}

class MainWindow : public QMainWindow
{
    Q_OBJECT
protected:
        void sendToClients(const QByteArray& line);
public:
    MainWindow(QWidget *parent = 0);
    ~MainWindow();

private:
    Ui::MainWindowClass *ui;
    QTcpServer *server;
    QList<QTcpSocket*> connections;
    QHash<QTcpSocket*, QBuffer*> buffers;
    QTcpSocket *serverSocket;
    QTcpServer *tcpServer;
    QStringList tmpClientAddressPort;
    QMap<QString, quint16> adr;
private slots:
    void on_pushButton_3_clicked();
    void slotStartClicked();
    void slotStopClicked();
    void slotNewClient();
    void slotClientDisconnected();
    void slotSocketRead();
};

#endif // MAINWINDOW_H 

#include "mainwindow.h"
#include "ui_mainwindow.h"
#include <QBuffer>

MainWindow::MainWindow(QWidget *parent)
    : QMainWindow(parent), ui(new Ui::MainWindowClass)
{
    ui->setupUi(this);
    tcpServer = new QTcpServer(this);
    serverSocket = new QTcpSocket(this);
    connect(ui->pushButton, SIGNAL(clicked()), this, SLOT(slotStartClicked()));
    connect(ui->pushButton_2, SIGNAL(clicked()), this, SLOT(slotStopClicked()));
    connect(tcpServer, SIGNAL(newConnection()), this, SLOT(slotNewClient()));
    QRegExp regExp("[1-9][0-9]{0,4}");
    ui->lineEdit->setValidator(new QRegExpValidator(regExp, this));
    if (!tcpServer->listen(QHostAddress::Any, 1234)) {
        QMessageBox::critical(this, tr("Server"), tr("Unable to start the server: %1.").arg(tcpServer->errorString()));
        return;
    }
}

MainWindow::~MainWindow()
{
    delete ui;
}

void MainWindow::sendToClients(const QByteArray& line)
{
        foreach (QTcpSocket* connection, connections)
        {
                connection->write(line);
        }
}

void MainWindow::slotStartClicked()
{
        ui->label->setText(tr("Server starting"));
        if (ui->lineEdit->text() == "")
        {
                QMessageBox::critical(this, tr("Server"), tr("Please enter a valid port number"));
                return;
        }
        if (ui->lineEdit->text().toInt() > 65535)
        {
                ui->lineEdit->setText("65535");
        }

    if (!tcpServer->listen(QHostAddress::Any, ui->lineEdit->text().toInt())) {
        QMessageBox::critical(this, tr("Server"), tr("Unable to start the server: %1.").arg(tcpServer->errorString()));
        return;
    }
        ui->pushButton->setDisabled(true);
        ui->pushButton_2->setDisabled(false);
        ui->lineEdit->setDisabled(true);
        ui->label->setText(tr("Server started at port %1").arg(tcpServer->serverPort()));
}

void MainWindow::slotStopClicked()
{
        ui->pushButton->setEnabled(true);
        ui->pushButton_2->setEnabled(false);
        ui->lineEdit->setDisabled(false);

        if (tcpServer->isListening())
        {
                tcpServer->close();
        }

        if (!connections.isEmpty())
        {
                foreach (QTcpSocket* connection, connections)
                {
                                connection->close();
                }
                connections.clear();
        }

        if (serverSocket->isValid())
        {
                serverSocket->close();
        }
        ui->label->setText(tr("Server stopped"));
}

void MainWindow::slotNewClient()
{
        if (!connections.isEmpty())
        {
                QByteArray msg = "New Client connected";
                foreach (QTcpSocket* connection, connections)
                {
                                connection->write(msg);
                }
        }
        serverSocket = tcpServer->nextPendingConnection();
        QString str_buf;
        //tmpClientAddressPort << tr("%1").arg(serverSocket->peerAddress().toString()) << tr("%1").arg(serverSocket->peerPort());
        tmpClientAddressPort << tr("%1").arg(serverSocket->peerPort());
        str_buf = tr("%1").arg(serverSocket->peerPort());
        ui->label->setNum(serverSocket->socketDescriptor());
        ui->listWidget->addItem(ui->label->text());
        connections.append(serverSocket);

        QBuffer* buffer = new QBuffer(this);
        ui->label->setText(serverSocket->peerAddress().toString());
        buffer->open(QIODevice::ReadWrite);
        buffers.insert(serverSocket, buffer); 
        connect(serverSocket, SIGNAL(disconnected()), this, SLOT(slotClientDisconnected()));
        connect(serverSocket, SIGNAL(readyRead()), this, SLOT(slotSocketRead()));

}

void MainWindow::slotClientDisconnected()
{
        ui->label->setText("Client disconnected");
        QTcpSocket* socket = static_cast<QTcpSocket*>(sender());
        QBuffer* buffer = buffers.take(socket);
        buffer->close();
        buffer->deleteLater();
        connections.removeAll(socket);
        socket->deleteLater();

        QByteArray msg = "Client disconnected";
        foreach (QTcpSocket* connection, connections)
        {
                connection->write(msg);
        }
}

void MainWindow::slotSocketRead()
{
 QTcpSocket* socket = static_cast<QTcpSocket*>(sender());
 QBuffer* buffer = buffers.value(socket);
 ui->label->setText("readyread");
 qint64 bytes = buffer->write(socket->readAll());
 buffer->seek(buffer->pos() - bytes);
 QByteArray line = buffer->readAll();
 ui->textEdit->append(line);
 sendToClients(line);
}

void MainWindow::on_pushButton_3_clicked()
{
    QByteArray ba3;
    ba3.append(ui->lineEdit_2->text());
    foreach (QTcpSocket* connection, connections)
    {
        if (connection->socketDescriptor() == ui->listWidget->item(ui->listWidget->currentRow())->text().toInt())
            connection->write(ba3);
    }
}

void MainWindow::slotStartClicked()
{
...
        ui->pushButton->setDisabled(true);
        ui->pushButton_2->setDisabled(false);
        ui->lineEdit->setDisabled(true);
...
}

void MainWindow::slotStopClicked()
{
        ui->pushButton->setEnabled(true);
        ui->pushButton_2->setEnabled(false);
        ui->lineEdit->setDisabled(false);

He
Hell
Hello
Hello W
Hello World