ThinkPHP6 및 Swoole로 구축된 RPC 서비스를 사용하여 고가용성 작업 대기열 구현

ThinkPHP6 및 Swoole로 구축된 RPC 서비스를 사용하여 고가용성 작업 대기열 구현

[소개]
작업 대기열은 현대 개발에서 시간이 많이 걸리는 작업을 주요 프로세스에서 분리하고 응답을 개선할 수 있는 중요한 역할을 합니다. 시스템 속도는 시스템 장애나 네트워크 중단 시 작업의 신뢰성과 고가용성을 보장할 수 있습니다. 이 기사에서는 ThinkPHP6 및 Swoole을 사용하여 비동기 작업 처리를 구현하는 고가용성 작업 대기열을 구축하는 동시에 작업 대기열 관리를 위한 RPC 서비스를 제공하는 방법을 소개합니다.

【환경 준비】
시작하기 전에 다음을 포함한 몇 가지 개발 환경을 준비해야 합니다.

1. PHP 환경에서는 PHP 7.4 이상을 사용하는 것이 좋습니다.
2. 컴포저를 설치하여 프로젝트 종속성을 관리합니다. 작업 관련 정보를 저장하는 데 사용되는 데이터베이스
3. 작업 대기열의 실시간 알림 및 모니터링을 구현하는 데 사용되는 Redis 설치
4. 고성능 RPC 서비스 및 비동기 작업 처리를 구현하는 데 사용되는 Swoole 확장 프로그램 설치.
5. 【프로젝트 구성】

프로젝트 만들기

Composer를 사용하여 새로운 ThinkPHP6 프로젝트를 만듭니다.
1. 
   

   composer create-project topthink/think hello-think

종속성 추가

프로젝트 루트 디렉터리의 작곡가.json 파일에 Swoole 및 Swoole-ide-helper의 종속성을 추가합니다.
2. 
   

   "require": {
       "swoole/swoole": "4.6.7",
       "swoole/ide-helper": "4.6.7"
   }

그런 다음

명령을 실행하여 종속성을 설치합니다.

composer update

Swoole의 RPC 서비스 및 예약된 작업 구성

프로젝트 루트 디렉터리 아래의 config 디렉터리에 swoole.php 구성 파일을 생성하고 다음 콘텐츠를 추가하세요.
3. 
   

   return [
       'rpc' => [
           'listen_ip' => '0.0.0.0',
           'listen_port' => 9501,
           'worker_num' => 4,
           'task_worker_num' => 4,
       ],
       'task' => [
           'task_ip' => '127.0.0.1',
           'task_port' => 9502,
       ],
       'timer' => [
           'interval' => 1000,
       ],
   ];

RPC 서버 생성

앱 디렉터리에 생성 프로젝트의 rpc 디렉터리를 만들고 rpc 디렉터리에 서버 디렉터리를 만듭니다. 그런 다음 TaskServer.php 파일을 생성하고 다음 내용을 추가합니다.
4. 
   

   namespace apppcserver;
   
   use SwooleServer;
   use thinkRpcServer;
   use thinkacadeConfig;
   
   class TaskServer
   {
       protected $server;
   
       public function start()
       {
           $this->server = new Server(Config::get('swoole.rpc.listen_ip'), Config::get('swoole.rpc.listen_port'));
   
           $rpcServer = new RpcServer($this->server);
   
           $rpcServer->classMap([
               'apppcserviceTaskService',
           ]);
   
           $rpcServer->start();
       }
     
   }

RPC 서비스 생성

rpc 디렉토리에 서비스 디렉토리를 생성하고 서비스 디렉토리에 TaskService.php 파일을 생성합니다. TaskService.php 파일에서는 addTask 및 getTask와 같은 특정 RPC 메소드를 정의합니다.
5. 
   

   namespace apppcservice;
   
   class TaskService
   {
       public function addTask($data)
       {
           // 处理添加任务的逻辑，将任务添加到任务队列中
       }
   
       public function getTask($id)
       {
           // 处理获取任务的逻辑，从任务队列中获取相关任务信息
       }
   
       // 其他RPC方法...
   }

[작업 큐 구현]

작업 대기열 테이블 생성

작업 관련 정보를 저장하기 위해 MySQL 데이터베이스에 작업 테이블을 생성합니다.
1. 
   

   CREATE TABLE `task` (
     `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
     `task_name` varchar(255) DEFAULT NULL,
     `task_data` text,
     `task_status` tinyint(1) DEFAULT NULL,
     `create_time` int(11) DEFAULT NULL,
     `update_time` int(11) DEFAULT NULL,
     PRIMARY KEY (`id`),
     KEY `task_status` (`task_status`)
   ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

작업 모델 만들기

appmodel 디렉터리에 Task.php 파일을 만들고 다음 콘텐츠를 추가합니다.
2. 
   

   namespace appmodel;
   
   use thinkModel;
   
   class Task extends Model
   {
       protected $autoWriteTimestamp = true;
       protected $dateFormat = 'Y-m-d H:i:s';
   }

작업 처리 로직 만들기

appservice 디렉터리에 TaskService.php 파일을 만들고 다음 콘텐츠를 추가합니다. :
3. 
   

   namespace appservice;
   
   use appmodelTask;
   
   class TaskService
   {
       public function addTask($data)
       {
           $task = new Task;
           $task->task_name = $data['task_name'];
           $task->task_data = $data['task_data'];
           $task->task_status = 0;
           $task->save();
   
           // TODO: 将任务添加到任务队列中
       }
   
       public function getTask($id)
       {
           return Task::find($id);
       }
   
       // 其他任务处理逻辑...
   }

RPC 서버는 작업 처리 로직을 호출합니다

TaskService.php의 addTask 메소드에서는 데이터베이스에 작업을 저장한 후 작업 큐에 작업을 추가하는 등의 작업을 추가하는 로직을 처리하겠습니다.
4. 
   
[예약된 작업 구현]

예약된 작업 처리 로직 만들기

appservice 디렉터리에 TimerService.php 파일을 만들고 다음 내용을 추가하세요.
1. 
   

   namespace appservice;
   
   use appmodelTask;
   use SwooleTimer;
   
   class TimerService
   {
       public function start()
       {
           Timer::tick(config('swoole.timer.interval'), function() {
               // TODO: 定时检查任务队列，处理待执行的任务
           });
       }
     
       // 其他定时任务处理逻辑...
   }

TaskServer.php에 예약된 작업 추가

TaskServer In .php의 시작 메소드에 예약된 작업의 시작 로직을 추가합니다.
2. 
   

   public function start()
   {
       $this->server = new Server(Config::get('swoole.rpc.listen_ip'), Config::get('swoole.rpc.listen_port'));
   
       $rpcServer = new RpcServer($this->server);
   
       $rpcServer->classMap([
           'apppcserviceTaskService',
       ]);
   
       $timerService = new TimerService();
       $timerService->start();
   
       $rpcServer->start();
   }

【RPC 서비스 및 작업 큐 시작】

프로젝트 루트 디렉터리에서 다음 명령을 실행하여 RPC 서비스 및 작업 큐를 시작합니다.

php think swoole:rpc start

【RPC 호출 예시】

응용 프로그램에서 RPC를 사용하여 작업 대기열을 호출하는 예시입니다.

class Index extends Controller
{
    public function index()
    {
        $taskService = new pppcserviceTaskService();
        $taskService->addTask([
            'task_name' => '任务名称',
            'task_data' => '任务数据',
        ]);
    }
}

【요약】

ThinkPHP6 및 Swoole 확장을 사용하여 가용성이 높은 작업 대기열 시스템을 구축할 수 있습니다. RPC 서비스를 사용하여 작업 대기열을 관리하고, 작업 추가 및 가져오기를 위한 인터페이스를 제공하고, 작업의 비동기 처리를 실현하고, 시스템의 응답 속도와 가용성을 향상시킵니다. 동시에 Swoole의 예약된 작업 기능을 사용하면 정기적으로 작업 대기열을 확인하고 대기 중인 작업을 적시에 처리할 수 있습니다. 이러한 시스템 아키텍처는 시스템의 처리 능력을 향상시킬 수 있을 뿐만 아니라 확장성과 내결함성도 우수합니다.

위 내용은 ThinkPHP6 및 Swoole로 구축된 RPC 서비스를 사용하여 고가용성 작업 대기열 구현의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!