Система сбора и отображения данных

[8Observer8]

Я видимо, перемудрил с сокетами. У меня Server и Viewer соединены по одному каналу. Каждую секунду я перебрасываю строку от Viewer - запрос "currentValues". На этот запрос Sever мне передаёт посылку-строку с названиями и значениями текущих датчиков (которых может быть сколько угодно, по ТЗ не больше 10). По этому же каналу я передаю запрос "getRequiredRange,времяНачала,времяОкончания". Server считывает из базы данных названия и значения датчиков и передаёт их Viewer'у, которых может быть много (в базе данных я также храню время-дату съёма). В том числе вся база данных. И всё это по-одному каналу. Придётся капать в сторону потоков, чтобы завести несколько сокетных соединений.

[8Observer8]

Я нашёл, как мне кажется, подходящий пример из Qt: ThreadedFortuneServer. Он позволил бы мне обрабатывать такие запросы от клиентов как: запрос на текущие (ежесекундные) данные с датчиков (название датчиков, их значение и время съёма данных), а так же запрос на историю изменений значений датчиков за указанный период.

Проблем появилось очень много. К примеру, клиент тоже придётся как-то переделать через потоки. Один поток запрашивает текущие данные, другой по желанию пользователя запрашивает данные за указанный период.

Одна из текущих проблем: как переделать ThreadedFortuneServer, чтобы он принимал данные от клиента. Так как в этом примере данные генерируются внутри самого класса FortuneServer:

Код

C++ (Qt)
#include "fortuneserver.h"
#include "fortunethread.h"
 
#include <stdlib.h>
 
//! [0]
FortuneServer::FortuneServer(QObject *parent)
    : QTcpServer(parent)
{
    fortunes << tr("You've been leading a dog's life. Stay off the furniture.")
             << tr("You've got to think about tomorrow.")
             << tr("You will be surprised by a loud noise.")
             << tr("You will feel hungry again in another hour.")
             << tr("You might have mail.")
             << tr("You cannot kill time without injuring eternity.")
             << tr("Computers are not intelligent. They only think they are.");
}
//! [0]
 
//! [1]
void FortuneServer::incomingConnection(qintptr socketDescriptor)
{
    QString fortune = fortunes.at(qrand() % fortunes.size());
    FortuneThread *thread = new FortuneThread(socketDescriptor, fortune, this);
    connect(thread, SIGNAL(finished()), thread, SLOT(deleteLater()));
    thread->start();
}
//! [1]

[Bepec]

Не вижу ваших проблем в упор.
Fortune Server спокойно держит до 15 клиентов, принимает и отсылает данные. И есть подозрение что так будет и при 100+ клиентах.
Вам нужно всего-то свой протокол сделать. Команды запроса-ответа, механизм верификации.

[8Observer8]

Да, точно, Вы правы! Со стороны сервера при новом соединении создаётся новый сокет:

Код

C++ (Qt)
void IcebreakerServer::readyRead()
{
    // ...
    QTcpSocket* clientSocket = (QTcpSocket*)sender();
    // ...
}
 

Надо со стороны Viewer несколько сокетов завести. Скорее всего, сервер переделывать не придётся. Спасибо!

[Bepec]

Зачем несколько сокетов?

В упор не вижу ваших проблем

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

[8Observer8]

А если я запросил командой переслать всю информацию из базы данных? У меня тогда клиент зависнет. Разве нет?

[Bepec]

м... это долгая операция. Хотя смотря как пересылать. Всё равно в одном пакете не получится, значит просто будут части посылаться. А между пакетами с частями всей инфы можно и любой другой пакет запросить.

PS и да, можно просто блочить интерфейс на ресурсоёмкую операцию. Все так делают, ничего постыдного нет.

[Old]

А если я запросил командой переслать всю информацию из базы данных? У меня тогда клиент зависнет. Разве нет?

Почему?

[8Observer8]

Ура! Я выполнил задание! Всем огромное спасибо!

Вот так на рисунке выглядят программы: Server, Viewer, Менеджер датчиков:


Исходники
Server: https://github.com/8Observer8/IcebreakerServer/tree/with_sensors_manager
Viewer: https://github.com/8Observer8/IcebreakerViewer/tree/with_sensors_manager
Менеджер датчиков: https://github.com/8Observer8/Sensors

Краткое описание проекта:

"Сервер Данных"
- пользователь запускает программу "Сервер Данных"

"Драйвер Датчика"
- пользователь запускает программу "Драйвер Датчика" (на том же компьютере, что и
"Сервер Данных" или удалённом компьютере)
- добавляет датчики в таблицу, нажимая в меню "Добавить". В открывшимся диалоге
указывает: имя датчика, номер COM-порта. В меню есть так же пункты: "Редактировать", "Удалить" запись из таблицы.
- вводит IP адрес (или имя компьютера) и порт "Сервера Данных"
- нажимает кнопку "Подсоединиться к серверу"
- пользователь может наблюдать текущие значения каждого датчика в приложении "Драйвер Датчика" в таблице

"Сервер Данных"
- после того, как пользователь нажал кнопку "Подсоединиться к серверу" в приложении
"Драйвер Датчика", то "Сервер Данных" начинает принимать данные
- "Сервер Данных" сохраняет данные от датчиков в базу данных в таком виде: имя датчика,
значение датчика, дата и время съёма

"Приложение Оператора"
- пользователь запускает "Приложение Оператора"
- вводит IP адрес (или имя компьютера) и порт сервера
- нажимает кнопку "Подсоединиться к серверу"
- "Приложение Оператора" начинает отправлять запросы приложению "Сервер Данных" каждую секунду
- в ответ приложение "Сервер Данных" присылает текущие значения датчиков
- "Приложение Оператора" отображает текущие значения датчиков
- пользователь вводит требуемый временной диапазон (дата-время) и получает от
приложения "Сервер Данных" значения датчиков за указанный период
- пользователь так же может узнать значение указанного датчика в указанный момент
времени, а так же значения указанного датчика в указанный период времени

Дополнительная функциональность (которую я не успел реализовать на Qwt). Пользователь может
наблюдать текущие значения датчиков на графике в "Приложении Оператора" (графики рисуются в
реальном времени). Как в примере из Qwt:

[8Observer8]

Облом... Вчера отправил задание на проверку. Сегодня позвонил. Сказали, что у них в компании какие-то проблемы и они экстренно все вакансии закрыли. Вот эта вакансия: http://www.volgasoft.com/careers.htm#cppj

По Qt в Саратове ничего больше нет. И эта компания подходила, так как они работают с зарубежным заказчиком. Хотелось ещё английский, чтобы пригодился (хотя он ещё очень плох). Теперь либо удалённо искать на Qt, либо изучать C# или Java.

Наверное всё же посижу ещё немного на шеи у родителей, отлично изучу C++ и Qt и найду себе работу по удалёнке!

[Old]

они экстренно все вакансии закрыли.

А что они там вообще делали?

[8Observer8]

По-моему, то же самое что и я делал, только для конкретных систем и в других масштабах. Системы сбора, хранения и визуализации данных. Российский заказчик у них ГазПром. Пишут ПО для управления промышленным оборудованием.

[Bepec]

Если они используют то, что я думаю, то о Qt можно было бы забыть в начинке Есть вроде одна система специально под газпром написанная

Разве что для интерфейса

[8Observer8]

У них ещё .NET. А так они в основном с зарубежным заказчиком работают. Вот что они применяют для разработок: http://www.volgasoft.com/expertise/

[Old]

Если они используют то, что я думаю, то о Qt можно было бы забыть в начинке

Для чего искать разработчиков Qt, что бы они забыли про Qt?

Разве что для интерфейса

Ну так Qt для этого и предназначен.