Thinkphp6 baiy/think-async redis 异步代码执行/异步延迟执行/异步事件订阅

Dear 丶 2021-09-08 19:36 1034阅读 0赞

### 配置文件async.php ###

<?php

use Baiy\\ThinkAsync\\Subscribe\\ConfigFileEventGetter;  
use Baiy\\ThinkAsync\\Subscribe\\DemoSubscriber;  
use crmeb\\subscribes\\DemoAsyncSubscriber;  
use crmeb\\subscribes\\DemoAsyncSubscriber01;

return \[  
    // 异步执行默认队列  
    'async\_exec\_method\_queue'        => 'async\_exec\_method',  
    // 异步执行自定义队列  
    'async\_exec\_method\_custom\_queue' => \[  
        'async\_exec\_method\_custom' => '自定义异步执行队列',  
        'async\_exec\_method\_custom01' => '自定义异步执行队列01',  
    \],

// 异步订阅默认队列名称  
    'subscribe\_default\_queue'        => 'subscribe\_default',  
    // 异步订阅事件获取类  
    'subscribe\_event\_get\_class'      => ConfigFileEventGetter::class,  
    // 异步订阅事件配置(可通过修改\`subscribe\_event\_get\_class\`改变配置来源)  
    'subscribe\_event\_config'         => \[  
        \[  
            'name'       => 'demo',  
            'title'      => '演示事件',  
            'queue'      => 'async\_subscribe\_demo', // 事件处理队列 为空使用异步订阅默认队列  
            // 事件订阅者配置  
            'subscriber' => \[  
                \[DemoSubscriber::class, 'handle'\],  
            \]  
        \],  
        \[  
            'name'       => 'zidingyishijian',  
            'title'      => '自定义事件',  
            'queue'      => 'async\_subscribe\_zidingyi',  
            // 事件订阅者配置  
            'subscriber' => \[  
                \[DemoAsyncSubscriber::class, 'handle'\],  
                \[DemoAsyncSubscriber01::class, 'handle'\],  
            \]  
        \],  
    \]  
\];

### 异步代码执行/异步延迟执行/异步事件订阅文件PublicController.php ###

<?php

namespace app\\api\\controller\\demo;

use Baiy\\ThinkAsync\\Facade\\Async;

/\*\*  
 \* 公共类  
 \* Class PublicController  
 \* @package app\\api\\controller  
 \*/  
class PublicController  
\{  
    //异步代码执行/异步延迟执行/异步事件订阅  
    //http://meishu.local/api/demo/demoasync  
    public function demoasync()\{  
        // 异步执行默认队列  
        //Async::exec(self::class, 'test', 'exec');  
        //异步执行代码使用自定义队列  
        //Async::execUseCustomQueue(self::class, 'test','async\_exec\_method\_custom', 'exec');  
        //Async::execUseCustomQueue(self::class, 'test','async\_exec\_method\_custom01', 'exec');  
        // 异步延迟执行默认队列 延迟10秒  
        //Async::delay(10, self::class, 'test', 'delay');  
        // 异步延迟执行默认队列 延迟10秒  
        //Async::delayUseCustomQueue(10, self::class, 'test','async\_exec\_method\_custom', 'delay');  
        // 获取所有队列标示  
        //var\_dump(Async::queue());  
        // 获取队列长度  
        //var\_dump(Async::queueSize('async\_exec\_method\_custom'));  
        // 获取队列名称  
        //var\_dump(Async::queueName('async\_exec\_method\_custom'));  
          
        //事件订阅  
        //事件触发  
        Async::trigger('zidingyishijian',33,'lisi');  
        echo 11;  
          
    \}

public static function test()  
    \{  
        $arr\['name'\] = mt\_rand(111111,999999);  
        $res = Db::name('demo')->insert($arr);  
    \}  
\}

### 事件订阅者DemoAsyncSubscriber.php ###

<?php

namespace crmeb\\subscribes;  
use think\\facade\\Db;

class DemoAsyncSubscriber

\{  
    public static function handle($id,$name)\{  
        $arr\['name'\] = $id.$name;  
        $res = Db::name('demo')->insert($arr);  
    \}  
      
\}

### 事件订阅者DemoAsyncSubscriber01.php ###

<?php

namespace crmeb\\subscribes;  
use think\\facade\\Db;

class DemoAsyncSubscriber01

\{  
    public static function handle($id,$name)\{  
        $arr\['name'\] = $name.$id;  
        $res = Db::name('demo')->insert($arr);  
    \}  
      
\}

### 执行命令： ###

php think queue:work --queue async\_subscribe\_zidingyi