Implementierung einer hochverfügbaren Aufgabenwarteschlange mithilfe von RPC-Diensten, die mit ThinkPHP6 und Swoole erstellt wurden

Verwendung von RPC-Diensten, die mit ThinkPHP6 und Swoole erstellt wurden, um hochverfügbare Aufgabenwarteschlangen zu implementieren

[Einführung]
Aufgabenwarteschlangen spielen eine wichtige Rolle in der modernen Entwicklung. Sie können zeitaufwändige Aufgaben vom Hauptprozess trennen und die Reaktion verbessern Die Geschwindigkeit des Systems kann die Zuverlässigkeit und hohe Verfügbarkeit von Aufgaben gewährleisten, wenn das System ausfällt oder das Netzwerk unterbrochen wird. In diesem Artikel stellen wir vor, wie Sie mit ThinkPHP6 und Swoole eine hochverfügbare Aufgabenwarteschlange erstellen, um die asynchrone Aufgabenverarbeitung zu implementieren und gleichzeitig RPC-Dienste für die Aufgabenwarteschlangenverwaltung bereitzustellen.

Umgebungsvorbereitung:
Bevor wir beginnen, müssen wir einige Entwicklungsumgebungen vorbereiten, darunter:

1. PHP-Umgebung, es wird empfohlen, PHP 7.4 und höher zu verwenden;
2. Installieren Sie MySQL Datenbank zum Speichern aufgabenbezogener Informationen;
3. Installieren Sie Redis, um Echtzeitbenachrichtigungen und Überwachung von Aufgabenwarteschlangen zu implementieren.
4. Installieren Sie die Swoole-Erweiterung, um leistungsstarke RPC-Dienste und asynchrone Aufgabenverarbeitung zu implementieren.
5. 【Projektaufbau】

Projekt erstellen

Verwenden Sie Composer, um ein neues ThinkPHP6-Projekt zu erstellen.
1. 
   

   composer create-project topthink/think hello-think

Abhängigkeiten hinzufügen

Fügen Sie die Abhängigkeiten von Swoole und Swoole-ide-helper in der Datei „composer.json“ im Stammverzeichnis des Projekts hinzu.
2. 
   

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

Führen Sie dann den Befehl

aus, um Abhängigkeiten zu installieren.

composer update

Konfigurieren Sie den RPC-Dienst und die geplanten Aufgaben von Swoole.

Erstellen Sie die Konfigurationsdatei swoole.php im Konfigurationsverzeichnis unter dem Projektstammverzeichnis und fügen Sie den folgenden Inhalt hinzu:
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,
       ],
   ];

Erstellen Sie den RPC-Server.

Erstellen Sie ihn im App-Verzeichnis des Projekts ein RPC-Verzeichnis und erstellen Sie das Serververzeichnis im RPC-Verzeichnis. Erstellen Sie dann eine TaskServer.php-Datei und fügen Sie den folgenden Inhalt hinzu:
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-Dienst erstellen

Erstellen Sie ein Dienstverzeichnis im RPC-Verzeichnis und erstellen Sie eine TaskService.php-Datei im Dienstverzeichnis. In der Datei TaskService.php definieren wir einige spezifische RPC-Methoden, wie zum Beispiel addTask und getTask.
5. 
   

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

[Implementierung der Aufgabenwarteschlange]

Aufgabenwarteschlangentabelle erstellen

Erstellen Sie eine Aufgabentabelle in der MySQL-Datenbank, um aufgabenbezogene Informationen zu speichern.
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;

Aufgabenmodell erstellen

Erstellen Sie eine Task.php-Datei im Appmodel-Verzeichnis und fügen Sie den folgenden Inhalt hinzu:
2. 
   

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

Aufgabenverarbeitungslogik erstellen

Erstellen Sie eine TaskService.php-Datei im Appservice-Verzeichnis und fügen Sie den folgenden Inhalt hinzu :
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-Server ruft Aufgabenverarbeitungslogik auf

In der addTask-Methode von TaskService.php kümmern wir uns um die Logik des Hinzufügens von Aufgaben, z. B. das Speichern von Aufgaben in der Datenbank und das anschließende Hinzufügen von Aufgaben zur Aufgabenwarteschlange.
4. 
   
[Implementierung geplanter Aufgaben]

Erstellen Sie eine Verarbeitungslogik für geplante Aufgaben

Erstellen Sie eine TimerService.php-Datei im Appservice-Verzeichnis und fügen Sie den folgenden Inhalt hinzu:
1. 
   

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

Fügen Sie geplante Aufgaben in TaskServer.php hinzu

In TaskServer In Fügen Sie der Startmethode von .php die Startlogik der geplanten Aufgabe hinzu.
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-Dienst und Aufgabenwarteschlange starten】

Führen Sie den folgenden Befehl im Projektstammverzeichnis aus, um den RPC-Dienst und die Aufgabenwarteschlange zu starten.

php think swoole:rpc start

【RPC-Aufrufbeispiel】

Ein Beispiel für die Verwendung von RPC zum Aufrufen einer Aufgabenwarteschlange in einer Anwendung.

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

【Zusammenfassung】Durch die Verwendung von ThinkPHP6 und der Swoole-Erweiterung können wir ein hochverfügbares Aufgabenwarteschlangensystem erstellen. Verwenden Sie RPC-Dienste, um Aufgabenwarteschlangen zu verwalten, Schnittstellen zum Hinzufügen und Abrufen von Aufgaben bereitzustellen, die asynchrone Verarbeitung von Aufgaben zu realisieren und die Reaktionsgeschwindigkeit und Verfügbarkeit des Systems zu verbessern. Gleichzeitig können Sie mit der Funktion „Geplante Aufgaben“ von Swoole regelmäßig die Aufgabenwarteschlange überprüfen und ausstehende Aufgaben zeitnah bearbeiten. Eine solche Systemarchitektur kann nicht nur die Verarbeitungsfähigkeiten des Systems verbessern, sondern weist auch eine gute Skalierbarkeit und Fehlertoleranz auf.

Das obige ist der detaillierte Inhalt vonImplementierung einer hochverfügbaren Aufgabenwarteschlange mithilfe von RPC-Diensten, die mit ThinkPHP6 und Swoole erstellt wurden. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!