thinkphp6 think-queue消息队列

这几天一直都在研究tp6中的消息对列问题。顾名思义，消息对列，其实就是一个生产者和消费者的一种模式。

生产者：并非我们生活中工厂时的生产。在代码世界里，生产者我们可以简单理解为我们发出一个事件处理程序，需要有一个“人”来去处理这个程序，就好比页面上有一个按纽，但这个按纽是由谁来点击触发。那么，这个时候，就会有一个消费者的名字出现。
消费者：也并非我们生活中市场营销中的消费者，在程序中的消费者就是刚上面生产者“生产”出来的一个程序，是有“我（当前处理人员）”来消费（执行）。

当然，这生产者和消费者的概念是我自己的理解。可能我讲的会跟你们在百度上找的会有所不同。目前我是这么理解的，以后我有更深入的理解，我会再做补充。

OK，现在来说下重点，就是消息队列的用法。

假如在开发中，有这么一个场景，订单下单后，如果半小时没有支付，那么这个订单就自动关闭。其实，这个场景在面试中也经常会被问到。当然，这里面会有很多种解答，比如说用Linux系统的定时任务，或者是mysql里面也会有一个任务计划等等。 而运用tp6中的扩展 think-queue 也一样可以实现。

composer require topthink/think-queue #安装

安装完之后，如果没有特别的需求，保持默认也是可以的。当然，在百度之下，也有说结合redis一起来完成（这个我还没有去深入研究，先把这个理顺先吧）

	//控制器中
    namespace app\index\controller;
	use app\BaseController;
	use think\facade\Db;
	use think\facade\Cache;
	use think\facade\Queue;


	class Index extends BaseController{
		public function index(){
			$g_id = input('get.g_id'); //假设这儿是订单id
			$jobHandlerClassName = 'app\job\Test'; //这个我们可以简单理解为消费者的类
			$jobQueueName = 'qqaa12'; //注意这个名字（名字随意取，无所谓，但等回在终端执行的时候需要用上）
			$orderData = [ //这个是需要传到消费者的数据
				'g_id'	=>	$g_id,
			];
			Db::name('test')->insert(['name'=>'小冰冰','age'=>18,'g_id'=>$g_id]);
			$isPushed = Queue::later(10, $jobHandlerClassName, $orderData, $jobQueueName); //这儿的10是指10秒后执行队列任务
			if($isPushed !== false){
				echo '队列添加成功' . date('Y-m-d H:i:s');
			}else{
				echo '插入失败了' . date('Y-m-d H:i:s'); 
			}
		}


		
	}

//消费者
namespace app\job; //需要注意命名空间及文件路径，需要跟上面定义消费者的一至
	use think\queue\Job;
	use think\facade\Db;


	class Test{
        //这个方法的名字是固定写法，只能是 【fire】写其他的无效
		public function fire(Job $job , $data){//这儿的$data是刚前面传来的数据
			$g_id = $data['g_id'];
			Db::name('test')->where(['g_id'=>$g_id])->update(['age'=>100]);
			$job->delete(); //执行完成之后记得需要删除任务
		}
	}

#在终端执行（指的是在项目跟目录下执行）
 php think queue:listen --queue qqaa12  #注意qqaa12需要跟刚在代码中定义的一要致