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']);
}
Полезные ссылки
Related posts:
Комментариев нет:
Отправить комментарий