Gearman — это сервер организации и распределения задач, или проще говоря сервер очереди сообщений. Gearman включает множество функциональных особенностей — балансировка, асинхронное/синхронное выполнение, приоритеты и т.п. В этой статье, на примере с PHP, реализуем простой механизм отложенной отправки почты.
Суть
Зачем вообще нужны такие решения, как Gearman, читайте в статье ““. Наша задача реализовать отложенную отправку почты, т.к. это довольно ресурсоемкая операция и может сильно влиять на скорость ответа приложения клиенту.
Установка
Установка происходит в два этапа. Сначала ставим сам сервер (исходники качаем ):
tar -xvzf gearmand-version.tar.gz cd gearmand ./configure make; make install
Теперь устанавливаем php расширение:
pecl download gearman-0.7.0 tar -xvf gearman-0.7.0.tgz cd gearman-0.7.0 phpize ./configure make make install
Не забываем добавить “extension=gearman.so” в php.ini. Если все хорошо, то phpinfo () покажет нам:
Клиент
В нашем клиенте (основное приложение) отправка email сообщений будет осуществляться путем регистрации новых задач на сервере Gearman:
...
$mail = array(
'to' => 'test@gmail.com',
'subject' => 'Привет',
'body' => 'Это тестовое сообщение',
);
...
# Подключаемся к серверу
$client= new GearmanClient();
$client->addServer();
# Регистрируем задачу для фонового выполнения
# "sendmail" - это тип задачи
# $mail - это данные письма
$result = $client->doBackground("sendmail", serialize($mail));
Обратите внимание, что PHP клиент принимает только строку в качестве данных о задаче, поэтому необходимо любой другой тип объектов сериализовать. Мы использовали асинхронное выполнение задач (метод doBackground), поэтому реальное время отправки почты не повлияет на скорость выполнения нашего приложения.
Обработчик задачи
Обработчик — это отдельное приложение (скрипт), который “слушает” сервер на предмет появления новых задач. Как только задача приходит — он выполняет связанную с ней логику (в нашем случае это будет отправка письма с помощью почтового сервера).
# Создаем "воркера" и подключаемся к серверу задач
$worker= new GearmanWorker();
$worker->addServer();
# Регистрируем обработчик события "sendmail"
# "send_mail" - это имя функции, объявленной ниже
$worker->addFunction("sendmail", "send_mail");
while (1)
{
echo "Ждем работы...\n";
$ret= $worker->work();
if ($worker->returnCode() != GEARMAN_SUCCESS) break;
}
# Функция реальной отправки почты
# В аргумент ей передается объект задачи
function send_mail($job)
{
$workload= $job->workload();
$data = unserialize($workload);
mail($data['to'], $data['subject'], $data['body']);
}