1 00 行のコードで (単純に) 何が楽しいことを達成できるでしょうか?この記事では、100 行の PHP コードで Socks5 プロキシ サーバー モジュールを簡単に実装する方法の例を示します。これが皆さんの役に立つことを願っています。
もちろん、PHP (swoole 拡張機能は除く) 自体はネットワークサーバープログラミングが得意ではないため、このプロキシは単なるおもちゃであり、日常使用からは少し離れています。
書いている途中で、PHPのマルチスレッドはまだ難しいことが分かりました。たとえば、接続ごとに新しいスレッドを作成することを考え始めました。ただし、このスレッドは $clients 配列に保存する必要があります (たとえば、配列に保存する)。それ以外の場合は、(curl -L 301 を必要とするアドレス) してみると、何が起こるかわかります。
次に、以下はスレッド プールを使用して実装されたプロキシです。論理的に言えば、終了時にプールを shut down() する必要があり、リッスンしているソケットもシャットダウンする必要があります。ただし、コードは数百行あります。強制する必要はありません。 ctrl + c を使用して、オペレーティング システムにリソースを再利用させます。
なぜPHPはネットワークプログラミングが苦手なのでしょうか?まず、stream_socket_XXX 関連の関数を使用しました。ソケット拡張を使用してみてはいかがでしょうか。ソケットの拡張に問題があるためです。ただし、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('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)); }
関連する推奨事項:
phpはswooleを使用してクライアントデータをリアルタイムで更新します
Windowsにswooleをインストールする手順は何ですか?
以上がPHP は単に Socks5 プロキシ サーバーを実装するだけですの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。