Проект Simple Tracker. Часть 7: сервер и клиент

Simple Tracker, Qt, Iscander Che, C++

Рассмотрим теперь сервер и клиента.

С вопросами, касающимися общей организации взаимодействия клиента и сервера, можно ознакомиться в этой статье: " Пример использования QLocalServer и QLocalSocket ". Здесь я коснусь лишь моментов, непосредственно связанных с передачей информации по задаче и закрытием задачи.

Сервер

// trackerserver.cpp

TrackerServer::TrackerServer(QWidget* parent)
    : QWidget(parent)
{
    // Задаём имя сервера
    nameServer = "TrackerServer";
    // Устанавливаем размер следующего блока равным нулю
    nextBlockSize = 0;
    ...
}

// Метод создания и запуска сервера
void TrackerServer::createServer()
{
    localServer = new QLocalServer(this);
    // Если сервер не запустить, выдать сообщение и завершить программу
    if(!localServer->listen(nameServer))
    {
        QMessageBox::critical(0,
                              tr("Ошибка сервера"),
                              tr("Невозможно запустить сервер ") + nameServer + ": "
                              + localServer->errorString());
        localServer->close();
        return;
    }
}
...

// Метод создания подключений
void TrackerServer::createConnections()
{
    // Подключение сигнала сервера о новом подключении к обработчику нового подключения
    connect(localServer, &QLocalServer::newConnection, this, &TrackerServer::slotNewConnection);
    ...
}

Теперь рассмотрим слоты сервера.

// trackerserver.cpp

// Слот обработки нового соединения
void TrackerServer::slotNewConnection()
{
    // Получаем сокет, подключённый к серверу
    QLocalSocket* socket = localServer->nextPendingConnection();

    // Соединяем сигнал отключения сокета с обработчиком удаления сокета
    connect(socket, &QLocalSocket::disconnected, socket, &QLocalSocket::deleteLater);

    // Соединяем сигнал сокета о готовности передачи данных со слотом закрытия задачи
    connect(socket, &QLocalSocket::readyRead, this, &TrackerServer::slotCloseTask);
}

// Слот получения информации от клиента и закрытия задачи
void TrackerServer::slotCloseTask()
{
    QLocalSocket* socket = (QLocalSocket*)sender();
    QDataStream in(socket);
    in.setVersion(QDataStream::Qt_5_3);
    for(;;)
    {
        if(!nextBlockSize)
        {
            if(socket->bytesAvailable() < (int)sizeof(quint16))
                break;
            in >> nextBlockSize;
        }

        in >> clientTaskNumber >> clientRevision;

        nextBlockSize = 0;
    }

    if(!database->isClosed(clientTaskNumber) && clientTaskNumber && clientRevision)
        // Если задача не закрыта и если номер задачи и ревизия не пустые, закрываем задачу
    {
        database->closeTask(clientTaskNumber, QString("%1").arg(clientRevision));

        // Обновляем SQL-таблицу задач
        taskSqlTableModel->select();

        // Если все задачи для текущего проекта закрыты
        if(database->isClosedAllTasks(projectCurrentId))
            // сделать доступной кнопку "Архивировать"
            archiveProjectButton->setEnabled(true);
        else
            // иначе блокировать кнопку "Архивировать"
            archiveProjectButton->setDisabled(true);
    }
}

Клиент

// main.cpp

#include "trackerclient.h"
#include <QCoreApplication>
#include <QFile>
#include <QTextStream>
#include <QDebug>
#include <QRegExp>

int main(int argc, char* argv[])
{
    QCoreApplication app(argc, argv);

    // Считываем из аргумента 1 командной строки путь к файлу log.txt
    QString pathToFile = argv[1];

    QString result;

    // Если файл открывается, считываем данные из файла в строку
    QFile file(pathToFile);
    if(file.open(QIODevice::ReadOnly | QIODevice::Text))
    {
        QTextStream stream(&file);
        result = stream.readAll();
        file.close();
    }
    else
        qDebug() << "Unable open file " + pathToFile;

    int taskNumber = 0;
    int revisionNumber = 0;

    // С помощью регулярного выражения извлекаем из строки номер задачи и номер ревизии
    QString expr = "(.*)(\\#\\{)(\\d+)(\\})(.*)(r\\{)(\\d+)(\\})";
    QRegExp taskRevision(expr);
    int position = taskRevision.indexIn(result);
    if(position > -1)
    {
        taskNumber = taskRevision.cap(3).toInt(); // это номер задачи
        revisionNumber = taskRevision.cap(7).toInt(); // это номер ревизии
    }

    // Инициализируем клиента с соответствующими параметрами
    TrackerClient client("TrackerServer", taskNumber, revisionNumber);

    app.exit(0);
}

Теперь разберём вопрос, откуда берётся log.txt.

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

Проекты с поддержкой СКВ формируются с помощью bat-файла. Его я написал несколько раньше из необходимости создавать и использовать репозитории SVN так, чтобы они при наличии коммитов автоматизированно архивировались. Рассмотрим его в той части, которая касается создания проектов с поддержкой СКВ, то есть уже реально существующих в файловой системе проектов.

rem Запрашиваем наименование проекта
set /p repo_name=[Input name project]: 
echo Name repository: %repo_name%

rem Устанавливаем путь к репозиторию
set repo_path=%repo_root%\%repo_name%
echo Full path to repository: %repo_path%

rem Создаём репозиторий
svnadmin create %repo_path%

rem Очищаем папку репозитория hooks
del /f /q %repo_path%\hooks\

rem Создаём / копируем в папке hooks файлы ini.bat, pre-commit.bat, post-commit.bat
echo set commit=n>%repo_path%\hooks\ini.bat
copy pre-commit.bat %repo_path%\hooks\
copy post-commit2.bat %repo_path%\hooks\post-commit.bat

rem Импортируем файловую структуру по умолчанию и формируем первый коммит
svn import %def_tree% file:///%repo_path% -m "initial import"

Файл ini.bat содержит в себе флаг commit, устанавливаемый в "n", если коммитов нет, или устанавливаемый в "y", если есть хотя бы один коммит. По его состоянию скрипт архивации определяет, надо ли архивировать данный репозиторий.

rem pre-commit.bat
@echo off

rem Считываем переменные из командной строки
set repo_path=%1
set transaction=%2

rem Записываем сообщение коммита в файл log.txt
"G:\soft\svn\bin\svnlook.exe" log -t "%transaction%" "%repo_path%">%repo_path%\hooks\log.txt

В сообщении коммита содержится номер закрываемой задачи в формате #{ <номер задачи> } .

rem post-commit.bat

@echo off

rem Считываем переменные из командной строки
set repo_path=%1
set revision=%2

rem Устанавливаем в файле ini.bat флаг commit в "y"
echo set commit=y>%repo_path%\hooks\ini.bat

rem Записываем номер ревизии в файл log.txt
echo r{%revision%}>>%repo_path%\hooks\log.txt

rem 
%path_to_tracker%\ICTrackerClient.exe  %repo_path%\hooks\log.txt

После записи ревизии в post-commit.bat файл log.txt выглядит примерно следующим образом.

Closing task #{2} end some editing files
r{29}

И последним вызывается клиент, который считывает эти данные из файла.

Осталось только передать эти данные серверу.

// trackerclient.h

#ifndef TRACKERCLIENT_H
#define TRACKERCLIENT_H

#include <QObject>
#include <QLocalSocket>

class TrackerClient : public QObject
{
    Q_OBJECT

public:
    explicit TrackerClient(const QString& serverName, int taskId, int revision,
                           QObject* parent = 0);

    ~TrackerClient();

private:
    QLocalSocket* localSocket;
    int taskId;
    int revision;

private slots:
    void sendToServer();
};

#endif // TRACKERCLIENT_H
// trackerclient.cpp

#include "trackerclient.h"
#include <QDataStream>

TrackerClient::TrackerClient(const QString &serverName, int taskId, int revision,
                             QObject* parent) :
    QObject(parent), taskId(taskId), revision(revision)
{
    localSocket = new QLocalSocket(this);
    localSocket->setServerName(serverName);

    connect(localSocket, &QLocalSocket::connected, this, &TrackerClient::sendToServer);

    localSocket->connectToServer();
}

TrackerClient::~TrackerClient()
{
}

void TrackerClient::sendToServer()
{
    QByteArray arrayBlock;
    QDataStream out(&arrayBlock, QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_5_3);
    out << quint16(0) << taskId << revision;

    out.device()->seek(0);
    out << quint16(arrayBlock.size() - sizeof(quint16));

    localSocket->write(arrayBlock);

    localSocket->disconnectFromServer();
}
Рекомендуем хостинг TIMEWEB
Рекомендуем хостинг TIMEWEB
Стабильный хостинг, на котором располагается социальная сеть EVILEG. Для проектов на Django рекомендуем VDS хостинг.

Добрый день, и снова немного ревью.

Вот это каст в стиле Си

QLocalSocket* socket = (QLocalSocket*)sender();

Лучше кастовать в стиле С++, мы же на С++ пишем.

QLocalSocket* socket = static_cast<QLocalSocket*>(sender());

Получается несколько многословнее, но честно, в большом проекте хоть есть за что глазу зацепиться. Плюс более контролируемый каст.

Далее, думаю, что вот это

        // Если все задачи для текущего проекта закрыты
        if(database->isClosedAllTasks(projectCurrentId))
            // сделать доступной кнопку "Архивировать"
            archiveProjectButton->setEnabled(true);
        else
            // иначе блокировать кнопку "Архивировать"
            archiveProjectButton->setDisabled(true);

Можно переписать так

archiveProjectButton->setEnabled(database->isClosedAllTasks(projectCurrentId));

setEnabled и setDisabled делают тоже самое.

Вот это

explicit TrackerClient(const QString& serverName, int taskId, int revision,
                           QObject* parent = 0);

Нужно переписать так

explicit TrackerClient(const QString& serverName, int taskId, int revision, QObject* parent = nullptr);

nullptr - это специальный псевдотип данных для нулевого указателя. В случае с 0, там по сути может оказаться какой угодно мусор в зависимости от платформы. В случае с nullptr поведение будет предсказуемым.

Далее вот это объявление

QLocalSocket* localSocket;

Наверное стоит вам сразу писать как

QLocalSocket* m_localSocket;

Это принятый код-стайл в Qt, а также именно на такую запись заточены макросы Q_PROPERTY. Ну и стоит в деструкторе удалять m_localSocket, чтобы не было утчечек памяти. Вообще этот как раз тот случай, где имеет смысл использовать умные указатели, как вы делали в прошлой статье.

QLocalSocket* socket = static_cast<QLocalSocket*>(sender());

Получается несколько многословнее, но честно, в большом проекте хоть есть за что глазу зацепиться. Плюс более контролируемый каст.

Да, я уже со static_cast освоился, такая запись понятнее.

setEnabled и setDisabled делают тоже самое

Ага.

nullptr - это специальный псевдотип данных для нулевого указателя

Понял.

Наверное стоит вам сразу писать как QLocalSocket* m_localSocket;

А что означает буква m перед наименованием? Эти буквы меня всегда путают и с толку сбивают.

А что означает буква m перед наименованием? Эти буквы меня всегда путают и с толку сбивают.

member - член класса, некоторое поле. В Qt это обычное обозначение тех объектов, которые объявлены в private или protected секциях.

Просто в Q_PROPERTY это прописывается без m_ но макрос разворачивается на член класса, который содержит этот префикс.

Вообще этот как раз тот случай, где имеет смысл использовать умные указатели

Как правильно объявить умный указатель и инициализировать по отдельности? Я пробовал так:

QSharedPointer<HelloWorldClass> hwc2;
hwc2 = new HelloWorldClass();

выдаёт ошибку при компиляции.

QSharedPointer<HelloWorldClass> hwc2;
hwc2.reset(new HelloWorldClass()); // Удаляет автоматически предыдущий объект, если он там был, и если нет указателей на тот объект в других QSharedPointer

Теперь на коннекте ошибку выдаёт:

connect(localSocket, &QLocalSocket::connected, this, &TrackerClient::sendToServer);

connect(m_localSocket.get(), &QLocalSocket::connected, this, &TrackerClient::sendToServer);

Комментарии

Только авторизованные пользователи могут публиковать комментарии.
Пожалуйста, авторизуйтесь или зарегистрируйтесь
Ищу работу?
25,000.00 руб. - 30,000.00 руб.
Разработчик Qt/C++
Barnaul, Altai Krai, Russia

Для зарегистрированных пользователей на сайте присутствует минимальное количество рекламы

СВ
23 октября 2019 г. 1:00
Семен Волох

C++ - Тест 004. Указатели, Массивы и Циклы

  • Результат:70баллов,
  • Очки рейтинга1
SS
22 октября 2019 г. 14:31
Samantha Smith

Qt - Тест 001. Сигналы и слоты

  • Результат:52баллов,
  • Очки рейтинга-4
МБ
21 октября 2019 г. 1:25
Михаил Булатов

C++ - Тест 002. Константы

  • Результат:16баллов,
  • Очки рейтинга-10
Последние комментарии
17 октября 2019 г. 2:17
Евгений Легоцкой

Используем, там где требуется :)
MP
17 октября 2019 г. 2:15
Mikhail Petrov

Совет: подключайте ресурсы динамически. Используйте Resource Compiler: https://doc.qt.io/qt-5/rcc.html
16 октября 2019 г. 6:45
Евгений Легоцкой

Если это не чистой воды спам, а по делу, то без проблем. Но в таком случае лучше создавайте отдельный вопрос на форуме . При создании вопроса есть поле, в котором можно указать статью…
КК
16 октября 2019 г. 6:39
Кирилл Кирилыч

А тут можно ссылки на сторонний ресурс показывать? Нашёл на habr похожую статью, только там чуток отличается код и про локальный сервер написано, нужно чтоб кто то понимающий посмотрел и своё …
Сейчас обсуждают на форуме
23 октября 2019 г. 4:06
Евгений Легоцкой

Ну если после обновления начало появляться, то тогда откатить драйвера. А вообще, если это жить не мешает и код работает как и раньше, то просто проигнорировать эти сообщения.
22 октября 2019 г. 2:42
Pavel K.

Всем привет , Пытаюсь реализовать класс для работы с блютуз (Bluetooth Handler) для мобилки , с использование QBluetoothDeviceInfo и QBluetoothDeviceDiscoveryAgent . Может у кого е…
22 октября 2019 г. 2:16
Pavel K.

попробуй сделать через свой собственный компонет , те возьми контрол Component, например , переорпедели как свой , в нем что нить типо проперти type : disk1, disk2 (сделай метод в структуре …
Е
22 октября 2019 г. 0:03
Евгений_Канусовский@1981

Этот алгоритм предназначен для того чтобы исключить из обработки строки содержащие буквенные символы. Если Вам не трудно опишите пожалуйста как бы Вы написали этот алгоритм, желательно в коде?
MP
21 октября 2019 г. 7:03
Mikhail Petrov

Зависит от вашей задачи. Можете обратить внимание на этот пример: https://doc.qt.io/qt-5/qtqml-referenceexamples-properties-example.html QQmlListProperty используется мною достаточно ч…
EVILEG
О нас
Услуги
© EVILEG 2015-2019
Рекомендует хостинг TIMEWEB