QThread + QTcpSocket + основной поток

[Vexator]

Доброго времени суток!

помогите разобраться со следующей задачей:
существует основной поток, выполняющий обработку данных и множество входящих подключений по TCP.
соответственно, для каждого нового подключения хочется запускать отдельный поток, который бы его обслуживал
(т.е. передвал в него данные и считывал ответ клиента), при этом выполняя обмен данными с основным потоком (который обрабатывает эти данные).

почитал, посмотрел примеры реализации подобных серверных приложений и решил сделать используя QThread + QTcpSocket. создав основной класс от QTcpServer , и порождая новые нити при каждом новом подключении.
в итоге получил нечто вида:

Код:

void chat_deamon::incomingConnection(int socketDescriptor)
{
chat_trhead *thread = new chat_trhead(socketDescriptor, this);
connect(thread, SIGNAL(finished()), thread, SLOT(deleteLater()));
connect(thread, SIGNAL(post(QString)), this, SLOT(post(QString)) );
connect(this, SIGNAL(users_upd(QString)) , thread, SLOT(upd_users(QString)) );
thread->start();
}

а в нити:

Код:

void chat_trhead::run()
{
QTcpSocket tcpSocket;
if (!tcpSocket.setSocketDescriptor(socketDescriptor)) {
emit error(tcpSocket.error());
return;
}

while(1)
{
// читаем и т.д.
}

при этом для общения с нитями использую связки из слотов/сигналов
возводя при этом флаги и обрабатывая их в цикле while(1) в run()

Код:

void chat_trhead::upd_users(QString nul)
{
	ul = nul;
	upd_u = true;
}

и все это работает, причем вроде даже хорошо, но:
1) передавать данные через сигналы не очень удобно, можно ли для этого передавать указатель на общие данные и писать/читать уже оттуда используя QRWlock(), не сильно ли это скажется на надежности и скорости приложения?
2) если к примеру требуется передать данные через сигнал КОНКРЕТНОМУ приемнику, как это сделать? ведь connect в данном случае привязывает слоты КАЖДОГО потока к одному СИГНАЛУ сервера, и следовательно, при его использовании данные рассылаются всем нитям, а не конкретной, можно ли как то ее идентифицировать и общаться с ней?
3) можно ли создать поток обработки QTcpSocket в отдельной нити так, что бы он обрабатывался не через while(1)... а через сигналы readyRead() и т.д. а то после окончания run() достучаться до потока уже немогу ( ...

подскажите как лучше сделать?

[kuzulis]

3) можно ли создать поток обработки QTcpSocket в отдельной нити так, что бы он обрабатывался не через while(1)... а через сигналы readyRead() и т.д. а то после окончания run() достучаться до потока уже немогу (

мож сделать так:

Код:

void chat_trhead::run()
{
    QTcpSocket tcpSocket;
    connect(tcpSocket, SIGNAL(readyRead()), this, SLOT(тут какой нить слот));
    if (!tcpSocket.setSocketDescriptor(socketDescriptor)) {
        emit error(tcpSocket.error());
        return;
    }
    exec();
}

[Winstrol]

3) можно ли создать поток обработки QTcpSocket в отдельной нити так, что бы он обрабатывался не через while(1)... а через сигналы readyRead() и т.д. а то после окончания run() достучаться до потока уже немогу ( ...

Для работы через сигналы readyRead() надо либо не переопределять метод run, либо, совершив некоторые предварительные действия в переопределенном run, вызвать цикл обработки событий (в том числе от сокетов) - метод exec().

[Vexator]

Спасибо буду тестить
а что можете посоветовать по поводу того как обратиться к конкретному потоку (через сигнал) ?

[alexman]

1) Можно использовать глобальный буфер, но его внутренние данные которые изменяются потоками необходимо закрыть мьютексом или семафором в зависимости от ситуации.
2) Можно реализовать глобальный proxy-класс, который будет отфильтровывать сообщения и посылать сигналы требуемым потокам.
3) while(1) плохо, так как процессор грузиться. Лучше использовать while(1), но внутри засыпать на QWaitCondition, а далее постоянно будить поток по сигналу readyRead.

[Vexator]

1) Можно использовать глобальный буфер, но его внутренние данные которые изменяются потоками необходимо закрыть мьютексом или семафором в зависимости от ситуации.

по сути сделать общие ресурсы и управлять через них?..

2) Можно реализовать глобальный proxy-класс, который будет отфильтровывать сообщения и посылать сигналы требуемым потокам.

а как такое сделать??

3) while(1) плохо, так как процессор грузиться. Лучше использовать while(1), но внутри засыпать на QWaitCondition, а далее постоянно будить поток по сигналу readyRead.

я думал так сделать, но ,во-первых, у меня таких Condition может быть несколько (поток просыпается не только по получению readRead() но и других сигналов), можно ли это увязать в пределах QWaitCondition ??, а, во-вторых, смущает строчка из assistenta :

void QWaitCondition::wakeOne ()
Wakes one thread waiting on the wait condition. The thread that is woken up depends on the operating system's scheduling policies, and cannot be controlled or predicted.
If you want to wake up a specific thread, the solution is typically to use different wait conditions and have different threads wait on different conditions.

не будет ли проблем разбудить "конкретный" поток таким путем??

[ритт]

1. жесть
2. жесть
3. плохо. либо waitForConnected, либо петлю

на connectNotify запоминай кто коннектился к сигналу (на disconnectNotify убирай запись из списка), когда узнал кому "отправлять сигнал" (видимо, данная задача это подразумевает), делай QMetaObject::invokeMethod
советую использовать петлю.

зы. и далеко не всегда поток на сокет - хорошее решение

[Vexator]

1. жесть
2. жесть

ага )

3. плохо. либо waitForConnected, либо петлю
на connectNotify запоминай кто коннектился к сигналу (на disconnectNotify убирай запись из списка), когда узнал кому "отправлять сигнал" (видимо, данная задача это подразумевает), делай QMetaObject::invokeMethod
советую использовать петлю.

петлю - в смысле while(1) ?

зы. и далеко не всегда поток на сокет - хорошее решение

а как еще можно обеспечить параллельную работу основного потока (вычисления) с передачей в него и из него данных в сокеты ?

[BRE]

Рекомендую прочесть статейку:
http://www.opennet.ru/base/dev/server_way.txt.html

[alexman]

1. Не жесть, а часто используемое решение.
2. На счёт этого согласен)

[Vexator]

1. Не жесть, а часто используемое решение.

ага с этого начинал )

2. На счёт этого согласен)

мне в принципе интересно как ето сделать )))

[ритт]

Код:

 class MyThread : public QThread
 {
 public:
     void run();
 };

 void MyThread::run()
 {
     QTcpSocket socket;
     // connect QTcpSocket's signals somewhere meaningful
     ...
     socket.connectToHost(hostName, portNumber);
     exec();
 }

[Fastman]

У меня например сделан отдельный класс для обработки сообщений.
Все как и выше практически:

Сам сервак который слушает клиентов:

Код:

void CTcpCast::StartServer(qint32 nPort)
{
	if (!listen(QHostAddress::Any, nPort)) 
		return;
}

void CTcpCast::StopServer()
{
	this->close();
}

void CTcpCast::incomingConnection(qint32 nSocketDescriptor)
{
	CThreadWorker *m_pThread = new CThreadWorker(nSocketDescriptor, this);
	connect(m_pThread, SIGNAL(finished()), m_pThread, SLOT(deleteLater()));
	m_pThread->start();
}

Поточный класс:

Код:

CThreadWorker::CThreadWorker(int nSocketDescriptor, QObject *parent)
: QThread(parent), m_SockedDescriptor(nSocketDescriptor)
{

...
}

void CThreadWorker::run()
{
	CConnection m_Connection;
	if(!m_Connection.setSocketDescriptor(m_SockedDescriptor))
		return;

	connect(&m_Connection, SIGNAL(disconnected()), this, SLOT(deleteConnection()));
	exec();
}

А вот CConnection:
 

Код:

CConnection::CConnection(QObject *parent)
	: QTcpSocket(parent)
{
	connect(this, SIGNAL(readyRead()), this, SLOT(processReadyRead()));
             ...
}
....
void CConnection::processReadyRead()
{
	char    *szData;
	QString cReadedData;

	QByteArray block;
	QDataStream out(&block, QIODevice::WriteOnly);
	out.setVersion(QDataStream::Qt_4_0);

	if(this->isReadable())
	{
		qint64 qnSize = this->bytesAvailable();
		if( qnSize > 0)
		{
			szData = new char [qnSize+sizeof(szData)];
			qint64 qnReadSize = this->read(szData, qnSize);
			szData[qnReadSize] = NULL;
		}
	}

	cReadedData.append(szData);
             if(szData != NULL)
	    delete[] szData;

	qDebug() << cReadedData.simplified();
             ....
}

[Vexator]

возник новый вопрос...
а как правильно организовать работу с общей памятью для множества процессов?
создать отдельный класс для хранения данных и передать всем на него указатель?
при каждом обращении к данному классу необходимо делать QMutex ?
подскажите пожалуйста, а то что то завис 

[denka]

Глянь вот это http://doc.trolltech.com/4.4/qsharedmemory.html