다시 쓰기 전에 socket_write가 완료 될 때까지 기다리십시오.

Question

PHP 서버에서 노드 서버로 일부 데이터를 보내야합니다. 성공적으로 내 노드 서버 및 출력이 메시지를 전송

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); 
$result = socket_connect($socket, '127.0.0.1', '3000'); 
socket_write($socket, "Hello World", 11); 
socket_close($socket); 

이 코드를 실행 :

는 여기에 지금까지 PHP 측에서 무슨의 단순화 된 버전입니다.

그러나 소켓으로 둘 이상의 메시지를 다시 보내야합니다. 실제로 수천 건의 응답을 보내야합니다. 내가 였다면과 같이 루프 내에서 socket_write() 함수를 호출합니다 : 함께 모든 데이터를 추가하고 스크립트의 끝에서 한 번에 보낼 것으로 보인다

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); 
$result = socket_connect($socket, '127.0.0.1', '3000'); 
for($i=0;$i<1000;$i++){ 
    socket_write($socket, "Hello World", 11); 
} 
socket_close($socket); 

. 실시간으로 데이터를 다시 보내야합니다. PHP에서이 작업을 수행 할 수있는 방법이 있습니까?

Answer 1

많은 PHP 소켓 라이브러리를 살펴본 결과 거의 모든 소켓이 소켓을 보낸 후에 usleep(1000000)을 구현 한 것으로 나타났습니다. 이것이 최선의 방법인지는 확실하지 않지만 PHP의 한계로 인해 유일한 방법 일 수 있습니다.

결국 데이터가 소켓에 마지막으로 기록 된 시간을 저장하기로 결정했습니다. 그런 다음 경과 된 시간을 계산하고이를 1000000 마이크로 초에서 뺍니다. 이렇게하면 스크립트가 필요한 것보다 오래 기다리지 않습니다.

public function send(array $payload){ 
    $json = json_encode($payload); 
    $write = socket_write($this->socket, $json, strlen($json); 
    $sleep_time = 1000000 - (microtime(true) - $this->last_sent); 
    if($sleep_time > 0) usleep($sleep_time); 
    $this->last_sent = microtime(true); 
    return $write !== false ? true : false; 
}