1 В избранное 0 Ответвления 0

OSCHINA-MIRROR/hzhangjiayun-multi-process-queue

Присоединиться к Gitlife
Откройте для себя и примите участие в публичных проектах с открытым исходным кодом с участием более 10 миллионов разработчиков. Приватные репозитории также полностью бесплатны :)
Присоединиться бесплатно
Клонировать/Скачать
main.php 1 КБ
Копировать Редактировать Web IDE Исходные данные Просмотреть построчно История
yun Отправлено 21.03.2022 17:18 51048ac
<?php
define('MP_QUEUE_CLI', true);
use MPQueue\Config\Config;
require_once __DIR__ . '/vendor/autoload.php';
$config = [
'basics' => [
'name' => 'mp-queue-1',//多个服务器同时启动时需要分别设置名字
'driver' => new \MPQueue\Queue\Driver\Redis('127.0.0.1'),
],
'log'=>[
// 'level'=>\Monolog\Logger::DEBUG
],
'queue' => [
[
'name' => 'test',//队列名称
'fail_handle' => function ($info,$e) {
var_dump(getmypid());
var_dump($info);
var_dump($e);
var_dump('失败了');
},//失败回调函数
],
[
'name' => 'test2',//队列名称
'worker_number' => 4,//当前队列工作进程数量
'memory_limit' => 0, //当前队列工作进程的最大使用内存,超出则重启。单位 MB
// 'model'=>\MPQueue\Config\QueueConfig::MODEL_GRAB
]
]
];
Config::set($config);
(new \MPQueue\Console\Application())->run();

Опубликовать ( 0 )

Вы можете оставить комментарий после Вход в систему

1
https://api.gitlife.ru/oschina-mirror/hzhangjiayun-multi-process-queue.git
git@api.gitlife.ru:oschina-mirror/hzhangjiayun-multi-process-queue.git
oschina-mirror
hzhangjiayun-multi-process-queue
hzhangjiayun-multi-process-queue
main