Swoole을 기반으로 가용성이 뛰어난 기업 수준의 예약된 작업 스케줄링 시스템을 구축합니다.

인터넷 산업의 지속적인 발전과 기술의 지속적인 발전으로 인해 예약된 작업 예약 시스템은 다양한 대규모 기업 수준 애플리케이션 시나리오에서 점점 더 중요해지고 있습니다. 기업에는 시스템의 안정성과 신뢰성을 보장하기 위해 데이터 백업, 이메일 전송, 정기 통계 등 일상적인 비즈니스 프로세스를 정기적으로 처리하기 위해 가용성이 높고 쉽게 확장 가능한 예약 작업 스케줄링 시스템이 필요합니다. 이 기사에서는 Swoole 프레임워크를 기반으로 가용성이 높은 기업 수준의 예약된 작업 스케줄링 시스템을 구축하는 방법을 소개합니다.

Swoole은 PHP 언어 기반의 코루틴 네트워크 통신 엔진으로, 이를 통해 PHP 프로그램이 Node.js와 동일한 높은 동시성 및 고성능 기능을 갖도록 할 수 있습니다. Swoole은 풍부한 네트워크 통신 및 비동기 IO 기능을 제공하여 엔터프라이즈 수준 애플리케이션에 대한 강력한 지원을 제공할 수 있습니다. 아래에서는 Swoole을 사용하여 가용성이 높은 기업 수준의 예약된 작업 스케줄링 시스템을 구축하는 방법을 자세히 소개합니다.

1. 디자인 아이디어

예정된 작업 스케줄링 시스템을 설계할 때 다음 측면을 고려해야 합니다.

1. 작업 관리: 작업 생성, 작업 수정, 작업 삭제, 작업을 포함한 모든 작업을 관리하고 예약하는 역할을 담당합니다. 운행현황 관리 등

2. 작업 실행: 지정된 비즈니스 로직 코드 호출, 작업 실행 로그 기록, 작업 예외 처리 등을 포함한 특정 작업 실행을 담당합니다.

3. 작업 스케줄링: 미리 정해진 시간 간격과 규칙에 따라 해당 실행자에게 작업을 할당하는 역할을 합니다.

4. 작업 모니터링: 모든 작업의 ​​실행 상태를 모니터링하고, 비정상적인 문제를 적시에 발견 및 처리하며, 시스템의 안정성과 신뢰성을 보장하는 역할을 담당합니다.

위의 아이디어를 바탕으로 전체 시스템을 다음 레이어로 나눌 수 있습니다.

작업 스케줄링 레이어: 작업의 스케줄링 및 배포를 담당하고 해당 실행자에게 작업을 할당합니다.

메시지 큐 레이어: 작업 정보 및 실행 결과를 저장하여 시스템 처리 기능과 안정성을 향상시키는 데 사용됩니다.

실행 계층: 지정된 작업을 실행하고 결과를 메시지 대기열에 쓰는 특정 작업 실행자입니다.

모니터링 레이어: 전체 시스템의 실행 상태를 모니터링하고 적시에 이상 현상을 감지하고 처리합니다.

2. 기술 아키텍처

1. 작업 스케줄링

작업 스케줄링은 전체 시스템의 핵심 부분이며 작업은 미리 정해진 규칙과 시간 간격에 따라 예약되고 할당되어야 합니다. Swoole의 타이머와 코루틴을 사용하여 작업 예약 기능을 구현할 수 있습니다. 먼저, 예약된 작업 예약 논리를 실행하기 위해 Swoole 프로세스를 시작해야 합니다.

$scheduler = new Scheduler();
$scheduler->add(function () use ($taskManager) {

$taskManager->assignTask();

}, '' , SWOOLE_TIMER_INTERVAL * 1000);

그 중 $taskManager는 작업 관리 객체입니다. 할당Task() 함수에서는 작업 목록에서 적절한 작업을 선택하고 미리 정해진 규칙과 시간에 따라 해당 작업에 할당할 수 있습니다. 실행기:

public 함수 할당Task()
{

$now = time();
foreach ($this->tasks as $task) {
    if ($task->nextExecTime == 0) {
        $task->nextExecTime = strtotime($task->cron);
    }
    if ($task->nextExecTime <= $now) {
        $task->nextExecTime = strtotime($task->cron, $now);
        $this->executeTask($task);
    }
}

}

executeTask() 함수에서 작업 정보를 메시지 대기열에 넣고 실행기가 처리될 때까지 기다릴 수 있습니다.

public 함수 실행 ($task )
{

// 将任务信息放入消息队列中
$this->queue->push($task);

}

2. 태스크 실행

태스크 실행은 전체 시스템의 또 다른 핵심 부분입니다. 태스크 정보를 기반으로 해당 비즈니스 로직 코드를 호출하고 실행 결과를 메시지 대기열. 작업 실행 중에 예외가 발생할 수 있으므로 실행 과정에서 예외 처리를 수행하고 실행 로그를 기록해야 합니다. Swoole의 코루틴과 비동기 IO 기능을 사용하여 고성능 작업 실행 기능을 달성할 수 있습니다. 먼저 작업 실행자로 여러 Swoole 하위 프로세스를 시작해야 합니다.

for ($i = 0; $i < SWOOLE_PROCESS_NUM; $i++) {

$worker = new Worker();
$worker->onWorkerStart = function ($worker) use ($queue) {
    while (true) {
        // 从消息队列中获取任务信息
        $task = $queue->pop();
        if (!$task) continue;
        // 执行任务
        $result = $this->execute($task);
        // 将执行结果写入消息队列中
        $this->queue->push($result);
    }
};
$worker->listen();

}

execute() 함수에서 다음을 수행할 수 있습니다. 작업 정보는 해당 비즈니스 로직 코드를 호출하고 예외 처리 및 로깅을 수행합니다.

public 함수 실행($task)
{

// 调用业务逻辑代码
try {
    $result = $this->doTask($task);
    return $result;
} catch (Exception $e) {
    // 异常处理
    $errMsg = sprintf("Task failed: %s, error message: %s", $task->name, $e->getMessage());
    $this->log($errMsg);
    return false;
}

}

3. 메시지 대기열

메시지 대기열은 전체 시스템의 통신 허브입니다. . 용도 작업 정보 및 실행 결과를 저장하고, 시스템 처리 능력 및 안정성을 향상시키기 위해 사용됩니다. Swoole에서 제공하는 코루틴 및 비동기 IO 기능을 사용하여 고성능 메시지 큐 기능을 구현할 수 있습니다. 먼저 Swoole 프로세스를 메시지 대기열로 시작해야 합니다.

$queue = new Channel();
$server = new Server('0.0.0.0', 9501, SWOOLE_PROCESS, SWOOLE_SOCK_TCP);
$server-> on( 'receive', function ($server, $fd, $from_id, $data) use ($queue) {

// 将消息放入消息队列中
$queue->push($data);

});
$server->start();

특정 작업 실행 프로세스 중 , 메시지 큐에 작업 정보와 실행 결과를 기록하고 다른 구성 요소가 처리될 때까지 기다릴 수 있습니다.

// 작업 정보를 메시지 큐에 넣기
$this->queue->push($task);

4. 모니터링 시스템

모니터링 시스템은 전체 시스템의 작동 상태를 모니터링하고, 비정상적인 문제를 적시에 감지 및 처리하며, 시스템의 안정성과 신뢰성을 보장하는 데 사용됩니다. . Swoole의 프로세스 관리 및 신호 처리 기능을 사용하여 모니터링 시스템의 기능을 구현할 수 있습니다. 모니터링 프로세스로 Swoole 프로세스를 시작할 수 있습니다.

$monitor = new Monitor();
$monitor->start();

Monitor 클래스의 start() 함수에서 Swoole의 프로세스 관리를 사용할 수 있습니다. 모니터링 시스템의 기능을 구현하기 위한 신호 처리 기능:

public function start()
{

// 注册信号处理函数
pcntl_signal(SIGUSR1, array($this, 'handleSignal'));
while (true) {
    $cpuUsage = $this->getCpuUsage();
    $memUsage = $this->getMemUsage();
    $this->log(sprintf('CPU usage: %.2f%%, Memory usage: %.2fMB', $cpuUsage, $memUsage));
    sleep(MONITOR_INTERVAL);
}

}

其中，getCpuUsage()函数用于获取当前进程的CPU使用率，getMemUsage()函数用于获取当前进程的内存使用情况，handleSignal()函数用于处理信号并进行相应的处理。

三、系统部署

在系统部署方面，我们可以使用Docker容器化的方式，来实现系统的快速部署和迁移。首先，我们需要构建一组Docker镜像：

docker build -t task-scheduler:latest .
docker build -t task-executor:latest .
docker build -t task-queue:latest .
docker build -t task-monitor:latest .

其中，task-scheduler镜像用于运行任务调度进程，task-executor镜像用于运行任务执行进程，task-queue镜像用于运行消息队列进程，task-monitor镜像用于运行监控进程。

接着，我们可以使用docker-compose来启动和管理整个系统：

version: '3'
services:
scheduler:

image: task-scheduler:latest
restart: always

executor:

image: task-executor:latest
restart: always
scale: 5

queue:

image: task-queue:latest
restart: always

monitor:

image: task-monitor:latest
restart: always

其中，scheduler服务用于启动任务调度进程，executor服务用于启动任务执行进程，queue服务用于启动消息队列进程，monitor服务用于启动监控进程。可以根据实际情况，调整服务的数量和启动参数。

四、总结

本文介绍了如何基于Swoole框架构建一套高可用的企业级定时任务调度系统，其中涵盖了任务调度、任务执行、消息队列和监控等方面。Swoole的高性能和异步IO特性，为企业级应用提供了强大的支持，能够满足各种大规模应用的需求。通过本文的介绍，相信读者可以更好地了解Swoole框架的应用和实践。

위 내용은 Swoole을 기반으로 가용성이 뛰어난 기업 수준의 예약된 작업 스케줄링 시스템을 구축합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!