yii_swoole_task

在YII框架中结合了swoole 的task 做了异步处理。 本例中 主要用到
1、protected/commands/ServerCommand.php 用来做server。
2、protected/event/下的文件 这里是在异步中的具体实现。

客户端调用参照 TestController

  1. <?php
  2. class TestController extends Controller{
  3. public function actionTT(){
  4. $message['uid'] = 2;
  5. $message['email'] = '83212019@qq.com';
  6. $message['title'] = '接口报警邮件';
  7. $message['contents'] = "'EmailEvent'接口请求过程出错! 错误信息如下:err_no:'00000' err_msg:'测试队列' 请求参数为:'[]'";
  8. $message['type'] = 2;
  9. $data['param'] = $message;
  10. $data['class'] = 'Email';
  11. $client = new EventClient();
  12. $data = $client->send($data);
  13. }
  14. }
  15. ?>

有个task表是用来记录异步任务的。如果失败重试3次。sql在protected/data/sql.sql里。 如有意见欢迎拍砖 83212019@qq.com