Почему не срабатывает сигнал в Qt?

Question

[Sazoks]

В потоке создаю сокет и делаю коннект:

mTcpSocket = new QTcpSocket;
mTcpSocket->setSocketDescriptor(mSockD);
connect(mTcpSocket, &QTcpSocket::readyRead, this, &Listener::SlotMessageAccepted);

Т.е. при получении данных вызывается метод для их обработки.
Проблема в том, что когда сервер высылает данные, эта штука не работает...
Но данные точно поступают в сокет!
Когда вышеуказанного кода я написал это:

QByteArray Block;
_sock->waitForReadyRead();
while (_sock->bytesAvailable() > 0)
    Block.append(_sock->readAll());

Данные поступали и записывались в Block. Т.е. проблема, как я понимаю, не в доставке данных, а в коннекте.
Но как исправить проблему?

Comments

[Gennady S]

Из вашего кода не ясно, Вы подключение-то выполняете? Посмотрите внимательно рабочий пример: https://doc.qt.io/qt-5/qtnetwork-fortuneclient-exa... , проверьте, все ли шаги выполнили.

[Sazoks]

Gennady S, разумеется да)) Проблему нашел, но не знаю, как решить. Написал ответ ниже

Answer 1

[Sazoks]

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

Comments

[xorknown]

Вы же сами подключаете сигналы к слотам, просто одним сокетом читайте, другим пишите. Так же у QAbstrackSocket в метод connectToHost передается флаг, можно выбрать хотите вы только читать или только писать.

[Sazoks]

xorknown, смотрите, у меня есть сокет. Во время работы приложения один один, да. Но в определенный момент мне необходимо создать поток, который будет только слушать. В этот поток я передаю дескриптор исходного сокета. Сам исходный сокет будет отправлять данные на сервер. Проблема в том, что данные почему-то записываются в исходный сокет и до 2-го просто не доходят, только если я явно не буду считывать данные сразу во 2й сокет.
Можно ли как-то по ходу работы установить сокет только в чтение или только в запись?

[xorknown]

Sazoks, я про это и говорю, в главном потоке вы создаете connect, который читает данные в исходный сокет, потом создаете второй, но connect остается, так ведь? И получается что исходный сокет читает все данные и второму ничего не остается. Метод connect возвращает QMetaObject::Connection с помощью которого потом можно сделать disconnect для исходного сокета от сигнала readyRead. Либо я до сих пор не понял в чем проблема.

[Sazoks]

xorknown, не поняли) Ну, вероятно, я плохо объясняю.
1) Есть главный поток, в котором производилось подключение к серверу.
2) В определенный момент я создаю 2й поток для приема сообщений от сервера, туда я передаю дескриптор сокета.
3) Во 2м потоке я создаю новый сокет по дескриптору старого и там же, во 2м потоке, делаю connect

connect(mTcpSocket, &QTcpSocket::readyRead, this, &Listener::SlotMessageAccepted);

Вот и все. Я сам еще плохо понимаю, как работают сокеты в Qt...
Когда сервер отправляет данные, они, почему-то, приходят в тот сокет, который в главном потоке. А там-то никаких connect'ов нету! К слову, ради теста я сделал в главном потоке тот самый connect, и все заработало, но мне нужно во 2м потоке

[xorknown]

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

[xorknown]

Я на всякий случай уточню, вполне возможно, что не могут существовать два QTcpSocket-а с одинаковым дескриптором, так как они читают из него в свой локальный буфер и поэтому до второго не доходят данные, но не уверен в подобной реализации. Опять же чтение из одного дескриптора из разных потоков не факт что безопасно.
Да и qt не советует использовать QTcpSocket в потоках, так как он условно асинхронный.
Либо второй вариант, проблема может быть в потоке и его eventLoop.

[Sazoks]

xorknown, Да, вы правы. Я тоже об этом задумывался, но из-за нехватки знаний не был уверен... Создать отдельное подключение здесь невозможно из-за архитектуры (хотя "это" сложно назвать архитектурой). Если не против, я вам расскажу в общем, как все работает.
1) Сервер с помощью сигналов/слотов принимает новые соединения.
2) Создается новый поток и объект типа Worker, который и обрабатывает все запросы пользователя, хранит в себе класс юзера с его данными.
3) Когда пользователь посылает команду о подключении к какому-то каналу (имеется массив каналов, каждый канал хранит в себе массив указателей на сокеты пользователей, чтобы можно было посылать им сообщения), тут-то на клиенте и создается новый поток для получения сообщений.
Т.е. когда пользователь пишет какое-то сообщение и отправляет его, все остальные юзеры получают его в своем доп. потоке (так должно работать по идее). Я подумал, если на клиенте работать в одном потоке, данные могут смешаться: когда юзер отправляет сообщение, и одновременно с этим приходят данные с сервера.

Теперь я совсем запутался и не знаю, что делать...

[Sazoks]

xorknown, пока что действительно вижу только один выход: при подключении клиента СРАЗУ создать 2е подключение и иметь 2 разных сокета: один для записи, другой для чтения... Только как-то костыльно это выглядит...
Решил блин после ЕГЭ побаловать себя прогой..) Думал, закончу проект на месяц раньше

[xorknown]

Sazoks, А что значит смешаться? Какие проблемы могут возникнуть? Как раз таки в одном потоке ничего паралельно произойти не может, только асинхронно.

[xorknown]

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

[Sazoks]

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

[xorknown]

Sazoks, так в этом то и прикол, что у сокетов различные буферы для записи и чтения. Тоесть чтобы отправить вы пишете в одно место, а читаете из другого.
А в пределах вашей программы это не может одновременно произойти , так как у вас будет один поток и в единый момент времени вы либо читаете, либо пишете, одновременно никак.

[Sazoks]

xorknown, БОЛЬШОЕ СПАСИБО! Я обязательно попробую, но вы меня прямо воодушевили)) Огромное спасибо. Сейчас уже поздно, как сделаю, напишу))
Для меня это очень полезная информация, спасибо