Amalan pengaturcaraan tak segerak swoole: mencipta sistem baris gilir berprestasi tinggi

Dengan perkembangan pesat aplikasi Internet, semakin banyak syarikat mula menggunakan pengaturcaraan tak segerak untuk meningkatkan prestasi kod dan kecekapan aplikasi. Swoole ialah rangka kerja pengaturcaraan tak segerak yang berkuasa untuk PHP dengan prestasi tinggi, konkurensi tinggi dan kebolehskalaan yang sangat baik. Dalam artikel ini, kami akan memperkenalkan cara menggunakan Swoole untuk membina sistem baris gilir berprestasi tinggi.

Pertama, kita perlu memahami apa itu sistem beratur. Sistem baris gilir ialah sistem penjadualan keseluruhan perkhidmatan yang meningkatkan kelajuan tindak balas perkhidmatan dan keupayaan pemprosesan serentak sistem dengan pengurusan baris gilir dan penjadualan pelbagai perkhidmatan. Dalam aplikasi praktikal, sistem baris gilir biasanya digunakan untuk melaksanakan fungsi seperti akses serentak tinggi, penjadualan tugas tak segerak, pengimbangan beban, dsb. Oleh itu, prestasi tinggi dan ketersediaan tinggi adalah perlu.

Seterusnya, kami akan menggunakan keperluan berikut sebagai contoh untuk menerangkan cara menggunakan Swoole untuk membina sistem baris gilir berprestasi tinggi:

1. Menyokong berbilang baris gilir dan boleh menguruskan baris gilir ;
2. Menyokong penambahan dan pelaksanaan tugas, dan boleh mengurus status tugas;
3. Menyokong berbilang pengguna untuk memproses tugas, dan boleh mengurus pengguna;
4. Menyokong percubaan semula tugas dan tamat masa pemprosesan;
5. Menyokong pemprosesan tak segerak dan pemprosesan tugasan segerak.

Sekarang, mari mulakan perniagaan dan mula menggunakan Swoole untuk membina sistem baris gilir berprestasi tinggi ini.

1. Memperkenalkan Swoole

Pertama sekali, kami perlu memperkenalkan Swoole ke dalam projek. Di sini kita boleh memperkenalkan kebergantungan Swoole dengan mudah melalui Komposer.

komposer memerlukan swoole/swoole

2. Bina baris gilir

Dalam sistem baris gilir, baris gilir ialah struktur teras untuk menyimpan tugas. Kita perlu membina baris gilir dan menambah tugasan pada baris gilir. Di sini kami menggunakan Redis sebagai kaedah penyimpanan baris gilir dan menggunakan sambungan PHP Redis untuk mengendalikan baris gilir.

1. Buat sambungan Redis

Sebelum menggunakan Redis, kita perlu membuat sambungan ke Redis terlebih dahulu. Di sini kami mencipta kumpulan sambungan Redis untuk mengurus sambungan Redis.

gunakan SwooleCoroutineChannel;

kelas RedisPool
{

private $max;
private $pool;

public function __construct($max = 100)
{
    $this->max = $max;
    $this->pool = new Channel($max);
}

public function get($config)
{
    if (!$this->pool->isEmpty()) {
        return $this->pool->pop();
    }

    $redis = new Redis();
    $redis->connect($config['host'], $config['port']);
    $redis->select($config['db']);
    
    return $redis;
}

public function put($redis)
{
    if ($this->pool->length() < $this->max) {
        $this->pool->push($redis);
    } else {
        $redis->close();
    }
}

}

2. Buat Giliran

Connect Seterusnya, kita boleh mencipta kelas baris gilir untuk mengurus operasi baris gilir, termasuk penambahan tugas, pemerolehan tugas dan pemadaman tugas.

Baris Gilir kelas

{

private $redis;

public function __construct($config)
{
    $this->redis = (new RedisPool())->get($config);
}

public function push($queueName, $data)
{
    $this->redis->lpush($queueName, $data);
}

public function pop($queueName)
{
    return $this->redis->rpop($queueName);
}

public function del($queueName, $data)
{
    $this->redis->lrem($queueName, -1, $data);
}

}

3 Laksanakan pelaksanaan tugas

Selepas menambah tugasan pada baris gilir, kita memerlukan pelaksana tugas. untuk melaksanakan tugas. Di sini kami menggunakan coroutine untuk melaksanakan pelaksanaan tugasan tak segerak, dan menggunakan proses Pekerja untuk meningkatkan kecekapan pelaksanaan tugas.

Buat proses Pekerja

Dalam Swoole, kami boleh menggunakan proses Pekerja untuk melaksanakan tugas pemprosesan berbilang proses. Di sini kami mencipta proses Pekerja untuk mengendalikan tugas.

$worker = new SwooleProcessWorker();

Buat pelaksana coroutine

Seterusnya, kita boleh mencipta pelaksana coroutine untuk mengendalikan Tugas. Di sini kami menggunakan coroutine untuk melaksanakan pelaksanaan tugas tak segerak dan menggunakan kumpulan coroutine gaya Golang untuk meningkatkan kecekapan pemprosesan serentak.

kelas CoroutineExecutor

{

private $pool;
private $redisConfig;

public function __construct($maxCoroutineNum, $redisConfig)
{
    $this->pool = new SwooleCoroutineChannel($maxCoroutineNum);
    $this->redisConfig = $redisConfig;

    for ($i = 0; $i < $maxCoroutineNum; $i++) {
        $this->pool->push(new Coroutine());
    }
}

public function execute($callback, $data)
{
    $coroutine = $this->pool->pop();
    $coroutine->execute($callback, $data, $this->redisConfig);
    $this->pool->push($coroutine);
}

}

Mencipta coroutine

Seterusnya, kita boleh mencipta coroutine untuk melaksanakan tugasan.

kelas Coroutine

{

private $redis;

public function __construct()
{
    $this->redis = null;
}

public function execute($callback, $data, $config)
{
    if (!$this->redis) {
        $this->redis = (new RedisPool())->get($config);
    }
    
    Coroutine::create(function () use ($callback, $data) {
        call_user_func($callback, $this->redis, $data);
    });
}

}

4 Cipta perkhidmatan

Akhir sekali, kami boleh menggunakan Swoole untuk mencipta perkhidmatan untuk menyediakan baris gilir. pertanyaan dan Fungsi ditambah oleh tugasan.

Melaksanakan pengurusan baris gilir

Kami boleh menggunakan Pelayan HTTP Swoole untuk melaksanakan pemantauan port perkhidmatan dan pengurusan baris gilir melalui permintaan HTTP. Di sini kami menyediakan antara muka untuk pemerolehan senarai, pemadaman tugas dan penambahan tugas.

Merealisasikan pelaksanaan tugas

Kita boleh menggunakan proses TaskWorker Swoole untuk melaksanakan pelaksanaan tugas. Dengan menghantar tugasan ke proses TaskWorker, proses TaskWorker melaksanakan tugasan secara tidak segerak.

Tugas kelas

{

public function execute($worker, $workerId, $taskId, $taskData)
{
    $executor = new CoroutineExecutor(64, [
        'host' => '127.0.0.1',
        'port' => 6379,
        'db' => 0
    ]);
    $executor->execute($taskData['callback'], $taskData['data']);

    return true;
}

}

Melaksanakan permulaan perkhidmatan

Akhir sekali, kami dapat melaksanakan permulaan perkhidmatan dan pemantauan port, dan mulakan proses TaskWorker untuk melaksanakan tugas.

$http = new SwooleHttpServer("127.0.0.1", 9501);

$http->on('start', function () {

echo "Server started

";

});

$http->on('request', function ($request, $response) {

$queue = new Queue([
    'host' => '127.0.0.1',
    'port' => 6379,
    'db' => 0
]);

switch ($request->server['request_uri']) {
    case '/queue/list':
        // 获取队列列表
        break;
    case '/queue/delete':
        // 删除任务
        break;
    case '/queue/add':
        $data = json_decode($request->rawContent(), true);
        $queue->push($data['queue'], $data['data']);
        $http->task([
            'callback' => function ($redis, $data) {
                // 任务执行逻辑
            },
            'data' => $data
        ]);
        break;
    default:
        $response->status(404);
        $response->end();
        break;
}

});

$http-> ;on('task', function ($http, $taskId, $workerId, $data) {

$task = new Task();
$result = $task->execute($http, $workerId, $taskId, $data);

return $result;

});

$http->on('finish', function ($http, $taskId, $data) {

// 任务执行完成逻辑

});

$http->start();

Ringkasan

Artikel ini memperkenalkan cara menggunakan Swoole untuk melaksanakan sistem baris gilir berprestasi tinggi Melalui coroutine dan proses Pekerja Swoole, kami boleh mencapai pemprosesan tugas tak segerak berprestasi tinggi, dan mencapai pengurusan dan penjadualan tugas yang cekap melalui struktur storan Redis sistem baris gilir boleh digunakan secara meluas dalam senario berfungsi seperti penjadualan tugas tak segerak, akses serentak tinggi, pengimbangan beban, dll. Ia adalah penyelesaian yang layak untuk dipromosikan dan digunakan .

Atas ialah kandungan terperinci Amalan pengaturcaraan tak segerak swoole: mencipta sistem baris gilir berprestasi tinggi. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!