Home > Backend Development > PHP7 > PHP7's Reids key space notification cooperates with TP5 to implement distributed delayed tasks

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

藏色散人
Release: 2023-02-17 12:04:02
forward
3296 people have browsed it

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!

PHP7s Reids key space notification cooperates with TP5 to implement distributed delayed tasks

Test environment: windows 10 phpStudy

Configure the redis configuration file redis.windows.conf

notify-keyspace-events "Ex"
Copy after login

Restart the redis service

PHP7s Reids key space notification cooperates with TP5 to implement distributed delayed tasks

Reopen a console window and execute the command

psubscribe __keyevent@0__:expired
Copy after login

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
Copy after login

Open another terminal, redis-cli enter redis, add a key username that expires in 6 seconds:
PHP7s Reids key space notification cooperates with TP5 to implement distributed delayed tasks

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();
    }
}
Copy after login

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);
        });
    }
}
Copy after login

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
Copy after login

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>
Copy after login

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

PHP7s Reids key space notification cooperates with TP5 to implement distributed delayed tasks

6. The final result is as follows

PHP7s Reids key space notification cooperates with TP5 to implement distributed delayed tasks

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!

Related labels:
Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Popular Tutorials
More>
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template