登录  /  注册
首页 > 后端开发 > PHP7 > 正文

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

藏色散人
发布: 2019-04-13 11:03:53
转载
2778人浏览过

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

1e572951d89f44eef79b80328c622bf.png

测试环境:windows 10 + phpStudy

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

notify-keyspace-events "Ex"
登录后复制

重启redis服务

f82303ef78b1835d19a4c809e5bed8f.png

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

psubscribe __keyevent@0__:expired
登录后复制

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

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
登录后复制

再开启一个终端,redis-cli 进入 redis,新增一个 6秒过期的键 username:
05c43475f1596a28dbecf6ea32ec16f.png

命令行完成了

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

命令行工具的使用:https://www.kancloud.cn/manual/thinkphp5_1/354146

1、新建命令行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、编写脚本 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);
        });
    }
}
登录后复制

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

官方解释:匿名函数(Anonymous functions),也叫闭包函数(closures),允许 临时创建一个没有指定名称的函数。最经常用作回调函数(callback)参数的值。当然,也有其它应用的情况。

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

php think pay psubscribe
登录后复制

4、新打开console 窗口终端

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

7b0aefb0bbf05f1ab67c300e1182e74.png

6、最终的结果如下所示

aa6a20826cadb091c3cca0d72c04bc6.png

更高级的慢慢扩展

1、自动取消订单

2、订单完成后发送短信

3、延迟任务等等

相关推荐:《PHP7教程

以上就是PHP7之Reids键空间通知配合TP5 实现分布式延时任务的详细内容,更多请关注php中文网其它相关文章!

智能AI问答
PHP中文网智能助手能迅速回答你的编程问题,提供实时的代码和解决方案,帮助你解决各种难题。不仅如此,它还能提供编程资源和学习指导,帮助你快速提升编程技能。无论你是初学者还是专业人士,AI智能助手都能成为你的可靠助手,助力你在编程领域取得更大的成就。
来源:Tinywan网
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
作者最新文章
最新问题
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2024 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号