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

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

Buat proses Pekerja

Buat pelaksana coroutine

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

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

Melaksanakan pengurusan baris gilir

Merealisasikan pelaksanaan tugas

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

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

echo "Server started

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

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

return $result;

// 任务执行完成逻辑

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!