В этой статье приведен пример, показывающий, как PHP использует упорядоченный набор redi для реализации очереди задержки. Подробности заключаются в следующем:
Очередь задержки – это очередь сообщений с функцией задержки. По сравнению с обычной очередью, она может принимать сообщения в указанное время.
Сценарии применения очереди с задержкой:
1. New users sign up, and send email or on-site letter after 10 minutes. Новые пользователи регистрируются и отправляют электронное письмо или письмо на сайт через 10 минут.
2. If the user fails to pay 30 minutes after placing an order, the order will be void automatically. Если пользователь не оплатит через 30 минут после размещения заказа, заказ будет автоматически аннулирован.
Мы используем упорядоченный набор redi для реализации простой очереди с задержкой. Мы сериализуем данные сообщения как значение набора Z, учитываем время обработки сообщения как оценку и каждый раз получаем сообщение через zrangebyscore для обработки.
php
class DelayQueue
{
protected $prefix = 'delay_queue:';
protected $redis = null;
protected $key = '';
public function __construct($queue, $config = [])
{
$this->key = $this->prefix . $queue;
$this->redis = new Redis();
$this->redis->connect($config['host'], $config['port'], $config['timeout']);
$this->redis->auth($config['auth']);
}
public function delTask($value)
{
return $this->redis->zRem($this->key, $value);
}
public function getTask()
{
//Get the task, take 0 and current time as interval, return a record
return $this->redis->zRangeByScore($this->key, 0, time(), ['limit' => [0, 1]]);
}
public function addTask($name, $time, $data)
{
//Add tasks, take time as score, and sort the task queue from small to large
return $this->redis->zAdd(
$this->key,
$time,
json_encode([
'task_name' => $name,
'task_time' => $time,
'task_params' => $data,
], JSON_UNESCAPED_UNICODE)
);
}
public function run()
{
//Take only one task at a time
$task = $this->getTask();
if (empty($task)) {
return false;
}
$task = $task[0];
//There is the possibility of concurrency. Here, we use the return value of zrem to determine who grabs the task
if ($this->delTask($task)) {
$task = json_decode($task, true);
//Processing tasks
Echo 'task:'. $task ['task_ Name '].' running time: '. Date ('y-m-d H: I: s'). PHP_ EOL;
return true;
}
return false;
}
}
$dq = new DelayQueue('close_order', [
'host' => '127.0.0.1',
'port' => 6379,
'auth' => '',
'timeout' => 60,
]);
$dq->addTask('close_order_111', time() + 30, ['order_id' => '111']);
$dq->addTask('close_order_222', time() + 60, ['order_id' => '222']);
$dq->addTask('close_order_333', time() + 90, ['order_id' => '333']);Затем мы пишем PHP-скрипт для обработки задач в очереди.
'127.0.0.1',
'port' => 6379,
'auth' => '',
'timeout' => 60,
]);
while (true) {
$dq->run();
usleep(100000);
}
Для получения дополнительной информации о PHP читатели, интересующиеся этим сайтом, могут ознакомиться со следующими темами: краткое изложение навыков программирования баз данных PHP + redis, вводный курс объектно-ориентированного программирования PHP, вводный курс базовой грамматики PHP, навыки работы с массивами PHP, краткое описание использования строк PHP “Руководство по работе с базой данных PHP + MySQL” и “Краткое изложение общих навыков работы с базой данных PHP”.
Я надеюсь, что эта статья будет полезна для программирования на PHP.