[РЕШЕНО] Простой многопоточный сервер

[BRE]

Можно было тогда вообще не писать вашей реплики "это плохо и меня заканало это писать".

Я правда жалею.

[Reklats]

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

    Напомню суть: первое партия данных не считывается сервером. Или, если быть точнее, считывается, но 1 раз за 50 подключений примерно.
Подозреваю, что нужно что-то вроде waitForConnect(). Или по таймеру в слоте. Или вообще может поток как-то не правильно инициализируется. Идеи есть, но как это проверить я не в курсе.

    Согласен с идеей, что концепция "одно соединение - один поток" не правильна, ровно как и "все соединения в одном потоке", т.к. не обеспечивает нужного быстродействия. Думаю, что нужно в каждом потоке обслуживать некоторое число N соединений, а потом при превышении этого числа запускать новый поток. Думаю, что это будет компромиссом.

[andrew.k]

правильно думаешь, выложи еще раз в zip, если не сложно.

[Igors]

Думаю, что нужно в каждом потоке обслуживать некоторое число N соединений, а потом при превышении этого числа запускать новый поток. Думаю, что это будет компромиссом.

Это также обсуждалось, и уязвимые места довольно очевидны: трудно определить "время X" когда новая нитка должна быть создана, так же как и "время Y" когда от нее избавиться.

Никогда не имел никакого желания писать "многопоточный сервер", но, на мой взгляд, все multi-threaded задачи имеют много общего. Чем занимаюсь я в своей предметной области - это "нарезкой на порционные куски", выделением под-задач чтобы они могли быть скормлены любой рабочей нитке, их число = числу ядер. Это более 90% работы. Но есть еще задачи типа "проверить а не случилось ли чего" - и если да то подкинуть задания рабочим (типа диспетчера). Такие задачи нужно сливать в 1 нитку (ну или в как можно меньшее их число).

Повторюсь, что веб и сервера - не мой профиль, это просто "взгляд со стороны"  

[Reklats]

Это также обсуждалось, и уязвимые места довольно очевидны: трудно определить "время X" когда новая нитка должна быть создана, так же как и "время Y" когда от нее избавиться.

При каждом новом конекте, дисконнекте.

andrew.k, сорцы вот: http://pastebin.com/n0rM9Ncs
И тут ещё: http://www.prog.org.ru/index.php?topic=20287.msg138126#msg138126

UPD FIN: Решение найдено! У меня нулевое значение m_nNextBlockSize не задается вначале.
Какая же ламерская ошибка...

Код

C++ (Qt)
QServerThread::QServerThread(int socketDescriptor, QObject *parent)
    : QThread(parent), socketDescriptor(socketDescriptor), m_nNextBlockSize(0)
{
    this->moveToThread(this);
}
 

[andrew.k]

m_nNextBlockSize где у тебя инициализируется?

[Reklats]

Ну вот. Рано радовался.

Какие-то странные пакеты шлёт сервер. Ну и клиент тоже. Вот:


1) Такой пакет шлёт клиент
2) Таким отвечает сервер
3) Такой пакет не ловится, а нужно обработать именно такой. Только регистрируется, что клиент что-то послал.

Что посоветуете?

[Bepec]

А что ты посылал? в 3 пакетике?

[andrew.k]

Вот ты бы там где у тебя break'и стоят добавил бы qDebug() какой-нибудь. Либо сам в отладке посиди.
Сразу станет понятно. В чем проблема.
Может размер неправильно считается и данных реально меньше, чем указано в размере.

[Reklats]

А что ты посылал? в 3 пакетике?

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

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

Точно, почему-то считывает "308" и соответственно во втором бряке выходит из цикла. Откуда он берет 308 - хз...

[andrew.k]

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

[Bepec]

Reklats, а в твой протокол входит передача времени посыла? Или это эволюция твоей программы?

[Reklats]

Reklats, а в твой протокол входит передача времени посыла? Или это эволюция твоей программы?

Нет, не входит. Это лишнее, я это выкинул. Можно сказать, что это эволюция.

Пытаюсь вот побайтно считывать данные из сокета...

[andrew.k]

По-моему проще свой чат с нуля написать, чем ковырять чей-то протокол самопальный.
В чем смысл?

[Bepec]

andrew.k не соглашусь частично.

Проще написать свой протокол ^^.