QTcoSocket прием данных в отдельном потоке.

[Old]

Это что за кривота? Зачем поток в себя же запихивать?!

Это запись означает, что нужно объект QThread перенести из контекста нитки его создавшей в контекст нитки этого объекта.

Если пересмотреть архитектуру, то таких вещей делать не придется, но для этого надо вникать.

[GPPsoft]

Это что за кривота? Зачем поток в себя же запихивать?!

Это запись означает, что нужно объект QThread перенести из контекста нитки его создавшей в контекст нитки этого объекта.

Если пересмотреть архитектуру, то таких вещей делать не придется, но для этого надо вникать.

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

[Old]

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

Например, сделать объект обработчик, который будет взаимодействовать с сокетом и уже эту связку помещать в отдельную нитку. Тогда не придется наследоваться не от сокета, не от нитки.

[GPPsoft]

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

Например, сделать объект обработчик, который будет взаимодействовать с сокетом и уже эту связку помещать в отдельную нитку. Тогда не придется наследоваться не от сокета, не от нитки.

Т.е обернуть работу с сокетом в класс и запустить его в отдельном потоке? А как же мне тогда из GUI дергать за методы? Ведь та же самая проблема будет.

[GPPsoft]

Постараюсь описать то чего я хочу добиться. Хочу написать некий класс Session который будет работать с сокетом.
Класс должен:
1. Иметь конструктор Session(const QTcpSocket), либо метод setClientSocket(const QTcpSocket)
2. Читать данные в отдельном потоке
3. Иметь метод отключения, аля disconnectFromHost(потокобезопасный)
4. Испускать служебные сигналы(сигнал отключения от хоста и т.д)

Далее я наследуюсь этого класса и расширяю его функционал, в зависимости от предназначения.

[Old]

Лучше смотреть на саму задачу... что должен этот класс Session делать?

[GPPsoft]

Лучше смотреть на саму задачу... что должен этот класс Session делать?

Принимать в качестве параметра конструктора или через метод объект сокета и обрабатывать приходящие данные в отдельном потоке. Могу показать реализацию подобного класса на java. Собственно я и хочу повторить его. Сейчас приведу пример.

[Old]

Принимать в качестве параметра конструктора или через метод объект сокета и обрабатывать приходящие данные в отдельном потоке. Могу показать реализацию подобного класса на java. Собственно я и хочу повторить его. Сейчас приведу пример.

Не надо яву.
Абстрагируйтесь от конструкторов и параметров, что нужно сделать.
 

[GPPsoft]

Максимально упростил. Оставил только ключевые моменты.

Код

Java
public abstract class Session {
 
	public static final int BUFFER_SIZE=8192*2;
	public static final int ALIVE_TIMEOUT = 60000;
 
	private Socket mClient=null;
 
	public void killSession() {
		if (mClient != null){
			try {
				this.mClient.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
                }
	}
 
	public void setClientSocket(Socket client) throws IOException{
 
		if(this.mClient!=null){
			mClient.close();
		}
 
		this.mClient=client;
 
		mAliveTimer= new Timer("ALIVE_TIMER");
		mAliveTimer.schedule(new TimerTask() {
			public void run() {
				sendData(new Packets.KeepAlive());
			}
		},ALIVE_TIMEOUT,ALIVE_TIMEOUT);
 
		new Thread(new ClientDataRead(),"CLIENT_THREAD").start();
	}
 
	protected synchronized boolean sendData(byte[] data){
		if(mClient!=null){
			try{
				mClient.getOutputStream().write(data);
			}
			catch(Exception ex){
				return false;
			}
			return true;
		}else{
			return false;
		}
	}
 
	protected abstract void disconnect();
 
	public class ClientDataRead implements Runnable{
 
		public void run(){
			try{   
				int receivedBytes;
		                byte[] dataBuffer = new byte[BUFFER_SIZE];
 
		                while ((receivedBytes = stream.read(dataBuffer, 0, dataBuffer.length)) != -1) {
			              //Тут я обрабатываю данные....
		                }
 
				disconnect();
			}
			catch(Exception ex)
			{
				ex.printStackTrace();
				mAliveTimer.cancel();
				disconnect();
			}
			finally
			{
				try {
					mClient=null;
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}
	}
}
 

[GPPsoft]

Принимать в качестве параметра конструктора или через метод объект сокета и обрабатывать приходящие данные в отдельном потоке. Могу показать реализацию подобного класса на java. Собственно я и хочу повторить его. Сейчас приведу пример.

Не надо яву.
Абстрагируйтесь от конструкторов и параметров, что нужно сделать.

Думаю проще кодом объяснить. В приведенном примере обработка данных происходит в отдельном потоке. Остальная работа с классом сокета - "потоконезависима".

[Old]

Думаю проще кодом объяснить. В приведенном примере обработка данных происходит в отдельном потоке. Остальная работа с классом сокета - "потоконезависима".

Сейчас нужно уехать, чуть позже...

[GPPsoft]

Думаю проще кодом объяснить. В приведенном примере обработка данных происходит в отдельном потоке. Остальная работа с классом сокета - "потоконезависима".

Сейчас нужно уехать, чуть позже...

Вообщем все что мне нужно, это повторить класс Session который я реализовал на java.

P.S: Буду ждать! Спасибо за проявленный интерес

[Old]

Вообщем все что мне нужно, это повторить класс Session который я реализовал на java.

Тогда вы его уже практически повторили, осталось отвязать прямой вызов killConnection (использовать сигналы).

Другой вариант, это сделать через воркер (обработчик трафика), примерно так:

Код

C++ (Qt)
QThread *th = new QThread;
 
QTcpSocket *sock = new QTcpSocket;
sock->moveToThread( th );
 
Worker *w = new Worker;
w->moveToThread( th );
 
// Подключаем нужные сигналы между сокетом и работалкой.
connect( sock, ..., w ... );
connect( sock, ..., w ... );
 
th->start();
 

Или можно оформить весь процесс работы в одной функции и использовать QtConcurent, для запуска их в разных нитках.

[GPPsoft]

Вообщем все что мне нужно, это повторить класс Session который я реализовал на java.

Тогда вы его уже практически повторили, осталось отвязать прямой вызов killConnection (использовать сигналы).

Другой вариант, это сделать через воркер (обработчик трафика), примерно так:

Код

C++ (Qt)
QThread *th = new QThread;
 
QTcpSocket *sock = new QTcpSocket;
sock->moveToThread( th );
 
Worker *w = new Worker;
w->moveToThread( th );
 
// Подключаем нужные сигналы между сокетом и работалкой.
connect( sock, ..., w ... );
connect( sock, ..., w ... );
 
th->start();
 

Или можно оформить весь процесс работы в одной функции и использовать QtConcurent, для запуска их в разных нитках.

Т.е как я понимаю Worker это мой класс который должен обрабатывать входящий трафик? И в данном примере он будет обрабатывать все сигналы от сокета в отдельном потоке?