PHP 파일 잠금 및 프로세스 잠금 분석 예

이전의 Swoole 소개를 고려하여 Swoole의 서버/클라이언트 및 다중 프로세스 메커니즘을 사용하여 잠금을 설명하겠습니다. 이 기사에서는 주로 PHP 파일 잠금 및 프로세스 잠금의 사용 예를 소개합니다. 여기서는 PHP의 잠금 메커니즘만 설명합니다. . SQL 잠금으로 인해 다양한 기능과 적용 시나리오가 있으므로 모든 사람에게 도움이 될 수 있기를 바랍니다.

1. 파일 잠금

• flock()

• fclose()

• swoole_lock()

파일 잠금의 가능한 적용 시나리오는 다음과 같습니다.

1. 서버는 동일한 파일에 액세스하고 수정해야 합니다.

3. 비즈니스 로직에서 파일 내용을 보호합니다. file Lock C/S 통신 메커니즘 하에서 사용 시 특정 통신 과정이 생략되었습니다

Server(서버 통신 과정이 생략됨):

//监听数据发送事件
$serv->on('receive', function ($serv, $fd, $from_id, $data) {
  $serv->send($fd, "ServerEnd");

  $p_file = "locktest.txt";
  var_dump(file_get_contents($p_file));
});

Client1(서버 통신 과정이 생략됨):

$s_recv = "ww";

$p_file = "locktest.txt";

$o_file = fopen($p_file,'w+');
// flock()加锁方式:
flock($o_file,LOCK_EX);

// // swoole加锁方式:
// $lock = new swoole_lock(SWOOLE_FILELOCK, $p_file);
// $lock->lock();

fwrite($o_file, 'ss' . $s_recv);

sleep(30);
// 两种解锁方式
// flock($o_file, LOCK_UN);
// $lock->unlock();

Client2 (서버 통신 과정은 생략했습니다) ):

$s_recv = "xx";

$p_file = "locktest.txt";

$o_file = fopen($p_file,'w+');
// flock()加锁方式:
flock($o_file,LOCK_EX);

// // swoole加锁方式:
// $lock = new swoole_lock(SWOOLE_FILELOCK, $p_file);
// $lock->lock();


fwrite($o_file, 'ss' . $s_recv);

// 两种解锁方式
// flock($o_file, LOCK_UN);
// $lock->unlock();

결과:

Client2가 30초간 차단되었으며, Client1의 실행이 종료될 때까지 파일이 한 번도 작성되지 않았습니다.

[l0.16@4 m29.5% c30s04] $ php swoole_client2.php

주의할 점:

1. Flock() 또는 swoole 제공 swoole_lock()에는 프로세스가 종료되면 자동으로 잠금을 해제하는 메커니즘이 있으므로 데모에서는 수동으로 잠금을 해제하지 않아도 정상적으로 실행할 수 있습니다. 따라서 sleep() 일시 중지 기능이 실행됩니다. ;

2. Flock()의 표준 릴리스 방법은 Flock($file,LOCK_UN);이지만 개인적으로 향후 문제를 피하기 위해 fclose()를 좋아합니다.

2. 프로세스 잠금

은 파일 잠금과 다릅니다. 프로세스 잠금은 파일에 대한 I/O를 방지하는 데 사용되지 않지만 여러 프로세스의 동시성으로 인해 발생하는 예기치 않은 결과를 방지하는 데 사용됩니다. 즉, 프로세스의 주요 논리 실행이 종료될 때 다른 동시 프로세스의 논리적 실행을 차단하기 전에

몇 가지 구현 아이디어가 있습니다:

1. Flock() 파일 잠금을 사용하여 임시 잠금 파일을 만듭니다. LOCK_NB를 사용하여 차단 또는 비차단 흐름을 시뮬레이션한 다음 프로세스 내부에서 판단 조건을 사용합니다. 제어 논리 실행

비차단 모델 데모:

$p_file = "locktest.txt";
$o_file = fopen($p_file, 'w+');

// 如果临时文件被锁定,这里的flock()将返回false
if (!flock($o_file, LOCK_EX + LOCK_NB)) {
  var_dump('Process Locked');
}
else {
  // 非阻塞模型必须在flock()中增加LOCK_NB参数
  // 当然,这里取消LOCK_NB参数就是阻塞模型了
  flock($o_file, LOCK_EX + LOCK_NB);
  var_dump('Process Locking');
  // 模拟长时间的执行操作
  sleep(10);
}

2. swoole에서 제공하는 공유 메모리, 캐시 방법 또는 통신 방법을 사용합니다. 다양한 프로세스에서 전역 변수를 전달합니다. 프로세스가 변수의 상태를 얻은 후 판단 조건을 사용하여 논리 실행을 제어합니다.

변수를 전달하는 방법은 다양합니다. 예를 들면 다음과 같습니다. ;

차단 모델 데모:

// 初始化memcached
$memcached = new Memcache;
$memcached->connect("localhost", 11211);

// 获取用来做状态判定的全局变量
$s_flag = $memcached->get("flag");

if (!$s_flag) {
  // 这里利用了memcached的过期时间作为演示,实际上业务处理完成后销毁该变量即可
  $memcached->set("flag", "locked", 0, 10);
  main();
}
else {
  // 阻塞模型
  while ($s_flag == 'locked') {
    var_dump('Process locked, retrying...');
    // 设置重试时间, 避免过于频繁的操作尝试
    sleep(1);
    // 更新状态变量
    $s_flag = $memcached->get("flag");
  }
  // // 非阻塞模型
  // if ($s_flag == 'locked') {
  //   var_dump('Process locked, suspended');
  //   die();
  // }
  main();
}

// 模拟业务主函数
function main() {
  var_dump('Process Running');
  // 业务执行结束后回收memcached
  // $memcached->delete("flag");
}

여기에서 주목해야 할 점은:

1 memcached의 만료 시간은 프로그램이 실행되는 실제 시간보다 작을 수 없으므로 약간 더 길어서 재활용하는 것이 좋습니다.

2. Non-Blocking 모델에서는 상태가 거짓이라고 판단되면 비즈니스 로직이 계속 실행되지 않도록 프로세스를 일시 중지하거나 차단해야 합니다. ;

3. 실제 응용 프로그램에서는 재시도 시간을 설정해야 합니다. 그러면 memcached에 대한 대량의 I/O 동시성을 크게 줄이고 서버 부담을 줄일 수 있습니다.

관련 권장 사항:

파일 잠금, 뮤텍스 잠금에 대한 자세한 설명 및 PHP의 읽기-쓰기 잠금

PHP 파일 잠금 및 프로세스 잠금에 대한 간략한 소개

PHP의 파일 잠금과 프로세스 잠금의 차이점 비교

위 내용은 PHP 파일 잠금 및 프로세스 잠금 분석 예의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!