Очередь заданий

Реализовать сервер очередей заданий с заданным протоколом взаимодействия на базе TCP сокетов

Описание

Сервер это программа поднимающая socket на порту указанном как параметр запуска (по умолчаню 8080) и работающая до нажатия Ctrl+C.

Сервер должен поддерживать операцию добавление задания в очередь, взять очередное задание и подтвердить его выполнение. Если задание взято на обработку и не отмечено как выполненное в течение 5 минут (еще один параметр запуска), оно должно вернуться в очередь.

Данные о заданиях должны записываться на диск. Если сервер выключили (не только штатно, например, завершили процесс) - то после запуска он должен продолжить с тем же списком заданий в тех же состояниях что и до падения. Нельзя отвечать клиенту очереди о выполнении операции изменения данных, если данные не записаны.

Поддерживаемые команды

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

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

После подтверждения выполнения задания его можно удалять

Команды

• Добавление задания ADD <queue> <length> <data>
  • Параметры
    • queue - имя очереди: строка без пробелов
    • length - длина содержимого задания: целое число не больше 10^6
    • data - содержимое: массив байт длины length
  • Ответ
    • id - уникальный идентификатор задания: строка без пробелов не длиннее 128 символов (не равная NONE)
  • Примечание
    • Если очереди с таким именем нет - то она создается
• Получение задания GET <queue>
  • Параметры
    • queue - имя очереди: строка без пробелов
  • Ответ
    • id - уникальный идентификатор задания: строка без пробелов не длиннее 128 символов
    • length - длина содержимого задания: целое число не больше 10^6
    • data - содержимое: массив байт длины length
  • Примечание
    • Если очереди с таким именем нет или в очереди нет заданий для обработки ( например, они все выполняются), то возвращается строка NONE
• Подтверждение выполнения ACK <queue> <id>
  • Параметры
    • queue - имя очереди: строка без пробелов
    • id - уникальный идентификатор задания: строка без пробелов не длиннее 128 символов
  • Ответ
    • OK
• Проверка IN <queue> <id>
  • Параметры
    • queue - имя очереди: строка без пробелов
    • id - уникальный идентификатор задания: строка без пробелов не длиннее 128 символов
  • Ответ
    • YES - если такое задание присутствует в очереди (не важно выполняется или нет)
    • NO - если такого задания в очереди нет "# task_quque"