Thinkphp6 baiy/think-async redis异步函数执行/异步拖延执行/异步消息订阅

配置文件async.php

 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

insert($arr);  
}  
}

### 事件订阅者DemoAsyncSubscriber.php

insert($arr);  
}  

}  

事件订阅者DemoAsyncSubscriber01.php

insert($arr);  
}  

}

执行命令：

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