PHP7之Reids键空间通知配合TP5 实现分布式延时任务

Posted 2021-03-30 php中文网最新课程

源 / php中文网      源 / www.php.cn

本篇文章主要给大家介绍Reids 键空间通知配合TP5 实现分布式延时任务，希望对需要的朋友有所帮助！

(查看原文请点击本文末尾左下角：阅读原文)

测试环境：windows 10 + phpStudy

配置redis配置文件 redis.windows.conf

notify-keyspace-events "Ex"

重启redis服务

重新打开一个控制台窗口，执行命令

psubscribe __keyevent@0__:expired

打开新窗口执行了阻塞订阅操作后的终端，等会会有信息输出：

C:Usersadmin>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

再开启一个终端，redis-cli 进入 redis，新增一个 6秒过期的键 username：

命令行完成了

二、借助TP5.1 的命令行工具

命令行工具的使用：

https://www.kancloud.cn/manual/thinkphp5_1/354146

1、新建命令行pay

<?php

/**.-------------------------------------------------------------------------------------------------------------------

 * |  Github: https://github.com/Tinywan

 * '------------------------------------------------------------------------------------------------------------------*/

  

namespace appcommoncommand;

  

use apppayserviceRedisSubscribe;

use thinkconsoleCommand;

use thinkconsoleInput;

use thinkconsoleinputArgument;

use thinkconsoleOutput;

  

class Pay extends Command

{

    // 配置指令

    public function configure()

    {

        $this->setName('pay')

          ->addArgument('type', Argument::REQUIRED, "the type of the task that pay needs to run")

          ->setDescription('this is payment system command line tools');

    }

  

    // 执行指令

    public function execute(Input $input, Output $output)

    {

        $type = $input->getArgument('type');

        if ($type == 'psubscribe') {

            // 发布订阅任务

            $this->psubscribe();

        }

    }

  

    /**

     * Redis 发布订阅模式

     */

    private function psubscribe()

    {

        $service = new RedisSubscribe();

        $service->sub();

    }

}

2、编写脚本 RedisSubscribe.php

<?php

/**.-------------------------------------------------------------------------------------------------------------------

 * |  Github: https://github.com/Tinywan

 * '------------------------------------------------------------------------------------------------------------------*/

  

namespace apppayservice;

  

use redisBaseRedis;

use thinkfacadeLog;

  

class RedisSubscribe

{

    public function sub()

    {

        Log::error(get_current_date().'--过期事件的订阅-- ');

        $redis = BaseRedis::location(); //这里是直接连接本地redis

        $redis->setOption(Redis::OPT_READ_TIMEOUT, -1);

        $redis->psubscribe(array('__keyevent@0__:expired'), function ($redis, $pattern, $chan, $msg) {

            Log::error('[1]--过期事件的订阅 ' . $msg);

        });

    }

}

说明：

psubscribe( patterns,patterns,callback ) 方法的第二个参数为一个回调函数，这里我使用闭包作为一个回调。

官方解释：

匿名函数（Anonymous functions），也叫闭包函数（closures），允许 临时创建一个没有指定名称的函数。最经常用作回调函数（callback）参数的值。当然，也有其它应用的情况。

3、在TP5 项目根目录执行pay 命令工具

php think pay psubscribe

4、新打开console 窗口终端

C:Usersadmin>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、查看打日志文件，看有没有接收到过期的key

6、最终的结果如下所示

更高级的慢慢扩展

1、自动取消订单

2、订单完成后发送短信

3、延迟任务等等

-END-

声明：本文选自「 php中文网 」，搜索「 phpcnnew 」即可关注！

▼请点击下方：“阅读原文”，在线查看全部文章内容！