-2

NodeJS を使用して PHP と通信するための「最適な」ソリューションをテストしようとしていますが、ループに何か問題があるため、テストを実行できません。

ここに私のNodeJSコードがあります:

var ENCODING = 'utf8';

// SOCKETS
var net = require('net'); // Load the TCP Library

// HTTP REQUEST
var http = require('http'); // Load the HTTP Library | WEBSOCKETS NEED THIS!!
var querystring = require('querystring'); // Load Query Library


// SOCKET SERVER
net.createServer(function (socket) {

  socket.setEncoding(ENCODING);

  socket.on('data', function (data) {
      socket.end('TEXT FROM SOCKET', ENCODING);    
  });

  socket.on('close', function () {

  });

}).listen(5000);


// HTTP SERVER
http.createServer(function (req, res) {
  res.writeHead(200, {'Content-Type': 'text/plain'});
  res.end("TEXT FROM HTTP");
}).listen(2525);

そしてここで私のPHPテスト：

set_time_limit(0);
$address = '127.0.0.1';

$response = null;

// METHOD: HTTP (2525)
$start = microtime();
for ($x=0; $x<1000; $x++) {
    $response = getHttp($address);
}
echo "<br>METHOD 1: " . (microtime() - $start);


// METHOD: Open + Loop Send + Close (5000)
$start = microtime();
$sc = SockOpen($address);
for ($x=0; $x<1000; $x++) {
    $response = SockWrite($sc, $address);
}
SockClose($sc);
echo "<br>METHOD 2: " . (microtime() - $start);


// MMETHOD:  Loop (Open + Send + Close)  (5000)
$start = microtime();
for ($x=0; $x<1000; $x++) {
    $sc = SockOpen($address);
    $response = SockWrite($sc, $address);
    SockClose($sc);
}
echo "<br>METHOD 3: " . (microtime() - $start);


function SockOpen($address) {

    ob_implicit_flush();

    $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
    if ($socket === false) {
        echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
        return false;
    }

    $result = socket_connect($socket, $address, 5000);
    if ($result === false) {
        echo "socket_connect() failed.\nReason: ($result) " . socket_strerror(socket_last_error($socket)) . "\n";
        return false;
    }   

    return $socket;

}

function SockWrite($socket, $address) {

    $in = "HEAD / HTTP/1.1\r\n";
    $in .= "Host: ".$address."\r\n";
    $in .= "Connection: Close\r\n\r\n";
    //$in = "key1:value1\n";

    socket_write($socket, $in, strlen($in));

    $buffer=null;
    while ($out = socket_read($socket, 2048)) {
        $buffer .= $buffer;
    }

    return $buffer;

}

function SockClose($socket) {
    socket_close($socket); die();
}

function getHttp($address) {

    $url = 'http://'.$address.':2525/';
    $data = array('key1' => 'value1');

    // use key 'http' even if you send the request to https://...
    $options = array(
        'http' => array(
            'header'  => "Content-type: text/plain\r\n",
            'method'  => 'POST',
            'content' => http_build_query($data),
        ),
    );

    $context  = stream_context_create($options);
    $result = file_get_contents($url, false, $context);

    return $result;
}

1 つの単純な接続は正常に機能しますが、ループを作成すると、ソケットが接続を「切断」し、ループが失敗します。HTTP および Socket メソッドで失敗が発生します。

これを解決する方法はありますか？

ありがとう

4

1 に答える 1

0

エラーを検索してコードを更新しました。サーバーとクライアントのコードに問題が見つかりました。更新内容は次のとおりです。

クライアント：

set_time_limit(0);
$address = '127.0.0.1';

$response = null;

// METHOD: HTTP (2525)
$start = microtime();
$fails = 0;
for ($x=0; $x<1000; $x++) {
    $response = getHttp($address);
    if (empty($response)) {
        $fails++;
    }
}
echo "<br>METHOD 1: " . (microtime() - $start) . " errors: " . $fails;


// METHOD: Open + Loop Send + Close (5000)
$start = microtime();
$fails = 0;
$sc = SockOpen($address);
for ($x=0; $x<1000; $x++) {
    $response = SockWrite($sc, $address);
    if (empty($response)) {
        $fails++;
    }
}
SockClose($sc);
echo "<br>METHOD 2: " . (microtime() - $start) . " errors: " . $fails;


// MMETHOD:  Loop (Open + Send + Close)  (5000)
$start = microtime();
$fails = 0;
for ($x=0; $x<1000; $x++) {
    $sc = SockOpen($address);
    $response = SockWrite($sc, $address);
    if (empty($response)) {
        $fails++;
    }
    SockClose($sc);
}
echo "<br>METHOD 3: " . (microtime() - $start) . " errors: " . $fails;



function SockOpen($address) {

    //ob_implicit_flush();

    $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
    if ($socket === false) {
        echo "socket_create() failed: reason: " . socket_strerror(socket_last_error()) . "\n";
        return false;
    }

    $result = socket_connect($socket, $address, 5000);
    if ($result === false) {
        echo "socket_connect() failed.\nReason: ($result) " . socket_strerror(socket_last_error($socket)) . "\n";
        return false;
    }

    return $socket;

}

function SockWrite($socket, $address) {

    //$in = "HEAD / HTTP/1.1\r\n";
    //$in .= "Host: ".$address."\r\n";
    //$in .= "Connection: Close\r\n\r\n";
    $in = "key1:value1";

    socket_write($socket, $in, strlen($in));

    $buffer=null;
    //while ($out = socket_read($socket, 1024, MSG_WAITALL)) {
    while (socket_recv($socket, $buffer, 2048, MSG_WAITALL) === true) {
        $buffer .= $buffer;
    }

    return $buffer;

}

function SockClose($socket) {
    socket_shutdown($socket);
    socket_close($socket);
}

function getHttp($address) {

    $url = 'http://'.$address.':2525/';
    $data = array('key1' => 'value1');

    // use key 'http' even if you send the request to https://...
    $options = array(
        'http' => array(
            'header'  => "Content-type: text/plain\r\n",
            'method'  => 'POST',
            'content' => http_build_query($data),
        ),
    );

    $context  = stream_context_create($options);
    try {
        $result = @file_get_contents($url, false, $context);
    } catch (Exception $e) {
        return false;
    }

    return $result;
}

サーバ：

var ENCODING = 'utf8';

// SOCKETS
var net = require('net'); // Load the TCP Library

// HTTP REQUEST
var http = require('http'); // Load the HTTP Library | WEBSOCKETS NEED THIS!!
var querystring = require('querystring'); // Load Query Library


// SOCKET SERVER
net.createServer(function (socket) {

  socket.setEncoding(ENCODING);

  //socket.write("TEXT FROM SOCKET", ENCODING);

  socket.on('data', function (data) {
    socket.write("TEXT FROM SOCKET\n", ENCODING);
    //socket.end();
  });

  socket.on('close', function () {

  });

}).listen(5000);


    // HTTP SERVER
    http.createServer(function (req, response) {

      var body = 'TEXT FROM HTTP';
      response.writeHead(200, {
      'Content-Length': body.length,
      'Content-Type': 'text/plain' });

      response.write(body);
      response.end();

    }).listen(2525);

そして結果：

方法 1: 0.385564 エラー: 26 方法 2: 0.062286 エラー: 0 方法 3: 0.255954 エラー: 0

HTTP メソッドのエラーは、同じクライアント (PHP) による同時接続によるものだと思います。予想通り、高速はオープン + ループ + クローズで、最も遅いのは HTTP です。

PD: ネガ..?

于 2013-10-29T14:22:19.930 に答える