feat: 添加百万连接达成的另一个实验代码

tests/network/test02/client.php

@@ -0,0 +1,64 @@
+<?php
+
+/**
+ * Socket客户端
+ */
+
+if(!isset($argv[1]) || !isset($argv[2])){
+    echo "usage: php client.php {serverIp} {serverPort}  \n";
+    exit;
+}
+$serverIp       = $argv[1];
+$serverPort     = $argv[2];
+
+$sockets = array();
+
+function buildConnect($sIp,$sPort,$num){
+    global $sockets;
+
+    for($i=0;$i<$num;$i++){
+        if(0==$i%1000){
+            echo $i."\n";
+            sleep(1); 
+        }
+        
+        $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
+        if($socket == false) {
+            echo "$sPort socket_create() 失败,".socket_strerror(socket_last_error($socket))."\n";
+            sleep(5);
+            continue;
+        }
+
+        if(false == socket_connect($socket, $sIp, $sPort)){
+            echo "$sPort socket_connect() 失败的原因是:".socket_strerror(socket_last_error($socket))."\n";
+            sleep(5);
+            continue;
+        }
+
+        //将 socket 保存起来，避免连接被内核释放
+        $sockets[] = $socket;
+        
+        //$wmsg = "I am client!";
+        //socket_write($socket, $wmsg, strlen($wmsg));
+
+        //$rmsg = socket_read($socket, 1024);
+        //echo "接收到的数据长度:".strlen($rmsg)."\n";
+
+    }
+}
+
+
+function closeAll(){
+    global $sockets;
+    foreach($sockets as $socket){
+        socket_close($socket);
+    }
+}
+
+echo "\nconnect start:";
+buildConnect($serverIp, $serverPort, 50000);
+
+sleep(600);
+
+echo "\nclose all sockets now";
+closeAll();

tests/network/test02/clientd.php

@@ -0,0 +1,28 @@
+<?php
+
+/**
+ * Socket客户端
+ */
+
+require("ports.php");
+
+//这里填写你的服务器ip
+$serverIp = "";
+
+$cmd = "ps -ef | grep client.php | awk '{print $2}' | xargs kill -9";
+shell_exec($cmd);
+shell_exec("echo '' > clientd.log");
+
+if(isset($argv[1]) && "stop"==$argv[1]){
+    exit;
+}
+
+foreach($ports as $port){
+    $tCommand = "php client.php $serverIp $port >> clientd.log &";
+    echo $tCommand."\n";
+    shell_exec($tCommand);  
+    sleep(1);
+}
+
+
+

tests/network/test02/ports.php

@@ -0,0 +1,24 @@
+<?php
+
+$ports = array(
+        8100,
+        8101,
+        8102,
+        8103,
+        8104,
+        8105,
+        8106,
+        8107,
+        8108,
+        8109,
+        8110,
+        8111,
+        8112,
+        8113,
+        8114,
+        8115,
+        8116,
+        8117,
+        8118,
+        8119,
+    );

tests/network/test02/server.php

@@ -0,0 +1,55 @@
+<?php
+
+/**
+ * Socket服务端
+ */
+
+set_time_limit(0);
+
+if(!isset($argv[1]) || !isset($argv[2])){
+    echo "usage: php server.php {ip} {port}\n";
+    exit;
+}
+$ip = $argv[1];
+$port = $argv[2];
+
+if(($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) < 0) {
+    echo "socket_create() 失败，" . socket_strerror($sock) . "\n";
+    exit();
+}
+
+if(($ret = socket_bind($sock, $ip, $port)) < 0) {
+    echo "socket_bind() 失败，" . socket_strerror($ret) . "\n";
+    exit();
+}
+
+if(($ret = socket_listen($sock,1024)) < 0) {
+    echo "socket_listen() 失败，" . socket_strerror($ret) . "\n";
+    exit();
+}
+echo "$ip $port listen ok!\n";
+
+$sockets = array();
+$count = 0;
+do{
+    //接收一个Socket连接
+    $con = socket_accept($sock);
+    if (false == $con) {
+        echo "$ip $port socket_accept() failed: reason:".socket_strerror(socket_last_error($socket))."\n";
+        continue;
+    } else {
+        $count++;
+        if(0 == $count%1000){
+            echo "$ip $port accept success: ".$count."\n";
+        }
+
+        //发送数据
+        //$wmsg = "I am server\n";
+        //socket_write($con, $wmsg, strlen($wmsg));
+
+        //接收数据
+        //$rmsg = socket_read($msgsock[$count], 2048);
+        //echo = "收到的信息:".$rmsg."\n";
+    }
+    $sockets[$count] = $con;
+}while(true);

tests/network/test02/serverd.php

@@ -0,0 +1,23 @@
+<?php
+
+/**
+ * Socket服务端
+ */
+
+require("ports.php");
+
+$cmd = "ps -ef | grep server.php | awk '{print $2}' | xargs kill -9";
+shell_exec($cmd);
+shell_exec("echo '' > serverd.log");
+
+if(isset($argv[1]) && "stop"==$argv[1]){
+    exit;
+}
+
+foreach($ports as $port){
+    $tCommand = "php server.php 0.0.0.0 $port >> serverd.log &";
+    echo $tCommand."\n";
+    shell_exec($tCommand);
+    sleep(1);
+}
+