PHP는 파일 잠금 및 프로세스 잠금을 구현합니다.

이 글은 주로 PHP 파일 잠금과 프로세스 잠금의 사용 예를 소개하고 있습니다. 편집자는 꽤 좋다고 생각하여 지금 공유하고 참고용으로 제공하겠습니다. 에디터 따라가서 같이 구경해요

1. 파일잠금

• flock()

• fclose()

• swoole_lock()

포 파일 잠금의 다양한 응용 장면 대상:

1. 동일한 파일에 액세스하고 수정하기 위한 여러 서버의 필요성을 제한합니다.

2. 파일 I/O에 참여하는 프로세스를 인위적으로 차단합니다. 파일 내용을 보호하는 논리

다음은 파일 잠금 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파일 잠금높은 동시성 해결

PHP를 사용하여 높은 동시성 해결 단계에 대한 자세한 설명 파일 잠금

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