PHP簡單實作socks5代理伺服器-php教程-PHP中文網

PHP簡單實作socks5代理伺服器

*文

發布： 2023-03-18 19:32:01

原創

16066 人瀏覽過

100行程式碼能（簡單）實作個啥好玩的？本文以實例展示了100行PHP程式碼簡單實作socks5代理伺服器模組，希望對大家有幫助。

當然，由於php（不算swoole擴充功能）本身不擅長做網路服務端編程，所以這個代理，只是個玩具，離日常使用有點距離。

寫的過程中發現php多執行緒還是難的。例如我開始想每個連線新建一個執行緒。但這個線程得保存起來（例如保存到數組）要放到$clients這個數組裡，不然，你試試(curl -L一個要301的地址)就知道出現什麼情況了。

那，以下就是使用執行緒池來實現的代理，照道理講，退出時池要shutdown()，監聽socket也要shutdown的，但百行程式碼，就不勉強了，隨著ctrl + c，就讓作業系統來回收資源吧。

php不擅長網路程式設計體現在哪裡呢？首先我用的是stream_socket_XXX相關的函數，為啥不用socket擴充呢？因為socket擴充有問題。而stream_set_timeout對stream_socket_recvfrom這些進階操作，不起作用。而這些，在寫代理商時都需要考慮的。例如連接遠端目標伺服器時，沒有超時控制，很容易就線程池跑滿了。

測試的話，使用curl即可，對了，目前只支援遠端dns解析，為啥呢？因為這個玩具後期可是要實現禾鬥學上網的喲： curl --socks5-hostname 127.0.0.1:1080 http://ip.cn

Class Pipe extends Threaded
{
  private $client;
  private $remote;
  public function __construct($client, $remote) 
  {
    $this->client = $client;
    $this->remote = $remote; 
  }
  public function run()
  {
    for ( ; ; ) {
        $data = stream_socket_recvfrom($this->client, 4096);
        if ($data === false || strlen($data) === 0) {
          break;
        } 
        $sendBytes = stream_socket_sendto($this->remote, $data);
        if ($sendBytes <= 0) {
          break;
        }
    }
    stream_socket_shutdown($this->client, STREAM_SHUT_RD);
    stream_socket_shutdown($this->remote, STREAM_SHUT_WR);
  }
}

Class Client extends Threaded
{
  public $fd;
  public function __construct($fd)
  {
    $this->fd = $fd; 
  }

  public function run()
  {
    $data = stream_socket_recvfrom($this->fd, 2);
    $data = unpack(&#39;c*&#39;, $data);
    if ($data[1] !== 0x05) {
      stream_socket_shutdown($this->fd, STREAM_SHUT_RDWR);
      echo &#39;协议不正确.&#39;, PHP_EOL;
      return;
    }
    $nmethods = $data[2];
    $data = stream_socket_recvfrom($this->fd, $nmethods);
    stream_socket_sendto($this->fd, "\x05\x00");
    $data = stream_socket_recvfrom($this->fd, 4);
    $data = unpack(&#39;c*&#39;, $data);
    $addressType = $data[4];
    if ($addressType === 0x03) { // domain
      $domainLength = unpack(&#39;c&#39;, stream_socket_recvfrom($this->fd, 1))[1];
      $data = stream_socket_recvfrom($this->fd, $domainLength + 2);
      $domain = substr($data, 0, $domainLength);
      $port = unpack("n", substr($data, -2))[1];
    } else {
      stream_socket_shutdown($this->fd, STREAM_SHUT_RDWR);
      echo &#39;请使用远程dns解析.&#39;, PHP_EOL;
    }

    stream_socket_sendto($this->fd, "\x05\x00\x00\x01\x00\x00\x00\x00\x00\x00");
    echo "{$domain}:{$port}", PHP_EOL;
    $remote = stream_socket_client("tcp://{$domain}:{$port}");
    if ($remote === false) {
      stream_socket_shutdown($this->fd, STREAM_SHUT_RDWR);
      return;
    }

    $pool = $this->worker->pipePool;

    $pipe1 = new Pipe($remote, $this->fd);
    $pipe2 = new Pipe($this->fd, $remote);

    $pool->submit($pipe1);
    $pool->submit($pipe2);
  }
}

class ProxyWorker extends Worker
{
  public $pipePool;
  public function __construct($pipePool)
  {
    $this->pipePool = $pipePool;
  }
}

$server = stream_socket_server(&#39;tcp://0.0.0.0:1080&#39;, $errno, $errstr);
if ($server === false)
  exit($errstr);

$pipePool = new Pool(200, Worker::class);
$pool = new Pool(50, &#39;ProxyWorker&#39;, [$pipePool]);

for( ; ; ) {
  $fd = @stream_socket_accept($server, 60);
  if ($fd === false)
    continue;
  $pool->submit(new Client($fd));
}

登入後複製