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

[fuCtor]

А может посмотреть на существующие решения в плане организации межпроцессного общения и соответствующим протоколам?
Либо сервер должен в само приложения встраиваться наряду с клиентом?

Можно ссылки по этому поводу пожалуйста...?

Не совсем понял вопрос. Клиент отдельно, сервер отдельно. Сервер принимает данные от какой-нибудь клиента и отсылает их всем клиентам. То есть он нужен чтобы разослать данные от каждого клиента каждому клиенту, т.е. для взаимодействия клиентов каждый с каждым.

Если сервер отдельно, то гораздо проще. На вскидку:

• protobuf
• CORBA (тот еще монстр конечно)
• Thrift
• AMQP и один из серверов его поддерживающих (RabbitMQ, QPID, ZeroMQ)

ИМХО рекомендовал бы присмотреться к последнему варианту, производительность у этого решения более чем достаточная, позволяет очень гибкие схемы обмена данными делать. Есть обертки для интеграции в Qt окружение для некоторых из них.

Пример описывающие идеологию AMQP можно посмотреть тут: http://www.rabbitmq.com/getstarted.html и тут http://www.rabbitmq.com/tutorials/amqp-concepts.html

[lolbla2]

Ну например можно мувнуть сокет в нужный тред. Или создать его прям в нужном треде

ну и еще - тред у тебя не умрет никогда, а на каждую новую порцию данных будет создан новый

Имеешь в виду для каждого сокета отдельный поток что ли? Типо сокет подключился, создали для него поток... Я то хотел один поток для передачи всем сокетам (клиентам), поэтому в поток передаю список клиентов.  Кстати почему-то лист клиентов нельзя мувнуть в поток... почему? Чот я до конца не пойму, это получается поток может использовать только объекты созданные внутри него или как ?

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

вот это  QList <QTcpSocket *> clients как moveToThread сделать? по одному только что ли мувать?

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

[mutineer]

да, только по одному.
Вот тебе идея - создаешь объект, умеющий работать с сокетами. создаешь тред. муваешь этот объект в тред. в методе void MyServer::incomingConnection(int socketDescriptor) сигналом передаешь этому объекту socketDescriptor. Объект принимает дескриптор и создает для него сокет. А дальше объект вычитывает данные из сокетов, и отправляет через них же ответы клиентам

[lolbla2]

да, только по одному.
Вот тебе идея - создаешь объект, умеющий работать с сокетами. создаешь тред. муваешь этот объект в тред. в методе void MyServer::incomingConnection(int socketDescriptor) сигналом передаешь этому объекту socketDescriptor. Объект принимает дескриптор и создает для него сокет. А дальше объект вычитывает данные из сокетов, и отправляет через них же ответы клиентам

объект, умеющий работать с сокетами - сервер что ли, тобишь объект от него наследованный?

[mutineer]

объект, умеющий работать с сокетами - сервер что ли, тобишь объект от него наследованный?

Нет, просто наследник QObject с нужными методами и слотами (для приема данных от сокета, для отправки данных через сокет)

[lolbla2]

объект, умеющий работать с сокетами - сервер что ли, тобишь объект от него наследованный?

Нет, просто наследник QObject с нужными методами и слотами (для приема данных от сокета, для отправки данных через сокет)

Извини за тугодумство  , но чот я не догнал зачем QObject здесь? можно насчёт этого попдробнее с примерчиком кода?)_)

[mutineer]

QObject тут для того, чтобы у объекта были сигналы и слоты. Иначе как с ним общаться из другого треда?

[lolbla2]

QObject тут для того, чтобы у объекта были сигналы и слоты. Иначе как с ним общаться из другого треда?

ну сокет же сам как объект, да и тред тоже объект

[mutineer]

QObject тут для того, чтобы у объекта были сигналы и слоты. Иначе как с ним общаться из другого треда?

ну сокет же сам как объект, да и тред тоже объект

Блин, ну не нравится - делай по-своему, я же не заставляю

[lolbla2]

QObject тут для того, чтобы у объекта были сигналы и слоты. Иначе как с ним общаться из другого треда?

ну сокет же сам как объект, да и тред тоже объект

Блин, ну не нравится - делай по-своему, я же не заставляю

я просто примерчик прошу чтобы понятнее было

[mutineer]

Код

C++ (Qt)
class Replyer: public QObject
{
	Q_OBJECT
public:
	Replyer(QObject *parent = 0) :QObject(parent) {}
 
private:
	QList<QTcpSocket*> mClients;
	void reply(QString message);
 
public slots:
	void newConnection(int descriptor);
 
private slots:
	void readData();
};
 
void Replyer::newConnection(int descriptor)
{
	QTcpSocket *client = new QTcpSocket(this);
	if(client->setSocketDescriptor(descriptor))
	{
		connect(client, SIGNAL(readyRead()), SLOT(readData()));
		mClients.append(client);
	}
	else
	{
		client->deleteLater();
	}
}
 
void Replyer::readData()
{
	QTcpSocket *client = qobject_cast<QTcpSocket*>(sender());
	if(client)
	{
		//read data from socket
		reply(...);
	}
}
 
void Replyer::reply(QString message)
{
	foreach(QTcpSocket* client, mClients)
	{
		//send data to clients
	}
}

вот приблизительно так я вижу класс, который будет жить в потоке. Удаление сокетов при отключении добавь по вкусу))

Писал не компилируя, могуть быть синтаксические ошибки

[lolbla2]

Код

C++ (Qt)
class Replyer: public QObject
{
	Q_OBJECT
public:
	Replyer(QObject *parent = 0) :QObject(parent) {}
 
private:
	QList<QTcpSocket*> mClients;
	void reply(QString message);
 
public slots:
	void newConnection(int descriptor);
 
private slots:
	void readData();
};
 
void Replyer::newConnection(int descriptor)
{
	QTcpSocket *client = new QTcpSocket(this);
	if(client->setSocketDescriptor(descriptor))
	{
		connect(client, SIGNAL(readyRead()), SLOT(readData()));
		mClients.append(client);
	}
	else
	{
		client->deleteLater();
	}
}
 
void Replyer::readData()
{
	QTcpSocket *client = qobject_cast<QTcpSocket*>(sender());
	if(client)
	{
		//read data from socket
		reply(...);
	}
}
 
void Replyer::reply(QString message)
{
	foreach(QTcpSocket* client, mClients)
	{
		//send data to clients
	}
}

вот приблизительно так я вижу класс, который будет жить в потоке. Удаление сокетов при отключении добавь по вкусу))

Писал не компилируя, могуть быть синтаксические ошибки

А как теперь с потоком связать это?
Я думаю так может: В класс потока добавить этот объект Replyer.  В классе сервера на incomingConnection добавить в поток в объект Replyer подключившийся сокет, передав ему дескриптор сокета. Но тогда что должно выполняться в потоке в методе run ?

[mutineer]

QThread *thread = new QThread(this);
Replyer *repl = new Replyer();
repl->moveToThread(thread);
thread->run();

и кончено же к newConnection(int descriptor) надо прявязываться без Qt::DirectConnection

[lolbla2]

QThread *thread = new QThread(this);
Replyer *repl = new Replyer();
repl->moveToThread(thread);
thread->run();

и кончено же к newConnection(int descriptor) надо прявязываться без Qt::DirectConnection

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

[mutineer]

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

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