自定义进程

目录

【规范】

系统(框架)提供的进程，如果不需要继承修改，请尽量放在配置文件中进行声明。我们应当遵循：

  • 1、组件已提供对应进程且不需要自定义的，请在 config/autoload/process.php 中声明
  • 2、自定义组件(业务需要)，应当在 app 目录下创建 Process 目录，且所有自定义进程文件放入其中， 自定义进程使用 注解 方式声明。

即：系统(框架)进程在配置文件中声明；自定义进程使用 注解 声明。

【注意】

  • 抛出异常会退出进程，会被Server重新拉起。建议在自定义进程中，使用 try-catch-finally , 并且抛出自己定义的异常。
  • 定时任务本质上也是自定义进程操作，但是它会对异常处理(需要监听异常事件)

注册自定义进程

<?php

declare(strict_types=1);
namespace App\Process;

use App\Lib\Log\Log;
use Exception;
use Hyperf\Coroutine\Coroutine;
use Hyperf\Process\AbstractProcess;
use Hyperf\Process\Annotation\Process;
use Hyperf\Process\ProcessManager;
use Throwable;

#[Process(
    nums: 1, // 进程数目
    name: 'ConsumerProcess',
    redirectStdinStdout: false,
    pipeType: 2,
    enableCoroutine: true // 进程内是否启用协程
)]
class ConsumerProcess extends AbstractProcess
{
    public function handle(): void
    {
        $index = 0;
        try {
            while (ProcessManager::isRunning()) {
                Coroutine::sleep(1);
                ++$index;
                // 模拟异常
                if ($index === 10) {
                    throw new Exception('主动抛出异常');
                }
            }
        } catch (Throwable $e) {
            Log::stdout()->error("ConsumerProcess 异常被捕获: {$e->getMessage()}");
        } finally {
            Log::stdout()->warning('ConsumerProcess 进程将被拉起 !!!');
        }
    }

    // 是否随着服务一起启动
    public function isEnable($server): bool
    {
        return \Hyperf\Support\env('APP_ENV', 'dev') === 'dev';
    }
}

重载系统进程

【说明】

有一些系统进程我们可能需要自己管理或者变更逻辑，那么我们需要继承对应的消费进程，然后自己再进行注册。如果不需要变更，则直接在
config/autoload/process.php 配置即可。我更倾向于自己管理。😁

异步队列消费进程
<?php

declare(strict_types=1);

namespace App\Process\OverloadProcess;

use App\Constants\ConstCode;
use Hyperf\AsyncQueue\Process\ConsumerProcess;
use Hyperf\Process\Annotation\Process;

#[Process(
    nums: 4, // 消费者进程数
    name: 'AsyncQueueProcess', // 队列名称
    redirectStdinStdout: false, // 重定向自定义进程的标准输入和输出
    enableCoroutine: true, // 是否启用协程
)]
class AsyncQueueProcess extends ConsumerProcess
{
    // 这里的队列名称请和配置文件对应的队列名称保持一致
    protected string $queue = ConstCode::NORMAL_QUEUE_NAME;
}