PHP7's Reids key space notification cooperates with TP5 to implement distributed delayed tasks

This article mainly introduces Reids key space notification and TP5 to implement distributed delay tasks. I hope it will be helpful to friends in need!

Test environment: windows 10 phpStudy

Configure the redis configuration file redis.windows.conf

notify-keyspace-events "Ex"

Restart the redis service

Reopen a console window and execute the command

psubscribe __keyevent@0__:expired

Open a new window and execute the terminal after blocking the subscription operation. After a while, there will be information output:

C:\Users\admin>redis-cli
127.0.0.1:6379> psubscribe __keyevent@0__:expired
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "__keyevent@0__:expired"
3) (integer) 1

Open another terminal, redis-cli enter redis, add a key username that expires in 6 seconds:

The command line is completed

2. With the help of TP5 .1 command line tools

Use of command line tools: https://www.kancloud.cn/manual/thinkphp5_1/354146

1. Create a new command line pay

<?php
/**.-------------------------------------------------------------------------------------------------------------------
 * |  Github: https://github.com/Tinywan
 * &#39;------------------------------------------------------------------------------------------------------------------*/
 
namespace app\common\command;
 
use app\pay\service\RedisSubscribe;
use think\console\Command;
use think\console\Input;
use think\console\input\Argument;
use think\console\Output;
 
class Pay extends Command
{
    // 配置指令
    public function configure()
    {
        $this->setName(&#39;pay&#39;)
          ->addArgument(&#39;type&#39;, Argument::REQUIRED, "the type of the task that pay needs to run")
          ->setDescription(&#39;this is payment system command line tools&#39;);
    }
 
    // 执行指令
    public function execute(Input $input, Output $output)
    {
        $type = $input->getArgument(&#39;type&#39;);
        if ($type == &#39;psubscribe&#39;) {
            // 发布订阅任务
            $this->psubscribe();
        }
    }
 
    /**
     * Redis 发布订阅模式
     */
    private function psubscribe()
    {
        $service = new RedisSubscribe();
        $service->sub();
    }
}

2. Write the script RedisSubscribe.php

<?php
/**.-------------------------------------------------------------------------------------------------------------------
 * |  Github: https://github.com/Tinywan
 * &#39;------------------------------------------------------------------------------------------------------------------*/
 
namespace app\pay\service;
 
use redis\BaseRedis;
use think\facade\Log;
 
class RedisSubscribe
{
    public function sub()
    {
        Log::error(get_current_date().&#39;--过期事件的订阅-- &#39;);
        $redis = BaseRedis::location(); //这里是直接连接本地redis
        $redis->setOption(\Redis::OPT_READ_TIMEOUT, -1);
        $redis->psubscribe(array(&#39;__keyevent@0__:expired&#39;), function ($redis, $pattern, $chan, $msg) {
            Log::error(&#39;[1]--过期事件的订阅 &#39; . $msg);
        });
    }
}

Description: The second parameter of the psubscribe(patterns, patterns, callback) method is a callback function. Here I use closure as a callback.

Official explanation: Anonymous functions, also called closures, allow you to temporarily create a function without a specified name. The value most commonly used as a callback function argument. Of course, there are other applications as well.

3. Execute the pay command tool in the root directory of the TP5 project

php think pay psubscribe

4. Open a new console window terminal

C:\Users\admin>redis-cli
127.0.0.1:6379> setex UserName 10 Tinywan
OK
127.0.0.1:6379> get UserName
"Tinywan"
127.0.0.1:6379> get UserName
(nil)
127.0.0.1:6379>

5. Check the log file to see if it has been received Expired key

6. The final result is as follows

More advanced and slowly expand

1. Automatically cancel orders

2. Send text messages after the order is completed

3. Delay tasks, etc.

Related recommendations: "PHP7 Tutorial》

The above is the detailed content of PHP7's Reids key space notification cooperates with TP5 to implement distributed delayed tasks. For more information, please follow other related articles on the PHP Chinese website!