Помогите с сервером....

[lolbla2]

Спасибо, а что в методе run в потоке делать?

ничего. не перегружай поток, а используй стандартный QThread

спасибо вроде сделал, посмотри пожалуйста норм вышло?

replyer.h, replyer.cpp

Код

C++ (Qt)
#include <QObject>
#include <QtNetwork>
#include <QDebug>
 
class Replyer : public QObject
{
    Q_OBJECT
public:
    explicit Replyer(QObject *parent = 0);
 
private:
        QList<QTcpSocket*> mClients;
        void reply(QString message);
        QString text;
        int blockSize;
 
 
public slots:
        void newConnection(int descriptor);
        void newDisconnection(); //смешное  название получилось :)
 
private slots:
        void readData();
 
};
 
 
#include "replyer.h"
 
Replyer::Replyer(QObject *parent) :
    QObject(parent)
{
    blockSize = 0;
}
 
void Replyer::newConnection(int descriptor)
{
            QTcpSocket *client = new QTcpSocket(this);
            if(client->setSocketDescriptor(descriptor))
            {
                    connect(client, SIGNAL(readyRead()), SLOT(readData()));
                    connect(client,SIGNAL(disconnected()),SLOT(newDisconnection()));
                    mClients.append(client);
            }
            else
            {
                    client->deleteLater();
            }
}
void Replyer::newDisconnection()
{
 
    foreach(QTcpSocket *client, mClients)
    {
        if (client->state()!=QAbstractSocket::ConnectedState)
            {
               qDebug() << client->socketDescriptor() << " Client Disconnected";
               mClients.removeOne(client);
               client->deleteLater();
            }
    }
}
 
void Replyer::readData()
{
    QTcpSocket *client = qobject_cast<QTcpSocket*>(sender());
 
    QString message;
         while(client->bytesAvailable())
       {
           QDataStream in(client);
         in.setVersion(QDataStream::Qt_4_7);
 
         if (blockSize == 0) {
           if (client->bytesAvailable() < (int)sizeof(quint32))
               return;
         in >> blockSize;
       }
 
       if (client->bytesAvailable() < blockSize)
         return;
 
         in>>message;
        }
    blockSize = 0;
    text = message;
    qDebug() << message;
    reply(message);
}
 
void Replyer::reply(QString message)
{
    QByteArray block;
    QDataStream out(&block, QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_4_7);
    out << (quint32)0;
    out << message;
    out.device()->seek(0);
    out << (quint32)(block.size() - sizeof(quint32));
    foreach(QTcpSocket* client, mClients)
      {
          client->write(block);
      }
}
 

MyServerh, MyServer.cpp

Код

C++ (Qt)
#include <QtNetwork/QTcpServer>
#include <QDebug>
#include "replyer.h"
 
class MyServer : public QTcpServer
{
    Q_OBJECT
public:
    explicit MyServer(QObject *parent = 0);
    void StartServer();
protected:
    void incomingConnection(int socketDescriptor);
signals:
    void newClient(int socketDescriptor);
private:
    Replyer *replyer;
};
 
#include "myserver.h"
 
MyServer::MyServer(QObject *parent) :
    QTcpServer(parent)
{
    replyer = new Replyer();
    connect(this, SIGNAL(newClient(int)), replyer, SLOT(newConnection(int)));
    QThread *thread = new QThread(this);
    connect(thread,SIGNAL(finished()),thread,SLOT(deleteLater()));
    replyer->moveToThread(thread);
    thread->start();
}
 
void MyServer::incomingConnection(int socketDescriptor)
{
    qDebug() << socketDescriptor << " Client Connected";
    emit newClient(socketDescriptor);
}
 
void MyServer::StartServer()
{
    if(!this->listen(QHostAddress::Any,1234))
    {
        qDebug() << "Could not start server";
 
    }
    else
    {
        qDebug() << "Listening...";
    }
}
 

[mutineer]

вроде должно работать. вот только читаешь ты все куски данных в один массив, так что если несколько клиентов одновременно пришлют данные, то их данные тупо смешаются

[lolbla2]

вроде должно работать. вот только читаешь ты все куски данных в один массив, так что если несколько клиентов одновременно пришлют данные, то их данные тупо смешаются

Хмм... кстати я тоже об этом думал, но когда пытался быстро слать от 2 клиентов сообщения с разных компов, то вроде всё норм, но вроде бы потенциально может прийти клиентам какая-нибудь фигня смешанная. А как эту проблему пофиксить? Завести какую-то очередь сообщений что ли?

то есть клиент прислал сообщение его в очередь, а потом пока очередь не пуста отсылать эти сообщения клиентам, может так ?

[mutineer]

Да просто заведи на каждого клиента свой blockSize

[lolbla2]

Да просто заведи на каждого клиента свой blockSize

а идея с очередью не катит?)

[mutineer]

Да просто заведи на каждого клиента свой blockSize

а идея с очередью не катит?)

Не знаю, имхо излишне, хеша вида <сокет, blockSize> хватит с головой. Но можешь попробовать и очередь:)

[lolbla2]

Да просто заведи на каждого клиента свой blockSize

а идея с очередью не катит?)

Не знаю, имхо излишне, хеша вида <сокет, blockSize> хватит с головой. Но можешь попробовать и очередь:)

сделал очередь, но не знаю как проверить работает ли...

[mutineer]

И я не знаю. Это ж вероятная ситуация. Вызвать ее специально довольно сложно. проблема у тебя даже не в перемешивании данных, а в том, что blockSize ты прочитаешь из одного сокета, потом выйдешь из функции, а в следующий раз зайдешь уже когда сигнал будет от другого сокета и читать будешь уже не то, что ожидал

[demaker]

Но это только для 1-ого клиента