GTask — система задач

Введение

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

GTask поддерживает удалённое управление задачами, выполнение задач скриптов (в настоящее время поддерживается только Lua), разработчики могут создавать экземпляры задач и добавлять обработчики для экземпляров. Конфигурируя выполнение скрипта в обработчике, можно легко управлять задачами.

Компиляция и использование

Linux

./build/linux.sh

MaxOS

./build/macos.sh

После успешной компиляции в каталоге release будут созданы два файла: gtask и client, которые представляют собой программу сервера и клиентскую программу соответственно.

Запуск сервера

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

./release/gtask -cfg ./config/config.json

Подключение клиента к серверу

./release/client -h [host] -p 1126

На этом этапе потребуется ввести ключ, который является ключом инициализации сервера.

Документация по интерфейсу сервера

См. документацию по интерфейсу.

Описание команд клиента

Демонстрация клиента

Тестирование клиента

Используйте файл конфигурации по умолчанию и запустите сервер на локальном компьютере (localhost).

./release/client -h localhost -p 1126
secretKey:647851f2fcf6101aefa4a2c59a329a11c60300a4

# Создание задачи
> create job test
create job [test] success

# Выбор задачи
> use test
select job [test]

# Создать обработчик для задачи, проанализировать json и вывести соответствующие данные, выполнять каждые 3 секунды, циклически выполнять
test > create processor ./example/lua/test_json.lua 3 0 1 0
create processor success

# Запустить задачу
test > run
run job [test] success

# Добавить обработчик к задаче для отправки GET-запроса для получения данных веб-сайта, выполнять каждые 5 секунд, циклически выполнять
test > create processor ./example/lua/test_http_get.lua 5 0 1 0
create processor success

# Остановить и удалить текущую задачу
test > delete
>

Выполнение кода Lua

// Имя функции должно быть processor
// key(string): ключ задачи
// count(number): счётчик времени
function processor(key,count)
    data = {}
    data["hello"]="world"
    data["a"] = {}
    data["a"]["b"] = "b"
    data["a"]["c"] = {1,2,3,4,5,6}
    res = jsonMarshal(data)
    res = jsonUnMarshal(res)
    for k,v in ipairs(res["a"]["c"]) do
        print(k,v)
    end
    return true　// Если вернуть false, текущий обработчик завершит работу
end

Функции поддержки Lua

Шифрование

Время

Json

Http