From fdaaaded0a4d3b0d5ee108b4247f4220b295fccb Mon Sep 17 00:00:00 2001
From: zhangyanfei <zhangyanfei@sogou-inc.com>
Date: Mon, 15 Feb 2021 12:35:55 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B7=BB=E5=8A=A0=E7=99=BE=E4=B8=87?=
 =?UTF-8?q?=E8=BF=9E=E6=8E=A5=E8=BE=BE=E6=88=90=E7=9A=84=E5=8F=A6=E4=B8=80?=
 =?UTF-8?q?=E4=B8=AA=E5=AE=9E=E9=AA=8C=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tests/network/test02/client.php  | 64 ++++++++++++++++++++++++++++++++
 tests/network/test02/clientd.php | 28 ++++++++++++++
 tests/network/test02/ports.php   | 24 ++++++++++++
 tests/network/test02/server.php  | 55 +++++++++++++++++++++++++++
 tests/network/test02/serverd.php | 23 ++++++++++++
 5 files changed, 194 insertions(+)
 create mode 100755 tests/network/test02/client.php
 create mode 100755 tests/network/test02/clientd.php
 create mode 100644 tests/network/test02/ports.php
 create mode 100755 tests/network/test02/server.php
 create mode 100755 tests/network/test02/serverd.php

diff --git a/tests/network/test02/client.php b/tests/network/test02/client.php
new file mode 100755
index 0000000..a747b68
--- /dev/null
+++ b/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();
diff --git a/tests/network/test02/clientd.php b/tests/network/test02/clientd.php
new file mode 100755
index 0000000..067c144
--- /dev/null
+++ b/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);
+}
+
+
+
diff --git a/tests/network/test02/ports.php b/tests/network/test02/ports.php
new file mode 100644
index 0000000..e254cbc
--- /dev/null
+++ b/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,
+    );
diff --git a/tests/network/test02/server.php b/tests/network/test02/server.php
new file mode 100755
index 0000000..d4f8878
--- /dev/null
+++ b/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);
diff --git a/tests/network/test02/serverd.php b/tests/network/test02/serverd.php
new file mode 100755
index 0000000..3cd29df
--- /dev/null
+++ b/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);
+}
+