关于PHP的Laravel框架中使用消息队列queue及异步队列的方法分析
这篇文章主要介绍了PHP的Laravel框架中使用消息队列queue及异步队列的方法,针对Laravel 5.0后的版本,示例环境为Linux系统,需要的朋友可以参考下
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，使用composer，倒是很简单。
composer global require "laravel/installer=~1.1" vi ~/.bash_profile
把~/.composer/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 ++) {
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、监听queue
php artisan queue:listen
为了验证多任务处理，我们同时开三个窗口运行同样的命令。
8、用laravel内建的server启动服务
php artisan serve --port 8080
打开浏览器，访问http://localhost:8080/页面。当然也可以用nginx，apache之类的。但是需要各种配置，还是内建的使用方便。
在控制台就能看到各个queue执行的情况了，如下图。可以看到100个任务被三个work平分了。
到此，基本达到了我想要的效果。验证了laravel可以简单实现queue，并且可以多任务处理。
make command生成的代码中use App\Commands\Command ，但是运行时提示没有这个文件。 解决办法，修改为 use Illuminate\Console\Command; 不知道为什么会出现这个低级问题，难道是我mac系统问题，还是我的人品问题。
在controller的action中push队列的时候，没有异步执行，还是在action的脚本中执行的。 发现是配置问题，原来不仅仅要修改config中的queue.php，还要修改.evn中相关配置。 虽然问题解决了，但是还是觉得蛋疼，不能理解。还需要在学习学习laravel。
异步队列使用方法
1.配置
关于队列的定义，这里就不作介绍了。我们要使用异步队列就有两个关键：
（1）存储队列的地方
（2）执行任务的服务
打开 config/queue.php ，这是Laravel5关于队列的配置文件。首先我们可以通过 default 参数指定默认队列驱动，默认配置是 sync , 这是同步队列，我们要做异步队列首先就要改变这里。假设我们用 database 作为驱动，队列任务将会存放在数据库中，而我们后面会另外启动一个后台服务来处理队列任务，这就是异步方式了。
'default' => 'database'
修改完配置后，我们需要创建一个表来存放队列任务，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 表中，由队列监听服务处理。
以上就是本文的全部内容，希望对大家的学习有所帮助，更多相关内容请关注PHP中文网！
相关推荐：
Atas ialah kandungan terperinci 关于PHP的Laravel框架中使用消息队列queue及异步队列的方法分析. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!
Alat AI Hot
Undress AI Tool
Gambar buka pakaian secara percuma
Undresser.AI Undress
Apl berkuasa AI untuk mencipta foto bogel yang realistik
AI Clothes Remover
Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.
Clothoff.io
Penyingkiran pakaian AI
Video Face Swap
Tukar muka dalam mana-mana video dengan mudah menggunakan alat tukar muka AI percuma kami!
Artikel Panas
Alat panas
Notepad++7.3.1
Editor kod yang mudah digunakan dan percuma
SublimeText3 versi Cina
Versi Cina, sangat mudah digunakan
Hantar Studio 13.0.1
Persekitaran pembangunan bersepadu PHP yang berkuasa
Dreamweaver CS6
Alat pembangunan web visual
SublimeText3 versi Mac
Perisian penyuntingan kod peringkat Tuhan (SublimeText3)
Topik panas
Cara Menggunakan PHP untuk Membina Fungsi Perkongsian Sosial PHP Perkongsian Interface Integration Practice
Jul 25, 2025 pm 08:51 PM
Kaedah teras untuk membina fungsi perkongsian sosial dalam PHP adalah untuk menghasilkan pautan perkongsian secara dinamik yang memenuhi keperluan setiap platform. 1. Mula -mula dapatkan halaman semasa atau URL dan maklumat artikel yang ditentukan; 2. Gunakan urlencode untuk menyandikan parameter; 3. Sambutan dan menjana pautan perkongsian mengikut protokol setiap platform; 4. Pautan paparan di hujung depan untuk pengguna mengklik dan berkongsi; 5. Dinamik menghasilkan tag OG pada halaman untuk mengoptimumkan paparan kandungan perkongsian; 6. Pastikan untuk melepaskan input pengguna untuk mencegah serangan XSS. Kaedah ini tidak memerlukan pengesahan yang kompleks, mempunyai kos penyelenggaraan yang rendah, dan sesuai untuk kebanyakan keperluan perkongsian kandungan.
Cara Menggunakan PHP Digabungkan dengan AI Untuk Mencapai Ralat Pembetulan Ralat PHP Pengesanan dan Pengoptimuman Sintaks PHP
Jul 25, 2025 pm 08:57 PM
Untuk merealisasikan pembetulan ralat teks dan pengoptimuman sintaks dengan AI, anda perlu mengikuti langkah -langkah berikut: 1. Pilih model AI atau API yang sesuai, seperti Baidu, Tencent API atau perpustakaan NLP sumber terbuka; 2. Panggil API melalui curl atau Guzzle PHP dan memproses hasil pulangan; 3. Maklumat pembetulan ralat paparan dalam aplikasi dan membenarkan pengguna memilih sama ada untuk mengadopsinya; 4. Gunakan php-l dan php_codesniffer untuk pengesanan sintaks dan pengoptimuman kod; 5. Secara berterusan mengumpul maklum balas dan mengemas kini model atau peraturan untuk meningkatkan kesannya. Apabila memilih AIAPI, fokus pada menilai ketepatan, kelajuan tindak balas, harga dan sokongan untuk PHP. Pengoptimuman kod harus mengikuti spesifikasi PSR, gunakan cache yang munasabah, elakkan pertanyaan bulat, mengkaji semula kod secara berkala, dan gunakan x
PHP memanggil AI Pembantu Suara Pintar PHP Pembinaan Sistem Interaksi Suara PHP
Jul 25, 2025 pm 08:45 PM
Input suara pengguna ditangkap dan dihantar ke backend PHP melalui API Mediarecorder JavaScript front-end; 2. PHP menjimatkan audio sebagai fail sementara dan memanggil STTAPI (seperti Pengiktirafan Suara Google atau Baidu) untuk mengubahnya menjadi teks; 3. PHP menghantar teks kepada perkhidmatan AI (seperti Openaigpt) untuk mendapatkan jawapan pintar; 4. PHP kemudian memanggil TTSAPI (seperti sintesis Baidu atau Google Voice) untuk menukar balasan ke fail suara; 5. PHP mengalir fail suara kembali ke bahagian depan untuk bermain, menyelesaikan interaksi. Seluruh proses dikuasai oleh PHP untuk memastikan hubungan lancar antara semua pautan.
Beyond the Lamp Stack: Peranan PHP dalam Senibina Enterprise Moden
Jul 27, 2025 am 04:31 AM
Phpisstillrelevantinmodernenterpriseenvironments.1.modernphp (7.xand8.x) Menawarkan Perpaduan Perlengkapan, ketegangan, jitcompilation, danmodernsyntax, makeitsuatableforlarge-scaleapplications.2.phpintegratefective
Bagaimana Membuat Bekas PHP Sokongan Pembinaan Automatik? Kaedah konfigurasi CI bersepadu persekitaran PHP
Jul 25, 2025 pm 08:54 PM
Untuk membolehkan bekas PHP menyokong pembinaan automatik, terasnya terletak pada mengkonfigurasi proses integrasi berterusan (CI). 1. Gunakan Dockerfile untuk menentukan persekitaran PHP, termasuk imej asas, pemasangan lanjutan, pengurusan ketergantungan dan tetapan kebenaran; 2. Konfigurasi alat CI/CD seperti Gitlabci, dan tentukan peringkat binaan, ujian dan penempatan melalui fail .gitlab-ci.yml untuk mencapai pembinaan, pengujian dan penggunaan automatik; 3. Mengintegrasikan kerangka ujian seperti PHPUnit untuk memastikan ujian secara automatik dijalankan selepas perubahan kod; 4. Gunakan strategi penempatan automatik seperti Kubernet untuk menentukan konfigurasi penempatan melalui fail penyebaran.yaml; 5. Mengoptimumkan Dockerfile dan mengamalkan pembinaan pelbagai peringkat
Menggunakan beratur untuk pemprosesan latar belakang di Laravel.
Jul 26, 2025 am 05:45 AM
Tohandletime-consumingtasksinlaravelwithoutdelayingtheuserexperience, usequeuesforbackgroundprocessing.laravelqueuesallowyoutodeferheAvyTaskslikeSlikeMailsorimageProcessingBypushingJobsontoAqueue, whrearethenpheroShoShoShoShoShoAdoAqueue, whrearethenpheroShoSher.
Terangkan lingkungan laravel fasih.
Jul 26, 2025 am 07:22 AM
Eloquentscopes Laravel adalah alat yang merangkumi logik pertanyaan biasa, dibahagikan kepada skop tempatan dan skop global. 1. Skop tempatan ditakrifkan dengan kaedah yang bermula dengan skop dan perlu dipanggil secara eksplisit, seperti pos :: diterbitkan (); 2. Skop global secara automatik digunakan untuk semua pertanyaan, sering digunakan untuk pemadaman lembut atau sistem multi-penyewa, dan antara muka skop perlu dilaksanakan dan didaftarkan dalam model; 3. Skop boleh dilengkapi dengan parameter, seperti penapisan artikel mengikut tahun atau bulan, dan parameter yang sepadan diluluskan ketika memanggil; 4. Perhatikan spesifikasi penamaan, panggilan rantai, pelepasan sementara dan pengembangan gabungan apabila menggunakan untuk meningkatkan kejelasan kod dan kebolehgunaan semula.
Contoh Perintah Python Run Shell
Jul 26, 2025 am 07:50 AM
Gunakan subprocess.run () untuk melaksanakan perintah shell dengan selamat dan menangkap output. Adalah disyorkan untuk lulus parameter dalam senarai untuk mengelakkan risiko suntikan; 2. Apabila ciri -ciri shell diperlukan, anda boleh menetapkan shell = benar, tetapi berhati -hati dengan suntikan arahan; 3. Gunakan subprocess.popen untuk merealisasikan pemprosesan output masa nyata; 4. Tetapkan semak = benar untuk membuang pengecualian apabila arahan gagal; 5. Anda boleh secara langsung memanggil rantai untuk mendapatkan output dalam senario mudah; Anda harus memberi keutamaan kepada subprocess.run () dalam kehidupan seharian untuk mengelakkan menggunakan os.system () atau modul yang tidak ditetapkan. Kaedah di atas mengatasi penggunaan teras untuk melaksanakan perintah shell di Python.
