消息队列的概念、原理和场景
在高并发的时候，程序往往无法做到及时的处理。我们引入一个中间的系统，来进行分流和减压。
所以从本质上讲：消息队列就是一个队列结构的中间件。也就是说，你把消息和内容放入这个容器之后就可以直接返回，不用等它后期处理的结果。另外会有一个程序，读取这些数据并按照顺序处理。
1、队列结构的中间件
2、消息放入后，不必立即处理
3、由订阅者/消费者按顺序处理
也就是说：当遇到一个比较大或者耗时比较长的环节的时候，而同时你的业务又不需要立即知道这个环节的结果，使用消息队列是好的选择。
知识付费的拼团功能使用的就是消息队列功能；把每个拼团订单都储存在消息队列中，拼团完成或拼团结束就可以自动处理这个订单。
applicationindexcontrollerPushJob
代码语言：javascript复制/*** 一个使用了队列的 action*/
public static function actionWithDoPinkJob(array $data,string $name=''){
try{
// 1.当前任务将由哪个类来负责处理。
$jobHandlerClassName = 'appindexjobPullDoPink';
// 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']) return true;
$timewait = $data['pink_time'] 300;
// 4.将该任务推送到消息队列，等待对应的消费者去执行
$isPushed = Queue::later($timewait, $jobHandlerClassName , $jobData , $jobQueueName );
}
if( $isPushed !== false ){
return 1;
}else{
return 1;
}
}catch (ErrorException $e){
echo $e->getMessage();
}
}applicationindexjobPullDoPink
代码语言：javascript复制/**
* 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){
return true;
}
拼团使用，在订单生成完成后，把参数加入$do_job_pink数组中
PushJob::actionWithDoPinkJob($do_job_pink,’doPinkJob’);
在applicationindexjobPullDoPink下加如下面的方法用来接受处理数据
/**
* 根据消息中的数据进行实际的业务处理...
*/
private function doPinkJob($data)
{
return true;
}
如果需要加新的消息队列可以设置不同的名称即可
PushJob::actionWithDoPinkJob($do_job_pink,’名称’);
applicationindexjobPullDoPink：
private function 名称($data)
{
return true;
}完成后重新启动消息队列
最后
如果你觉得这篇文章对你有点用的话，麻烦请给我们的开源项目点点star:http://github.crmeb.net/u/defu不胜感激 ！
