Melaksanakan baris gilir tugas yang sangat tersedia menggunakan perkhidmatan RPC yang dibina dengan ThinkPHP6 dan Swoole

Menggunakan perkhidmatan RPC yang dibina dengan ThinkPHP6 dan Swoole untuk melaksanakan baris gilir tugas dengan ketersediaan tinggi

[Pengenalan]#🎜🎜 queues moden pembangunan Memainkan peranan penting, ia boleh memisahkan tugas yang memakan masa daripada proses utama, meningkatkan kelajuan tindak balas sistem, dan memastikan kebolehpercayaan dan ketersediaan tugas yang tinggi sekiranya berlaku kegagalan sistem atau gangguan rangkaian. Dalam artikel ini, kami akan memperkenalkan cara menggunakan ThinkPHP6 dan Swoole untuk membina baris gilir tugas yang sangat tersedia untuk melaksanakan pemprosesan tugas tak segerak dan menyediakan perkhidmatan RPC untuk pengurusan baris gilir tugas.

【Persediaan persekitaran】

Sebelum bermula, kita perlu menyediakan beberapa persekitaran pembangunan, termasuk:

persekitaran PHP, adalah disyorkan untuk menggunakan Versi PHP 7.4 dan ke atas;
1. Pasang Komposer, digunakan untuk menguruskan kebergantungan projek;
2. Pasang pangkalan data MySQL, digunakan untuk menyimpan maklumat berkaitan tugasan; #Pasang Redis , digunakan untuk melaksanakan pemberitahuan masa nyata dan pemantauan baris gilir tugas;
3. Pasang sambungan Swoole untuk melaksanakan perkhidmatan RPC berprestasi tinggi dan pemprosesan tugas tak segerak.
5. 【Pembinaan projek】

Buat projek

Gunakan Komposer untuk mencipta projek ThinkPHP6 baharu.

1. composer create-project topthink/think hello-think

   
   
Tambah kebergantungan

Tambah kebergantungan Swoole dan Swoole-ide-helper kepada fail composer.json dalam direktori akar projek.

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

   
   Kemudian laksanakan arahan
untuk memasang dependensi.

composer updateMengkonfigurasi perkhidmatan RPC Swoole dan tugas berjadual

Buat fail konfigurasi swoole.php dalam direktori konfigurasi di bawah direktori akar projek dan tambah kandungan berikut:

# 🎜🎜#

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,
    ],
];

3. 
   Buat pelayan RPC
Buat direktori rpc dalam direktori aplikasi projek dan buat direktori pelayan dalam direktori rpc. Kemudian buat fail TaskServer.php dan tambah kandungan berikut:

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();
    }
  
}

4. 
   Cipta perkhidmatan RPC
Buat direktori perkhidmatan dalam direktori rpc dan letakkannya dalam direktori perkhidmatan Cipta fail TaskService.php dalam . Dalam fail TaskService.php, kami mentakrifkan beberapa kaedah RPC khusus, seperti addTask dan getTask.

namespace apppcservice;

class TaskService
{
    public function addTask($data)
    {
        // 处理添加任务的逻辑，将任务添加到任务队列中
    }

    public function getTask($id)
    {
        // 处理获取任务的逻辑，从任务队列中获取相关任务信息
    }

    // 其他RPC方法...
}

5. [Pelaksanaan baris gilir tugas]
   

Buat jadual giliran tugas

Buat jadual tugasan dalam pangkalan data MySQL -maklumat berkaitan.

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;

1. 
   Buat model tugasan
Buat fail Task.php dalam direktori appmodel dan tambah kandungan berikut:

namespace appmodel;

use thinkModel;

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

🎜🎜#
2. Buat logik pemprosesan tugas
   Buat fail TaskService.php dalam direktori appservice dan tambah kandungan berikut:

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);
    }

    // 其他任务处理逻辑...
}

#🎜C🎜 Panggil logik pemprosesan tugas pada penghujung
3. Dalam kaedah addTask TaskService.php, kami akan mengendalikan logik untuk menambah tugasan, seperti menyimpan tugasan dalam pangkalan data, dan kemudian menambah tugasan pada baris gilir tugas.
   

[Pelaksanaan tugas berjadual]

4. 
   Buat logik pemprosesan tugas berjadual
Buat direktori Perkhidmatan Pemasa.phpy. Dan tambahkan kandungan berikut:

namespace appservice;

use appmodelTask;
use SwooleTimer;

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

Tambah tugas berjadual dalam TaskServer.php
1. Dalam kaedah permulaan TaskServer.php, tambah logik permulaan bagi tugas yang dijadualkan.
   

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();
}

【Mulakan perkhidmatan RPC dan baris gilir tugas】

Jalankan arahan berikut dalam direktori akar projek untuk memulakan perkhidmatan RPC dan baris gilir tugas.

2. php think swoole:rpc start

   
   [contoh panggilan RPC]
Contoh penggunaan RPC untuk memanggil baris gilir tugas dalam aplikasi.

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

【Ringkasan】
Dengan menggunakan sambungan ThinkPHP6 dan Swoole, kami boleh membina sistem baris gilir tugas yang tersedia. Gunakan perkhidmatan RPC untuk mengurus baris gilir tugas, menyediakan antara muka untuk menambah tugas dan mendapatkan tugas, merealisasikan pemprosesan tugasan tak segerak, dan meningkatkan kelajuan tindak balas dan ketersediaan sistem. Pada masa yang sama, menggunakan fungsi tugas berjadual Swoole, anda boleh menyemak baris gilir tugas dengan kerap dan memproses tugas yang belum selesai tepat pada masanya. Seni bina sistem sedemikian bukan sahaja dapat meningkatkan keupayaan pemprosesan sistem, tetapi juga mempunyai kebolehskalaan yang baik dan toleransi kesalahan.

Atas ialah kandungan terperinci Melaksanakan baris gilir tugas yang sangat tersedia menggunakan perkhidmatan RPC yang dibina dengan ThinkPHP6 dan Swoole. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!