многопоточная-очередь

[
    'basics' => [
        'name' => 'mp-queue-1', // Необходимо указать уникальное имя для каждого сервера при одновременном запуске нескольких серверов
        'driver' => new \MPQueue\Queue\Driver\Redis('127.0.0.1'),
    ],
    'queue' => [
        [
            'name' => 'test', // Имя очереди
            'fail_handle' => function () {
                var_dump('Произошла ошибка');
            }, // Функция обратного вызова при неудаче
        ],
        [
            'name' => 'test2', // Имя очереди
            'worker_number' => 4, // Количество рабочих процессов для данной очереди
            'memory_limit' => 0, // Максимальное использование памяти каждым рабочим процессом для данной очереди. При превышении этого значения процесс будет перезапущен. Единица измерения — мегабайты
        ]
    ]
]

composer require yuntian001/multi-process-queue

<?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'),
    ],
    'queue' => [
        [
            'name' => 'test', // Название очереди
            'fail_handle' => function () {
                var_dump('Ошибка!');
            }, // Обработчик ошибок
        ],
        [
            'name' => 'test2', // Название очереди
            'worker_number' => 4, // Количество рабочих процессов в очереди
            'memory_limit' => 0, // Ограничение памяти для рабочего процесса.
        ]
    ]
];
```При превышении — перезапуск. Единицы измерения: МБ
         ]
     ]
 ];
 Config::set($config);
 (new \MPQueue\Console\Application())->run();

  php master.php worker:start

  php master.php worker:start -d

 php master.php help

  queue:clean Очистить очередь --queue test Очистить указанную очередь:test
  queue:status Просмотреть информацию о очередях --queue test Указать очередь:test
  queue:failed Вывести детали ошибок --queue test Указать очередь:test
  worker:start Запустить --d для запуска в фоновом режиме
  worker:stop Остановить
  worker:restart Перезапустить --d для запуска в фоновом режиме
  worker:reload Гладкий перезапуск
  worker:status Проверить состояние процесса

- Выполните следующий код для отправки задач (может вызываться через веб, без необходимости загрузки расширения Swoole)

    require_once __DIR__ . '/vendor/autoload.php'; // Загрузка файла composer если он еще не был загружен
    $config = [
        'basics' => [
            'name' => 'mp-queue-1', // Название для нескольких серверов при одновременной активации
            'driver' => new \MPQueue\Queue\Driver\Redis('127.0.0.1'),
        ],
        'queue' => [
            [
                'name' => 'test', // Название очереди
                'fail_handle' => function() {
                    var_dump('Ошибка!');
                }, // Обработчик ошибок
            ],
            [
                'name' => 'test2',// название очереди
            ],
         ],
     ];
``````markdown
           'worker_number' => 4, // количество рабочих процессов в текущей очереди
            'memory_limit' => 0, // максимальное использование памяти рабочими процессами в текущей очереди. Если лимит превышен, процессы будут перезапущены. Единицы измерения - мегабайты (MB)
        ]
    ],
);
 Config::set($config);
 $job = function(){
    var_dump('hello world!');
 };
 MPQueue\Queue\Queue::push('test', $job, 10);

**Рекомендуется использовать** подклассы \MPQueue\Job для отправки $job, так как в этих подклассах можно настроить время ожидания, количество допустимых ошибок, время повторной попытки, функцию выполнения при превышении времени ожидания и функцию выполнения при возникновении ошибки. Подробное описание параметров доступно в [src/Job.php](src/Job.php).

- $delay — задержка перед отправкой задачи (в секундах), значение по умолчанию равно 0 (немедленная отправка).

Примеры отправки задач представлены в файлах normal.php, failed.php, timeout.php и pressure.php в папках test и test/Job.```## Внимание
- Команда `worker:reload` заставляет рабочий процесс завершить текущую задачу и перезапуститься. Команда `worker:restart` выполняет жёсткий перезапуск всех процессов manage, master и worker, что может привести к прерыванию выполнения задачи.
- Поскольку процессы загружаются сразу после запуска в оперативную память, изменения кода не будут применены немедленно. Чтобы изменения вступили в силу, необходимо выполнить команду `worker:reload` или `worker:start`.
- Команда `worker:reload` перезапускает только рабочие процессы и не перезагружает конфигурационные файлы. После изменения конфигурационных файлов необходимо выполнить команду `worker:restart`, чтобы изменения вступили в силу.## Использование в Laravel
- Установка
```bash
composer require yuntian001/multi-process-queue

<?php
// Пример конфигурации, конкретные настройки могут быть указаны согласно документации
return [
    'basics'=>[
        'name'=>'mp-queue-1',// Название должно быть уникальным для каждого сервера
        'driver'=> new \MPQueue\Queue\Driver\Redis('127.0.0.1'),
        'worker_start_handle'=>function(){
            // Загрузка основного кода Laravel
            defined('LARAVEL_START') || define('LARAVEL_START', microtime(true));
            $app = require_once __DIR__.'/../bootstrap/app.php';
            $app->make(Illuminate\Contracts\Console\Kernel::class)->bootstrap();
        }
    ],
    'queue' => [
        [
            'name' => 'test',// Название очереди
            'fail_handle'=>function($info,$e){
                // Логика обработки ошибок, например запись в базу данных MySQL
            },// Обработка ошибок
        ],
        [
            'name' => 'test2',// Название очереди
            'worker_number' => 4,// Количество рабочих процессов для данной очереди
            'memory_limit' => 0, // Максимальное использование памяти рабочими процессами этой очереди, если превышено — перезапуск. Единицы измерения — мегабайты
        ]
    ],
    'log' => [
        'path' => __DIR__.'/../storage/logs',// Директория для хранения логов должна иметь права записи
    ]
];

#!/usr/bin/env php
<?php
define('MP_QUEUE_CLI', true);
use MPQueue\Config\Config;

require __DIR__ . '/vendor/autoload.php';
Config::set(include(__DIR__ . '/config/mp-queue.php'));
(new \MPQueue\Console\Application())->run();

<?php
// Расположение файла app/Job/HelloWord.php
namespace App\Job;
```use Illuminate\Support\Facades\Log;
use MPQueue\Job;

class HelloWord extends Job
{
    // В методе handle можно использовать методы Laravel, но передача аргументов через внедрение зависимостей не поддерживается
    public function handle()
    {
        var_dump('Hello world!');
        Log::info('Hello world!');
    }
}

 php mp-queue worker:start -d
```- Отправьте задачу. Добавьте следующий код в любом месте (например, в контроллере):
```php
    \MPQueue\Config\Config::set(config('mp-queue')); // Настройки конфигурации также могут быть установлены в контейнере приложения AppServiceProvider boot()
    \MPQueue\Queue\Queue::push('test', \App\Job\HelloWord::class);

composer require yuntian001/multi-process-queue

<?php
// Пример конфигурации, конкретные настройки можно указать согласно документации
return [
    'basics' => [
        'name' => 'mp-queue-1', // При одновременном запуске на нескольких серверах каждому нужно присвоить уникальное имя
        'driver' => new \MPQueue\Queue\Driver\Redis('127.0.0.1'),
        'worker_start_handle' => function () {
            // Инициализация основного приложения ThinkPHP
            \think\App::initCommon();
        },
    ],
    'queue' => [
        [
            'name' => 'test', // Название очереди
            'fail_handle' => function ($info, $e) {
                // Логика выполнения при ошибке, например запись в MySQL
            }, // Обработчик ошибок
        ],
        [
            'name' => 'test2', // Название очереди
            'worker_number' => 4, // Количество рабочих процессов для текущей очереди
            'memory_limit' => 0, // Максимальное использование памяти рабочими процессами текущей очереди. Если превышено, процессы будут перезапущены. Единица измерения - МБ
        ],
    ],
    'log' => [
        'path' => __DIR__.'/../runtime', // Путь к логам должен иметь права записи
    ],
];

#!/usr/bin/env php
<?php
``````php
define('MP_QUEUES_CLI', true);
define('APP_PATH', __DIR__ . '/application/');
// Основной файл ThinkPHP
require __DIR__ . '/thinkphp/base.php';
\MPQueue\Config\Config::set(include(__DIR__ . '/application/extra/mp-queue.php'));
(new \MPQueue\Console\Application())->run();

<?php
// application/job/HelloWord.php
namespace app\job;

use MPQueue\Job;
use think\Log;

class HelloWord extends Job
{
    // Внутри метода handle можно вызывать методы и функции ThinkPHP, но метод handle не поддерживает передачу аргументов через внедрение зависимостей
    public function handle()
    {
        var_dump('hello world!');
        Log::info('hello world!');
    }
}
?>

- Запустите очередь в фоновом режиме (или запустите без ключа `-d`)

php mp-queue worker:start -d

- Отправьте задачу. Добавьте следующий код в любом месте (например, в контроллере) для отправки задачи

- Установка

- Создайте файл конфигурации mp-queue.php в папке config