内容纲要

php 在 windows 下多进程不好使,没有 fork,不过你还是可以通过启动多个 php.exe 来执行脚本,把公共队列数据放在数据库或者 redis 下,然后排队访问。

不过这个东西已经由 Laravel 实现了,Laravel 提供了一个消息队列的投递和监听框架,消息队列的后端可以是

  • sync 就是同步方法,一边生产数据一边消费数据,用来测试队列方法,生产环境不使用
  • database 采用数据库来存储消息队列数据
  • beanstalkd
  • sqs
  • redis

后面三种都是消息队列服务第三方组件,Laravel 在队列任务失败时,会把它存到数据库的 failed_jobs 表。

消息队列消费者

[php]
<?php namespace App\Jobs; use Illuminate\Bus\Queueable; use Illuminate\Queue\SerializesModels; use Illuminate\Queue\InteractsWithQueue; use Illuminate\Contracts\Queue\ShouldQueue; use Illuminate\Foundation\Bus\Dispatchable; class EchoTest implements ShouldQueue { use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; /** * Create a new job instance. * * @return void */ public function __construct($messageid) { $this->messageid_ = $messageid;
}

/**
* Execute the job.
*
* @return void
*/
public function handle()
{
echo "hello queue world!" . $this->messageid_;
}

protected $messageid_;
}
[/php]

消息队列数据生产者

[php]
<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;
use Illuminate\Foundation\Bus\DispatchesJobs;
use App\Jobs\EchoTest;

class TestDb extends Command
{
use DispatchesJobs;
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = ‘testdb {–queue}’;

/**
* The console command description.
*
* @var string
*/
protected $description = ‘Command description’;

/**
* Create a new command instance.
*
* @return void
*/
public function __construct()
{
parent::__construct();
}

/**
* Execute the console command.
*
* @return mixed
*/
public function handle()
{
$options = $this->options();
$queueName = $this->option(‘queue’);
$this->info(‘hello world!’);
$this->info(‘中文测试’);
$this->error(‘something went wrong!’);

$this->info(‘通过命令行执行队列任务’);

for ($i = 0; $i < 1000; ++$i) {
$this->dispatch((new EchoTest($i))->onQueue(‘echo’));
}

}
}

[/php]

修改 .env 配置

QUEUE_DRIVER=database

运行一个消息队列监听进程

cd /d H:\laravel_cmd_test
php artisan queue:work database --daemon --queue=echo

运行消息队列生产者命令行

php artisan testdb

为什么要在 windows 下使用 laravel 实现消息队列

  • 不用 C++ 实现,用 asio 是可以但是不方便
  • 用 node 也可以,后端搭配 redis 使用也可以,失败任务队列还得持久化到 mysql 里
  • PHP 方便操作 mysql,可调用 C++ 命令行程序;数据方便入库,脚本修改逻辑方便
  • Laravel 框架很强大,生成数据表和测试数据很方便,失败队列任务重试轻松定制
  • 在 Laravel 的后台工作进程使用数据库长连接

添加批处理命令行启动多个消费者进程

** run-sub-daemon.bat **

title %1
cd /d "%~dp0" 
@path=%~dp0\tools;%path%
CALL "%~dp0\setenv.bat"
cd /d "%~dp0"


cd db_test\laravel_cmd_test
php artisan queue:work database --daemon --queue=echo

run-daemon.bat

@echo off
setlocal enabledelayedexpansion
:main
for /l %%i in (1,1,5) do (
set n=%%i
start "" "run-sub-daemon.bat" 队列子进程!n!
)

双击运行 run-daemon.bat,打开 5 个队列消费者进程。

然后运行 laravel 命令行 php artisan testdb,开始狂奔吧!

links

发表评论

电子邮件地址不会被公开。 必填项已用*标注