PHP 비동기: fsockopen 컬을 사용하여 PHP의 비동기 처리와 유사한 기능적 메서드 구현

주류 관점에서 보면 PHP는 프로세스 지향 언어입니다. 가장 큰 단점은 멀티 스레드 관리가 불가능하다는 점입니다. 프로그램이 처음부터 끝까지 논리에 따라 실행되며 분기가 불가능합니다. PHP가 주류 프로그래밍 언어 중 더 높은 수준의 언어로 발전하는 것을 제한하는 이유입니다.

PHP에서는 특정 작업을 수행하는 동안 실제로 다른 작업을 수행하고 싶을 때가 있습니다. 사용자가 티켓을 받을 때 데이터베이스가 쿼리를 수행하는 것을 원하지 않습니다. 판단, 삽입을 수행하고 완료 후 사용자 결과를 반환합니다. 실제로 사용자가 제출한 후 다양한 작업을 성공적으로 처리했다고 사용자에게 직접 알릴 수 있습니다. . 물론 이제 우리는 이 상황을 처리하기 위해 메시지 목록을 사용합니다. 사용자가 페이지를 성공적으로 닫은 후에도 실제로 배경은 여전히 ​​남아 있음을 메시지 대기열에 저장합니다. 메시지를 하나씩 수신하여 작업 대기열에서 요청을 제거합니다. 우리 기사에서는 사용자가 기다릴 필요 없이 백그라운드에서 작업을 실행할 수 있도록 이기종 접근 방식을 사용합니다.

먼저 요청 항목을 만들어야 합니다.

제출된 데이터

백그라운드에 제출됨

사용자가 이미 수행했습니다

둘째, 사용자가 온라인 상태인지 여부가 작업에 영향을 주지 않는 백그라운드 처리 프로그램이 필요합니다.

<?php 
ignore_user_abort(true);
set_time_limit(0);

들어오는 데이터

데이터 처리

이제 질문은 첫 번째 코드에서 "백그라운드에 제출"하는 방법입니다. 우리는 비차단 요청을 통해 이 기능을 구현합니다. 즉, 접근 가능한 URL을 생성하고, 이 URL에 두 번째 프로그램을 실행하고, 요청을 통해 해당 URL을 요청함으로써 두 번째 프로그램의 자동 실행을 활성화시키는 것입니다.

다음으로 코드를 직접 살펴보겠습니다.

// 远程请求（不获取内容）函数
function _sock($url) {
 $host = parse_url($url,PHP_URL_HOST);
 $port = parse_url($url,PHP_URL_PORT);
 $port = $port ? $port : 80;
 $scheme = parse_url($url,PHP_URL_SCHEME);
 $path = parse_url($url,PHP_URL_PATH);
 $query = parse_url($url,PHP_URL_QUERY);
 if($query) $path .= '?'.$query;
 if($scheme == 'https') {
  $host = 'ssl://'.$host;
 }
 
 $fp = fsockopen($host,$port,$error_code,$error_msg,1);
 if(!$fp) {
  return array('error_code' => $error_code,'error_msg' => $error_msg);
 }
 else {
  stream_set_blocking($fp,true);//开启了手册上说的非阻塞模式
  stream_set_timeout($fp,1);//设置超时
  $header = "GET $path HTTP/1.1\r\n";
  $header.="Host: $host\r\n";
  $header.="Connection: close\r\n\r\n";//长连接关闭
  fwrite($fp, $header);
  usleep(1000); // 这一句也是关键，如果没有这延时，可能在nginx服务器上就无法执行成功
  fclose($fp);
  return array('error_code' => 0);
 }
}

이 함수에서는 fsockopen을 사용하여 URL에 액세스합니다. 에 접근할 때 URL에 표시된 콘텐츠를 얻을 필요는 없고 접근 요청만 발행하며 요청이 도착하면 접근이 즉시 종료됩니다. 이것의 장점은 방문한 URL이 신뢰할 수 있는 정보를 반환할 때까지 기다릴 필요가 없기 때문에 시간이 절약된다는 것입니다. 이 코드의 실행 시간은 일반 방문자가 거의 인지할 수 없는 0.1~0.2초입니다. 따라서 사용시에는 이 함수와 해당 URL만 호출하면 됩니다. 하지만 여기에는 데이터 전송 부분이 제공되지 않습니다. 실제로 데이터를 전송하는 방법은 $header에 게시물 내용을 추가하기만 하면 됩니다.

fsockopen 외에도 컬을 사용하면 실제로 이 효과를 얻을 수 있습니다. 일부 호스트에서는 fsockopen을 지원하지 않으므로 컬을 사용하여 이 효과를 얻을 수 있습니다.

function _curl($url) {
 $ch = curl_init();
 curl_setopt($ch,CURLOPT_URL,$url);
 curl_setopt($ch,CURLOPT_RETURNTRANSFER,1);
 curl_setopt($ch,CURLOPT_TIMEOUT,1);
 $result = curl_exec($ch);
 curl_close($ch);
 return $result;
}

이 코드의 핵심은 단 1초의 시간 초과를 제공하는 것입니다. 즉, 반환된 콘텐츠의 수신 여부에 관계없이 컬이 요청을 한다는 의미입니다. 1초 접근이 종료되므로 이 함수의 실행 데이터는 1.0~1.1초이다. 하지만 사용자 입장에서는 데이터 처리가 필요한 애플리케이션이라면 1초의 대기 시간은 거의 무시됩니다. 더 간단하고 이해하기 쉬운 코드를 사용하고 싶다면 컬을 선택해 구현하면 됩니다.