thinkphp5的消息队列详细教程

消息队列的概念、原理和场景

在高并发的时候，程序往往无法做到及时的处理。我们引入一个中间的系统，来进行分流和减压。

所以从本质上讲：消息队列就是一个队列结构的中间件。也就是说，你把消息和内容放入这个容器之后就可以直接返回，不用等它后期处理的结果。另外会有一个程序，读取这些数据并按照顺序处理。

1、队列结构的中间件

2、消息放入后，不必立即处理

3、由订阅者/消费者按顺序处理

也就是说：当遇到一个比较大或者耗时比较长的环节的时候，而同时你的业务又不需要立即知道这个环节的结果，使用消息队列是好的选择。

知识付费的拼团功能使用的就是消息队列功能；把每个拼团订单都储存在消息队列中，拼团完成或拼团结束就可以自动处理这个订单。

application\index\controller\PushJob

/*** 一个使用了队列的 action*/
public static function actionWithDoPinkJob(array $data,string $name=''){
    try{// 1.当前任务将由哪个类来负责处理。
        $jobHandlerClassName  = 'app\index\job\PullDoPink';// 2.当前任务归属的队列名称，如果为新队列，会自动创建
        $jobQueueName        = Config::get('queue_name','') ? Config::get('queue_name',''): 'doPinkJobQueue';// 3.当前任务所需的业务数据 . 不能为 resource 类型，其他类型最终将转化为json形式的字符串if($name){
        $jobData   =['pinkInfo'=> $data,'time'=>date('Y-m-d H:i:s'),'doName'=>$name];
        $isPushed = Queue::push($jobHandlerClassName , $jobData , $jobQueueName );}else{
       $jobData   =['pinkInfo'=> $data,'time'=>date('Y-m-d H:i:s')];if(!isset($data['pink_time'])||!$data['pink_time'])returntrue;
       $timewait = $data['pink_time']+300;// 4.将该任务推送到消息队列，等待对应的消费者去执行
      $isPushed = Queue::later($timewait, $jobHandlerClassName , $jobData , $jobQueueName );}if( $isPushed !==false){return1;}else{return1;}}catch (ErrorException $e){
        echo $e->getMessage();}}

application\index\job\PullDoPink

/**
 * fire方法是消息队列默认调用的方法
 * @param Job            $job      当前的任务对象
 * @param array|mixed    $data     发布任务时自定义的数据
 */
public function fire(Job $job,$data){// 有些消息在到达消费者时,可能已经不再需要执行了
    $isJobStillNeedToBeDone = $this->checkDatabaseToSeeIfJobNeedToBeDone($data);if(!$isJobStillNeedToBeDone){
        $job->delete();return;}if(isset($data['doName'])&& $data['doName']){
        $doName=$data['doName'];
        $isJobDone = $this->$doName($data);}else
        $isJobDone = $this->doPinkJob($data);if($isJobDone){// 如果任务执行成功， 记得删除任务
        $job->delete();}else{if($job->attempts()>3){
            $job->delete();}}}

/**
 * 有些消息在到达消费者时,可能已经不再需要执行了
 * @param array|mixed    $data     发布任务时自定义的数据
 * @return boolean                 任务执行的结果
 */
private function checkDatabaseToSeeIfJobNeedToBeDone($data){returntrue;}

拼团使用，在订单生成完成后，把参数加入$do_job_pink数组中

PushJob::actionWithDoPinkJob($do_job_pink,’doPinkJob’);

在application\index\job\PullDoPink下加如下面的方法用来接受处理数据

/**
 * 根据消息中的数据进行实际的业务处理...
 */
private function doPinkJob($data){returntrue;}

如果需要加新的消息队列可以设置不同的名称即可

PushJob::actionWithDoPinkJob($do_job_pink,’名称’);

application\index\job\PullDoPink：

private function 名称($data){returntrue;}

完成后重新启动消息队列

最后
如果你觉得这篇文章对你有点用的话，麻烦请给我们的开源项目点点star:http://github.crmeb.net/u/defu不胜感激 ！

免费获取源码地址：http://www.crmeb.com

PHP学习手册：https://doc.crmeb.com

技术交流论坛：https://q.crmeb.com