3.4 Разработка алгоритма работы клиента-заказчика
Клиент-заказчик представляет собой библиотеку, предоставляющую ряд функций использующему её приложению. Эти функции позволяют обратиться к серверу с требованием выполнить участок кода на распределённой системе. Каждая из этих функций принимает объект задачи – экземпляр определённого класса, содержащий метод, который будет выполнен исполнителями, а также исходные данные для обработки.
Схема работы такой функции приведена на рисунке 3.6.
Объект задачи, который пользователь передаёт в функцию распределённой обработки, показан на диаграмме блоком 8. Сначала осуществляется подготовка этого объекта – установка идентификаторов сборки и сессии, сериализация и другие вспомогательные действия. Затем осуществляется проверка синхронизации модуля (.NET-сборки), в котором описан класс объекта задачи. Если этот модуль отсутствует на сервере, то происходит считывание содержимого модуля (блок 9) и отправка его на сервер (блок 10) – эта процедура необходима для последующего выполнения задачи исполнителями. После синхронизации модуля с сервером можно неоднократно выполнять распределённые вычисления с различными экземплярами класса задачи, не выполняя пересылки содержащего этот класс модуля.
Рисунок 3.6 – Схема работы заказчика
После синхронизации модуля библиотека-исполнитель отправляет на сервер запрос на обработку с подготовленным объектом задачи (блок 5). Если задача была успешно поставлена в очередь и выполнена, от сервера придёт ответ с полученными результатами вычисления, которые библиотека вернёт вызвавшему функцию приложению (блок 6). Однако при выполнении задачи могли произойти различные ошибки. Например, могла истечь сессия заказчика на сервере – тогда сервер может потребовать повторной авторизации, которая будет проведена автоматически (блок 13). После авторизации библиотека предпримет новую попытку отправить задачу.
Также могли произойти другие ошибки – как сетевые (сервер недоступен), так и уровня бизнес-логики (некорректный объект задачи). При возникновении ошибки, которую библиотека-исполнитель не может исправить самостоятельно, она выполнит передачу управления вызывающему коду, передав сообщение о произошедших неполадках (блок 12).
3.5 Разработка алгоритма работы клиента-исполнителя
Алгоритм работы исполнителя представляет собой постоянное циклическое обращение к серверу с запросами получения задачи. Получив работу, исполнитель сразу её выполняет и возвращает результат на сервер, после чего снова обращается за новой задачей. Схема работы исполнителя представлена на рисунке 3.7.
После запуске клиент-исполнитель подключается к серверу (блок 2), используя сохранённый в конфигурации адрес. Затем выполняется процедура авторизации (блок 3). Пользователь может остановить приложение – в таком случае на данном этапе осуществляется извещение сервера об отключении исполнителя (блок 11), чтобы он мог осуществить удаление его из пула.
Пройдя авторизацию, исполнитель сразу обращается к серверу с требованием выдать ему задачу (блок 5). Если сервер успешно добавит клиента в пул, то он будет ожидать появления задачи в данном состоянии. Как только сервер выдаст ему задачу, он запускает таймер оповещения сервера о ходе выполнения и начнём выполнение задачи. Пока происходит процесс обработки задачи, таймер оповещения срабатывает с равными интервалами, и при каждом срабатывании этого таймера исполнитель отправляет на сервер информацию о ходе обработки. Эта информация позволяет серверу убедиться в том, что исполнитель не отключился аварийно. Если оповещения перестают приходить от клиента, сервер считает его отключившимся и отдаёт его порцию работы другим исполнителям.
Рисунок 3.7 – Схема работы исполнителя
После окончания выполнения задачи клиент останавливает таймер оповещения и отправляет результаты работы на сервер (блок 10). Затем он приступает к запросу следующей задачи.
При получении задачи может прийти ряд исключительных ситуаций. В случае возникновения ошибки сначала анализируется её тип (блок 14). Срок действия сессии исполнителя на сервере может истечь, в таком случае сервер потребует повторной авторизации. Авторизация производится автоматически (блок 13), после чего производится повторное получение задачи.
Также сервер может вернуть сообщение о переполнении пула исполнителей. В таком случае клиент прекращает на некоторое время запросы, дожидаясь освобождения пула. Время ожидания определяется в конфигурации. По истечении заданного интервала исполнитель производит повторный опрос сервера. Если пул всё ещё полон, алгоритм повторяется до тех пор, пока исполнитель не получит возможность встать в очередь на получение задачи или не будет выключен.
В случае возникновения ошибки, которую модуль исполнителя не в состоянии исправить сам, производится вывод сообщения об ошибке на экран (блок 16). После этого алгоритм повторяется. Такая ситуация может возникнуть при отключении сервера или сетевых неполадках.
|
