3

これは私を夢中にさせます。どちらもノンブロッキング ソケットを使用して、クライアントがサーバーに接続する php 5.3 で非常に単純なノンブロッキング ソケット スクリプトを作成する必要があります。

phpsocketdaemonとphp manualの例を試しましたが、どちらの場合もサーバーに接続しようとすると次のエラーが発生します。

socket_connect() [function.socket-connect]: unable to connect [10035]:
A non-blocking socket operation could not be completed immediately

エラーが発生したクライアントスクリプト:

$service_port = 2002;
$address = '127.0.0.1';

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_nonblock($socket); 
$result = socket_connect($socket, $address, $service_port);
...

Win 7 で Zend Server 5.6.0 SP1 の無料版を使用しています。

この問題を解決する方法を知っている人、またはノンブロッキング ソケット クライアント/サーバー スクリプトの簡単でわかりやすい例を知っている人はいますか?

4

2 に答える 2

10

socket_connect()ソケットをブロックしないように設定すると、接続されている場合は TRUE が返され、接続されていない場合は FALSEが返されるとは期待できません。

PHPマニュアルページ：

ソケットが非ブロッキングの場合、この関数は FALSE を返し、Operation now in progress というエラーを返します。

これはどの言語でも同じです。正しく接続されているかどうかを確認する前に、ソケットの「ブロッキング」を設定するか、ファイル記述子をポーリング/選択する必要があります。PHP では、しばらくしてから関数を呼び出して、socket_connect()true、false を返すか、タイムアウトになるまで待機するかを確認できます。

このコードを試してください[タイムアウトルーチンの小さなエラーを修正するために編集] :

<?php

  $service_port = 2002;
  $address = '127.0.0.1';
  $timeout = 3;

  $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
  socket_set_nonblock($socket);
  $error = NULL;
  $attempts = 0;
  $timeout *= 1000;  // adjust because we sleeping in 1 millisecond increments
  $connected = FALSE;
  while (!($connected = @socket_connect($socket, $address, $service_port)) && ($attempts++ < $timeout)) {
        $error = socket_last_error();
        if ($error != SOCKET_EINPROGRESS && $error != SOCKET_EALREADY) {
              echo "Error Connecting Socket: ".socket_strerror($error) . "\n";
              socket_close($socket);
              return NULL;
        }
        usleep(1000);
  }

  if (!$connected) {
        echo "Error Connecting Socket: Connect Timed Out After " . $timeout/1000 . " seconds. ".socket_strerror(socket_last_error()) . "\n";
        socket_close($socket);
        return NULL;
  }

?>
于 2012-03-18T19:47:22.767 に答える
3

以前の解決策はうまくいかなかったので、socket_select を使用して解決策を見つけました。

<?php
$service_port = 80;
$address = '127.0.0.1';
$timeout = 3;

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_nonblock($socket);
$error = NULL;
$attempts = 0;
$timeout *= 1000;  // adjust because we sleeping in 1 millisecond increments
$connected = FALSE;
$connected = @socket_connect($socket, $address, $service_port);
if (!$connected)
{
    $error = socket_last_error();
    if ($error != 10035 && $error != SOCKET_EINPROGRESS && $error != SOCKET_EALREADY) {
        echo "Error Connecting Socket: ".socket_strerror($error) . "\n";
        socket_close($socket);
        exit();
    }
}
$writables = array();
$writables[] = $socket;
$readable = array();
$e = array();
$result = socket_select($readable, $writables, $e, $timeout);
if (!$result)
    die("Unable to connect to socket: Timeout");
/* blablah send lots of things */
socket_close($socket);

Windows上のXAMPPと私のLinuxサーバーの両方で動作しています。

于 2014-03-31T09:58:35.610 に答える