PHP的Laravel框架中使⽤消息队列queue及异步队列的⽅
法
简爱好词好句好段queue配置
⾸先说明⼀下我之前的项⽬中如何使⽤queue的。古天乐演的电影
我们现在的项⽬都是⽤的symfony，⽼⼀点的项⽬⽤的symfony1.4，新⼀点的项⽬⽤的都是symfony2。symfony⽤起来整体感觉还是很爽的，尤其symfony2，整体上来讲使⽤了很多java⾥⾯框架的设计思想。但是他不⽀持queue。在symfony，我们使⽤queue也经历了⼏个过程。最开始使⽤张堰同学的httpsqs。这个简单使⽤，但是存在单点。毕竟我们的项⽬还是正式对外服务的，所以我们研究了Apache旗下的开源项⽬ActiveMQ，研究研究发现还有Apache旗下还有更新的MQ，那就是Apollo。最后我们决定使⽤的Apollo。
queue在我们的项⽬中主要的应⽤场景就是异步处理⼀些⽐较耗时的功能，⽐如同步第三⽅数据、数据有变动了同步通知到我们的第三⽅数据使⽤者等等。我们⼤致的思路是这样的，在各个controller⾥⾯如果需要异步处理的，就把⼀个json对象encode⼀下，塞到Apollo⾥⾯。再写⼀个work的Command，在这个Command中解析json对象，根据⾥⾯的action和参数决定来调⽤不同的⽅法处理。根据业务需要同
时在不同的机器上运⾏Command作为守护进程⼀直跑着，也算实现异步多任务处理应⽤的⽅案。就这么⼀直使⽤着，直到发现了laravel。打算研究⼀下。如果可能替代⼀下也不是不可能。呵呵。
由于才开始学习，当然直接上laravel5。routes、controller、view都基本上和symfony差别不到，上⼿倒是不困难。最后研究⼀下queue。
1、安装laravle，使⽤compor，倒是很简单。
compor global require "laravel/installer=~1.1"
vi ~/.bash_profile
把~/.compor/vendor/bin 加⼊到环境变量中。
source ~/.bash_profile
就可以直接在命令⾏中使⽤laravel了。试⼀下。
laravel -V
能够看到下⾯的，就代表成功了。
Laravel Installer version 1.2.1
2、创建项⽬。
laravel new guagua
3、配置redis和queue。
4、创建controller，
经典英文电影台词php artisan make:controller DefaultController
在controller的action中push100个queue的任务。
for($i = 0; $i < 100; $i ++) {
7年级上册历史Queue::push(new SendEmail("ssss".$i));
}
5、创建queue的Command
php artisan make:command SendEmail --queued
修改app/Commands/SendEmail.php，添加⼀个私有变量。
protected $msg;
同时修改构造函数。
public function __construct($msg)
{
$this->msg = $msg;
}
再修改的handle⽅法
public function handle() {
柴胡舒肝丸的成分
sleep(4);
echo $this->msg."\t".date("Y-m-d H:i:s")."\n";
$this->delete();
}
6、修改routes
Route::get('/', [
'as' => 'index',
'us' => 'DefaultController@index'
]);
7、监听queue
php artisan queue:listen
为了验证多任务处理，我们同时开三个窗⼝运⾏同样的命令。
8、⽤laravel内建的rver启动服务
观沧海pptphp artisan rve --port 8080
在控制台就能看到各个queue执⾏的情况了，如下图。可以看到100个任务被三个work平分了。
到此，基本达到了我想要的效果。验证了laravel可以简单实现queue，并且可以多任务处理。
make command⽣成的代码中u App\Commands\Command ，但是运⾏时提⽰没有这个⽂件。解决办法，修改为 u Illuminate\Console\Command; 不知道为什么会出现这个低级问题，难道是我mac系统问题，还是我的⼈品问题。
在controller的action中push队列的时候，没有异步执⾏，还是在action的脚本中执⾏的。发现是配置问题，原来不仅仅要修改config中的queue.php，还要修改.evn中相关配置。虽然问题解决了，但是还是觉得蛋疼，不能理解。还需要在学习学习laravel。
异步队列使⽤⽅法
1.配置
关于队列的定义，这⾥就不作介绍了。我们要使⽤异步队列就有两个关键：
（1）存储队列的地⽅
（2）执⾏任务的服务
打开 config/queue.php ，这是Laravel5关于队列的配置⽂件。⾸先我们可以通过 default 参数指定默认队列驱动，默认配置是sync , 这是同步队列，我们要做异步队列⾸先就要改变这⾥。假设我们⽤ databa 作为驱动，队列任务将会存放在数据库中，⽽我们后⾯会另外启动⼀个后台服务来处理队列任务，这就是异步⽅式了。
'default' => 'databa'
修改完配置后，我们需要创建⼀个表来存放队列任务，Laravel5已经在⾃带artisan命令中内置了⼀个指令⽤来⽣成数据迁移，只需要两条命令即可，当然你得实现配置好数据库连接。
php artisan queue:table
php artisan migrate叠花
这样就⾃动在数据库中创建了 jobs 表。
2.启动队列监听服务
通过下⾯这条指令启动队列监听服务，它会⾃动处理 jobs 表中的队列任务：
php artisan queue:listen
在linux中，如果想让它在后台执⾏，可以这样：
nohup php artisan queue:listen &
3.添加队列任务
关于队列任务的添加，⼿册⾥说的⽐较详细，这⾥就简单举个例⼦吧。
⾸先，通过artisan创建⼀个队列命令：
php artisan make:command SendEmail --queued
这样会⽣成 app/Commands/SendEmail.php 这个类⽂件，这个类会被标识为队列命令，你可以在 handle ⽅法中写⾃⼰的业务逻辑。三眼一板
在控制器中，可以简单通过 Bus::dispatch 分发任务:
Bus::dispatch(new \App\Commands\SendEmail());
你会发现任务不会⽴即执⾏，⽽是被放到 jobs 表中，由队列监听服务处理。
更详细的⽤法建议参考 command bus 和 queue 相关的⼿册章节。
