PHP의 파일 잠금 및 프로세스 잠금 예제 소개

이 글은 주로 PHP 파일 잠금과 프로세스 잠금의 사용 예를 소개합니다. 편집자는 꽤 좋다고 생각해서 지금 공유하고 참고용으로 제공하겠습니다. 이전에 swoole을 소개한 것을 고려하여 swoole의 서버/클라이언트 및 다중 프로세스 메커니즘을 사용하여 잠금을 설명하겠습니다.

여기서는 PHP의 잠금 메커니즘만 설명합니다. SQL의 잠금 동작 모드와 적용 시나리오가 다르며 별도로 설명됩니다.

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

1. 동일한 파일에 액세스하고 수정해야 하는 동시 다중 프로세스 또는 다중 서버를 제한합니다. 2. 파일 I/O에 참여하는 프로세스의 대기열 및 인위적 차단.

• 3 .비즈니스 로직에서 파일 내용을 보호하세요.

다음은 파일 잠금 C/S 통신 메커니즘을 사용하는 것으로, 특정 통신 프로세스는 생략되었습니다.

• 서버(서버 통신 프로세스는 생략되었습니다) ):

• //监听数据发送事件
  $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. swoole에서 제공하는 Flock() 또는 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
$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. 비차단 모델에서는 상태가 거짓이라고 판단되면 비즈니스 로직이 계속 실행되지 않도록 프로세스를 종료하거나 차단해야 합니다.

3. 애플리케이션의 경우 재시도 시간을 설정해야 합니다. 이렇게 하면 memcached에 대한 대량의 I/O 동시성을 크게 줄이고 서버 부담을 줄일 수 있습니다.

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