PHP7의 Reids 키 공간 알림은 TP5와 협력하여 분산 지연 작업을 구현합니다.-PHP7-php.cn

PHP7의 Reids 키 공간 알림은 TP5와 협력하여 분산 지연 작업을 구현합니다.

藏色散人

풀어 주다： 2023-02-17 12:04:02

앞으로

3169명이 탐색했습니다.

이 글은 분산 지연 작업을 구현하기 위한 Reids 키 공간 알림과 TP5를 주로 소개합니다. 도움이 필요한 친구들에게 도움이 되길 바랍니다!

PHP7의 Reids 키 공간 알림은 TP5와 협력하여 분산 지연 작업을 구현합니다.

테스트 환경: windows 10 + phpStudy

redis 구성 파일 redis.windows.conf

notify-keyspace-events "Ex"

로그인 후 복사

restart the redis service

PHP7의 Reids 키 공간 알림은 TP5와 협력하여 분산 지연 작업을 구현합니다.

콘솔 창을 다시 열고

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초 후에 만료되는 키 사용자 이름을 추가합니다.
PHP7의 Reids 키 공간 알림은 TP5와 협력하여 분산 지연 작업을 구현합니다.

명령줄이 완료되었습니다.

II , 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) 메소드의 두 번째 매개변수는 콜백 함수입니다. 여기서는 클로저를 콜백으로 사용합니다.

공식 설명: 클로저라고도 불리는 익명 함수를 사용하면 지정된 이름 없이 일시적으로 함수를 생성할 수 있습니다. 콜백 함수 인수로 가장 일반적으로 사용되는 값입니다. 물론 다른 응용 프로그램도 있습니다.

3. TP5 프로젝트의 루트 디렉터리에서 pay 명령 도구를 실행합니다

php think pay psubscribe

로그인 후 복사

4. 새 콘솔 창 터미널을 엽니다

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. 만료된 키를 받았는지 확인하세요

PHP7의 Reids 키 공간 알림은 TP5와 협력하여 분산 지연 작업을 구현합니다.