TP5系列 | Console 命令行（CLI模式）

cd tp5
php think make:command commom/TestJobs

<?php
namespace app\command;

use think\console\Command;
use think\console\Input;
use think\console\Output;

class TestJobs extends Command
{
    protected function configure()
    {
        // 指令配置
        $this->setName('app\command\testjobs');
        // 设置参数
    }

    protected function execute(Input $input, Output $output)
    {
        // 指令输出
        $output->writeln('app\command\testjobs');
    }
}

class TestJobs extends Command
{
    protected function configure()
    {
        // 指令配置
        $this->setName('hello')->setDescription('This is Test cmd eg: hello:add | hello:edit');
        // 设置参数
        $this->addArgument('type', 1, 'this is test Jobs');
    }

    protected function execute(Input $input, Output $output)
    {
        // 指令输出
        $type = $input->getArgument('type');
        if ($type == 'hello:add') {
            $this->helloAdd();
        } elseif ($type == 'hello:edit') {
            $this->helloEdit();
        }
    }

    /**
     * @Desc: 自定义方法1
     * @Author: Tinywan
     */
    public function helloAdd()
    {
        Log::error('自定义命令行：'.__METHOD__);
    }

    /**
     * @Desc: 自定义方法2
     * @Author: Tinywan
     */
    public function helloEdit()
    {
        Log::error('自定义命令行：'.__METHOD__);
    }
}

return [
    \app\command\TestJobs::class
];

$ php think

Available commands:
  build              Build Application Dirs
  clear              Clear runtime file
  hello              This is Test cmd eg: hello:add | hello:edit

$ php think hello hello:add

[2019-07-22T10:57:57+08:00][ error ] 自定义命令行：app\command\TestJobs::helloAdd
error

$ php think hello hello:edit

[2019-07-22T10:57:57+08:00][ error ] 自定义命令行：app\command\TestJobs::helloAdd
error
[2019-07-22T10:59:50+08:00][ error ] 自定义命令行：app\command\TestJobs::helloEdit
error

nohup /usr/bin/php /var/www/tp5/think hello hello:edit > /dev/null 2> /dev/null &

class Jobs extends Command
{
    protected function configure()
    {
        $this->addArgument('type', 1, 'this is type');
        $this->setName('jobs')->setDescription('order_count|redis-notify-key-events|transaction_account_tables');
    }

    /**
     * 执行任务
     */
    protected function execute(Input $input, Output $output)
    {
        $type = $input->getArgument('type');
        if ($type == 'redis-notify-key-events') {
            $this->notifyKeySpaceEvents();
        } 
    }

    /**
     * @desc: Redis键过期事件
     */
    private function notifyKeySpaceEvents()
    {
        $service = new RedisSubscribe();
        $service->subscribe();
    }

class RedisSubscribe
{
    public function subscribe()
    {
        $redis = BaseRedis::plocal();
        $redis->setOption(\Redis::OPT_READ_TIMEOUT, -1);
        // 这里是键空间过期是选用的1号数据库
        $redis->psubscribe(array('__keyevent@1__:expired'), function ($redis, $pattern, $chan, $msg) {
            Log::info('[订阅事件] 过期KEY ' . $msg);
            $originData = explode(':', $msg);
            $event_key = $originData[1] ?? '0';
            $event_status = $originData[0] ?? '0';
            // 根据事件类型做出业务处理既可
        });
    }
}