Swoole 비동기 프로그래밍 실습: 고성능 큐잉 시스템 구축-Swoole-php.cn

인터넷 애플리케이션의 급속한 발전으로 인해 코드 성능과 애플리케이션 효율성을 향상시키기 위해 비동기 프로그래밍을 사용하기 시작하는 회사가 점점 더 많아지고 있습니다. Swoole은 고성능, 높은 동시성 및 뛰어난 확장성을 갖춘 강력한 PHP용 비동기 프로그래밍 프레임워크입니다. 이 기사에서는 Swoole을 사용하여 고성능 대기열 시스템을 구축하는 방법을 소개합니다.

먼저 대기열 시스템이 무엇인지 이해해야 합니다. 큐잉 시스템은 다양한 서비스의 큐 관리 및 스케줄링을 통해 서비스의 응답 속도와 시스템의 동시 처리 능력을 향상시키는 서비스 종합 스케줄링 시스템이다. 실제 애플리케이션에서 큐잉 시스템은 일반적으로 높은 동시 액세스, 비동기 작업 스케줄링, 로드 밸런싱 등과 같은 기능을 구현하는 데 사용됩니다. 따라서 높은 성능과 고가용성이 필요합니다.

다음으로 Swoole을 사용하여 고성능 대기열 시스템을 구축하는 방법을 설명하기 위해 다음 요구 사항을 사용합니다.

다중 대기열을 지원하고 대기열을 관리할 수 있습니다.
작업 추가 및 실행을 지원합니다. 작업 상태를 관리할 수 있습니다.
여러 소비자가 작업을 처리하고 소비자를 관리할 수 있습니다.
작업 재시도 및 시간 초과 처리를 지원합니다.
작업의 비동기 처리 및 동기 처리를 지원합니다.

이제 본격적으로 Swoole을 사용하여 고성능 대기열 시스템을 구축해 보겠습니다.

1. Swoole 소개

우선 프로젝트에 Swoole을 도입해야 합니다. 여기에서는 Composer를 통해 Swoole 종속성을 쉽게 도입할 수 있습니다.

composer require swoole/swoole

2. 대기열 구축

대기열 시스템에서 대기열은 작업을 저장하는 핵심 구조입니다. 대기열을 만들고 대기열에 작업을 추가해야 합니다. 여기서는 Redis를 대기열 저장 방법으로 사용하고 PHP Redis 확장을 사용하여 대기열을 운영합니다.

Redis 연결 생성

Redis를 사용하기 전에 먼저 Redis에 대한 연결을 생성해야 합니다. 여기서는 Redis 연결을 관리하기 위해 Redis 연결 풀을 생성합니다.

use SwooleCoroutineChannel;

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

로그인 후 복사

}

큐 만들기

다음으로 작업 추가, 작업 획득, 작업 삭제 작업을 포함한 대기열 작업을 관리하는 대기열 클래스를 만들 수 있습니다.

class Queue
{

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. 작업 실행 구현

작업을 대기열에 추가한 후 작업을 실행하려면 작업 실행자가 필요합니다. 여기서는 코루틴을 사용하여 작업의 비동기 실행을 구현하고 작업자 프로세스를 사용하여 작업 실행 효율성을 향상시킵니다.

Worker 프로세스 만들기

Swoole에서는 Worker 프로세스를 사용하여 다중 프로세스 처리 작업을 구현할 수 있습니다. 여기서는 작업을 처리하기 위한 작업자 프로세스를 만듭니다.

$worker = new SwooleProcessWorker();

코루틴 실행기 만들기

다음으로 작업을 처리할 코루틴 실행기를 만들 수 있습니다. 여기서는 코루틴을 사용하여 비동기 작업 실행을 구현하고 Golang 스타일 코루틴 풀을 사용하여 동시 처리의 효율성을 향상시킵니다.

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

로그인 후 복사

}

코루틴 만들기

다음으로 작업을 수행하는 코루틴을 만들 수 있습니다.

class 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. 서비스 만들기

마지막으로 Swoole을 사용하여 대기열 쿼리 및 작업 추가 기능을 제공하는 서비스를 만들 수 있습니다.

대기열 관리 구현

Swoole의 HTTP Server를 사용하여 서비스 포트 모니터링을 구현하고 HTTP 요청을 통해 대기열 관리를 수행할 수 있습니다. 여기에서는 목록 획득, 작업 삭제 및 작업 추가를 위한 인터페이스를 제공합니다.

작업 실행 구현

Swoole의 TaskWorker 프로세스를 사용하여 작업 실행을 구현할 수 있습니다. TaskWorker 프로세스에 작업을 디스패치함으로써 TaskWorker 프로세스는 작업을 비동기적으로 실행합니다.

class Task
{

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

로그인 후 복사

}

서비스 시작 구현

마지막으로 서비스 시작을 구현하고, 포트를 수신하고, TaskWorker 프로세스를 시작하여 작업을 수행할 수 있습니다.

$http = new SwooleHttpServer("127.0.0.1", 9501);
$http->on('start', function () {

echo "Server started

로그인 후 복사

";
});

$http->on ('요청', 함수($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', 함수($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();

5. 요약

이 기사에서는 Swoole을 사용하여 고성능 큐 시스템을 구현하는 방법을 소개합니다. Swoole의 코루틴과 Worker 프로세스를 통해 비동기 작업의 고성능 처리를 달성하고 Redis 스토리지 구조를 통해 효율적인 작업 관리 및 제어를 달성할 수 있습니다. 스케줄링. 이러한 큐잉 시스템은 비동기 작업 스케줄링, 높은 동시 액세스 및 로드 밸런싱과 같은 기능적 시나리오에서 널리 사용될 수 있습니다.

위 내용은 Swoole 비동기 프로그래밍 실습: 고성능 큐잉 시스템 구축의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!