Socks5 プロキシ サーバーを実装するための 100 行の PHP コード

2 日前、ステーション B で、滑らかなグラフィックで LOL をプレイするために 100 元でコンピュータを組み立てようとしている人を見かけました。100 行のコードで (単純に) 何か楽しいことが実現できるのではないかと突然思いました。私は主にPHP開発を行っているので、この記事を書いています。

もちろん、PHP (swoole 拡張機能は除く) 自体はネットワーク サーバー プログラミングが得意ではないため、このプロキシは単なるおもちゃであり、日常的な使用からは少し離れています。安定した信頼性の高い暗号化 (インターネットサーフィンを学習できるように) プロキシを使用したい場合は、これを使用できます: https://github.com/momaer/asocks-go これも 100 行のコードで、go を使用して実装されています。 。

書いている途中で、PHPのマルチスレッドはまだ難しいことが分かりました。たとえば、接続ごとに新しいスレッドを作成することを考え始めました。ただし、このスレッドは保存する必要があります (たとえば、配列に保存する)。たとえば、公式の例では次のようになります: https://github.com/krakjoe/pthreads/blob/master/examples/SocketServer.phpそれ以外の場合は、 (curl -L 301 を必要とするアドレス) してみると、何が起こるかわかります。

この例は、現実の世界では、実行されていないクライアントが確実に破棄されるように何かを行うことを示していますが、実行されなくなった接続を破棄する方法については説明しません。親切。 $clients をクラスに入れ、そのクラスをスレッド クラスに渡し、スレッド クラスが終了しようとしたときに $clients 内の対応する接続​​の設定を解除しようとしましたが、無駄でした。

次に、スレッド プールを使用して実装されたプロキシを示します。論理的に言えば、終了時にプールを shutdown() する必要があり、監視ソケットもシャットダウンする必要があります。しかし、数百行のコードでは、その必要はありません。 Ctrl + C を押すと、オペレーティング システムにリソースを再利用させます。

なぜPHPはネットワークプログラミングが苦手なのでしょうか？まず、stream_socket_XXX 関連の関数を使用しました。ソケット拡張を使用してみてはいかがでしょうか。ソケット拡張機能に問題があるため、https://github.com/krakjoe/pthreads/issues/581 を参照してください。 また、stream_set_timeout は、stream_socket_recvfrom などの高度な操作では機能しません。http://php.net を参照してください。 /manual/ja /function.stream-set-timeout.phpそして、プロキシを作成するときはこれらを考慮する必要があります。たとえば、リモートのターゲット サーバーに接続する場合、タイムアウト制御がないため、スレッド プールが簡単にいっぱいになる可能性があります。

テストするには、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('c*', $data);
    if ($data[1] !== 0x05) {
      stream_socket_shutdown($this->fd, STREAM_SHUT_RDWR);
      echo '协议不正确.', 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('c*', $data);
    $addressType = $data[4];
    if ($addressType === 0x03) { // domain
      $domainLength = unpack('c', 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 '请使用远程dns解析.', 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('tcp://0.0.0.0:1080', $errno, $errstr);
if ($server === false)
  exit($errstr);

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

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

上記では、socks5 プロキシ サーバーを実装するための 100 行の PHP コードをすべての側面を含めて紹介しています。PHP チュートリアルに興味のある友人にとって役立つことを願っています。