분산 잠금 관리를 위해 Hyperf 프레임워크를 사용하는 방법-Swoole-php.cn

분산 잠금 관리를 위해 Hyperf 프레임워크를 사용하는 방법

WBOY

풀어 주다： 2023-10-28 09:37:43

원래의

869명이 탐색했습니다.

분산 잠금 관리를 위해 Hyperf 프레임워크를 사용하는 방법

소개:
분산 시스템에서는 동시에 작업을 실행하는 여러 노드로 인해 여러 노드가 동시에 공유 리소스에 액세스하게 됩니다. 데이터 불일치, 더러운 읽기 및 기타 문제. 이 문제를 해결하려면 리소스의 독점성을 보장하기 위해 분산 잠금 메커니즘을 사용해야 하는 경우가 많습니다. Hyperf 프레임워크는 분산 잠금을 관리하는 편리한 방법을 제공합니다.

1. Hyperf 프레임워크 소개
Hyperf는 PHP 코루틴을 기반으로 하는 유연한 고성능 프레임워크로, 데이터 기반 애플리케이션을 빠르게 구축하는 데 적합합니다. 낮은 임계값, 유연한 종속성 주입, 강력한 IoC 컨테이너, 고성능 및 풍부한 표준 구성 요소의 특성을 가지고 있습니다.

2. 분산 잠금 원리
분산 잠금에는 일반적으로 데이터베이스 기반과 캐시 기반의 두 가지 구현 방법이 있습니다. 데이터베이스 기반 분산 잠금 구현은 비교적 간단하지만 성능이 낮습니다. 캐시 기반 분산 잠금은 일반적으로 높은 성능과 안정성을 갖춘 Redis 또는 Memcached와 같은 고성능 캐시 서비스를 사용하여 구현됩니다.

3. Hyperf 프레임워크는 Redis를 통합합니다

Redis 확장 설치

PHP 환경에서 Redis 확장을 사용하려면 Redid 관련 확장을 먼저 설치해야 합니다.

pecl install redis

로그인 후 복사

Redis 구성 추가

Hyperf 프로젝트 config/autoload/redis.php의 구성 파일에 Redis 연결 매개변수 추가: config/autoload/redis.php中添加Redis的连接参数：

<?php

declare(strict_types=1);

return [
    'default' => [
        'host' => env('REDIS_HOST', '127.0.0.1'),
        'auth' => env('REDIS_AUTH', null),
        'port' => (int) env('REDIS_PORT', 6379),
        'db' => (int) env('REDIS_DB', 0),
        'pool' => [
            'max_connections' => (int) env('REDIS_MAX_CONNECTIONS', 10),
            'min_connections' => (int) env('REDIS_MIN_CONNECTIONS', 1),
            'connect_timeout' => (float) env('REDIS_CONNECT_TIMEOUT', 1.0),
            'wait_timeout' => (float) env('REDIS_WAIT_TIMEOUT', 3.0),
            'heartbeat' => (int) env('REDIS_HEARTBEAT', -1),
            'max_idle_time' => (float) env('REDIS_MAX_IDLE_TIME', 60),
        ],
    ],
];

로그인 후 복사

配置Redis连接信息

在根目录下的.env文件中添加以下Redis连接信息，注意根据实际情况修改参数：

REDIS_HOST=127.0.0.1
REDIS_PORT=6379
REDIS_DB=0

로그인 후 복사

四、使用Hyperf框架进行分布式锁

创建锁服务类

在Hyperf的app/Utils目录下创建LockService.php

<?php

declare(strict_types=1);

namespace AppUtils;

use HyperfRedisRedisFactory;
use HyperfUtilsApplicationContext;
use RedisException;

class LockService
{
    /**
     * 获取锁
     * @param string $key 锁的key
     * @param int $expire 过期时间，单位为秒
     * @return bool
     */
    public function lock(string $key, int $expire): bool
    {
        $redis = $this->getRedis();
        try {
            return $redis->set($key, 1, ['nx', 'ex' => $expire]) ? true : false;
        } catch (RedisException $exception) {
            return false;
        }
    }

    /**
     * 解锁
     * @param string $key 锁的key
     * @return bool
     */
    public function unlock(string $key): bool
    {
        $redis = $this->getRedis();
        try {
            return $redis->del([$key]) > 0;
        } catch (RedisException $exception) {
            return false;
        }
    }

    /**
     * 获取Redis实例
     * @return mixed
     */
    private function getRedis()
    {
        $container = ApplicationContext::getContainer();
        return $container->get(RedisFactory::class)->get('default');
    }
}

로그인 후 복사

.env

<?php

declare(strict_types=1);

namespace AppController;

use AppUtilsLockService;
use HyperfHttpServerAnnotationAutoController;

/**
 * @AutoController()
 */
class DemoController
{
    public function index(LockService $lockService)
    {
        // 获取锁
        $lockKey = 'demo_lock';
        $expire = 10; // 过期时间10秒
        if ($lockService->lock($lockKey, $expire)) {
            // 获得锁，执行业务逻辑
            // TODO: 处理业务逻辑

            // 释放锁
            $lockService->unlock($lockKey);
        } else {
            // 未获得锁，返回重试或失败的响应
        }
    }
}

로그인 후 복사

4. Hyperf 프레임워크를 사용하여 분산 잠금 생성

잠금 서비스 클래스

app/Utils

LockService.php

위 내용은 분산 잠금 관리를 위해 Hyperf 프레임워크를 사용하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!