PHP的Laravel框架中使用消息队列queue及异步队列的方法

概述介绍《PHP应用：PHP的Laravel框架中使用消息队列queue及异步队列的方法》开发教程，希望对您有用。

《：PHP的Laravel框架中使用消息队列queue及异步队列的方法》要点：
本文介绍了：PHP的Laravel框架中使用消息队列queue及异步队列的方法，希望对您有用。如果有疑问，可以联系我们。

queue配置PHP利用

首先阐明一下我之前的项目中如何使用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,使用composer,却是很简单.

composer global require "laravel/installer=~1.1"vi ~/.bash_profile

把~/.composer/vendor/bin 参加到环境变量中.

source ~/.bash_profile

就可以直接在命令行中使用laravel了.试一下.PHP利用

laravel -V

能够看到下面的,就代表胜利了.

Laravel Installer version 1.2.1

2、创立项目.

laravel new guagua

3、配置redis和queue. PHP利用

4、创立controller,

PHP artisan make:controller DefaultController

在controller的action中push100个queue的任务.PHP利用

for($i = 0; $i < 100; $i ++) {  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','uses' => 'DefaultController@index']);

7、监听queuePHP利用

PHP artisan queue:Listen

为了验证多任务处置,我们同时开三个窗口运行同样的命令.

8、用laravel内建的server启动服务PHP利用

PHP artisan serve --port 8080 

打开浏览器,拜访http://localhost:8080/页面.当然也可以用Nginx,apache之类的.但是需要各种配置,还是内建的使用方便.

在控制台就能看到各个queue执行的环境了,如下图.可以看到100个任务被三个work平分了.

PHP利用

到此,基本达到了我想要的效果.验证了laravel可以简单实现queue,而且可以多任务处理.

make command生成的代码中use App\Commands\Command,但是运行时提示没有这个文件. 解决方法,修改为 use Illuminate\Console\Command; 不知道为什么会出现这个低级问题,难道是我mac系统问题,还是我的人品问题.
在controller的action中push队列的时候,没有异步执行,还是在action的脚本中执行的. 发现是配置问题,原来不仅仅要修改config中的queue.PHP,还要修改.evn中相关配置. 虽然问题解决了,但是还是觉得蛋疼,不能理解.还需要在学习学习laravel.

异步队列使用办法

1.配置PHP利用

关于队列的定义,这里就不作介绍了.我们要使用异队伍列就有两个关键：

(1)存储队列的地方
(2)执行任务的服务
打开 config/queue.PHP,这是Laravel5关于队列的配置文件.首先我们可以通过 default 参数指定默认队列驱动,默认配置是 sync,这是同步队列,我们要做异步队列首先就要改变这里.假设我们用 database 作为驱动,队列任务将会存放在数据库中,而我们后面会另外启动一个后台服务来处理队列任务,这便是异步方式了.

'default' => 'database'

修改完配置后,我们必要创建一个表来存放队列任务,Laravel5已经在自带artisan命令中内置了一个指令用来生成数据迁移,只必要两条命令即可,当然你得实现配置好数据库连接.

PHP artisan queue:tablePHP artisan migrate

这样就自动在数据库中创立了 jobs 表.

2.启动队列监听服务PHP利用

通过下面这条指令启动队列监听服务,它会自动处置 jobs 表中的队列任务：

PHP artisan queue:Listen

在linux中,如果想让它在后台执行,可以这样：PHP利用

nohup PHP artisan queue:Listen &

3.添加队列任务PHP利用

关于队列任务的添加,手册里说的比拟详细,这里就简单举个例子吧.

首先,通过artisan创立一个队列命令：

PHP artisan make:command SendEmail --queued

这样会生成 app/Commands/SendEmail.PHP 这个类文件,这个类会被标识为队列命令,你可以在 handle 办法中写自己的业务逻辑.

在节制器中,可以简单通过 Bus::dispatch 分发任务:

Bus::dispatch(new \App\Commands\SendEmail());

你会发现任务不会立即执行,而是被放到 jobs 表中,由队列监听服务处置.

更详细的用法建议参考 command bus 和 queue 相关的手册章节.PHP利用

《：PHP的Laravel框架中使用消息队列queue及异步队列的方法》是否对您有启发，欢迎查看更多与《：PHP的Laravel框架中使用消息队列queue及异步队列的方法》相关教程，学精学透。内存溢出 jb51.cc为您提供精彩教程。

总结

以上是内存溢出为你收集整理的PHP的Laravel框架中使用消息队列queue及异步队列的方法全部内容，希望文章能够帮你解决PHP的Laravel框架中使用消息队列queue及异步队列的方法所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。