양말5 프록시 server_php 팁을 구현하는 100줄의 PHP 코드-PHP 튜토리얼-php.cn

양말5 프록시 server_php 팁을 구현하는 100줄의 PHP 코드

WBOY

풀어 주다： 2016-05-16 19:53:26

원래의

1233명이 탐색했습니다.

이틀 전 B사이트에서 매끄러운 그래픽으로 LOL을 플레이할 수 있는 컴퓨터 조립 비용으로 100위안을 요구하는 남자를 보았는데 문득 코드 100줄이면 (단순히) 뭔가 재미있는 일을 이룰 수 있다는 생각이 들었습니다. 저는 주로 PHP 개발을 하고 있어서 이런 글을 보게 되었습니다.

물론 PHP(Swoole Extension은 포함하지 않음) 자체는 네트워크 서버 프로그래밍에 능숙하지 않기 때문에 이 에이전트는 단지 장난감에 불과하며 일상적인 사용과는 조금 거리가 있습니다. 안정적이고 신뢰할 수 있는 암호화된(인터넷 서핑 방법을 배울 수 있도록) 프록시를 사용하려면 다음을 사용할 수 있습니다: https://github.com/momaer/asocks-go또한 100이 걸립니다. go를 사용하여 구현할 코드 라인.

집필 과정에서 PHP 멀티스레딩이 여전히 어렵다는 것을 알게 되었습니다. 예를 들어, 각 연결마다 새 스레드를 만들고 싶었습니다. 하지만 이 스레드는 공식 예의 다음과 같이 저장되어야 합니다(예: 배열에 저장). https://github.com/krakjoe/pthreads/blob/master/examples/SocketServer.php $clients 배열에 배치해야 합니다. 그렇지 않으면 시도(curl -L 301이 필요한 주소)하면 무슨 일이 일어나는지 알 수 있습니다.

이 예는 실제 세계에서 실행되지 않는 클라이언트가 삭제되도록 여기에서 작업을 수행한다고 설명하지만 더 이상 실행되지 않는 연결을 삭제하는 방법에 대해서는 설명하지 않습니다. 친절. $clients를 클래스에 넣고 클래스를 스레드 클래스에 전달한 다음 스레드 클래스가 끝나려고 할 때 $clients에서 해당 연결을 설정 해제하려고 시도했지만 소용이 없었습니다.

그러면 다음은 스레드 풀을 사용하여 구현된 프록시입니다. 논리적으로 말하면 종료할 때 풀을 종료()해야 하고 모니터링 소켓도 종료해야 합니다. 하지만 수백 줄의 코드가 있습니다. 강제로 실행할 필요는 없습니다. Ctrl c를 사용하면 운영 체제에서 리소스를 회수할 수 있습니다.

PHP가 네트워크 프로그래밍을 잘 못하는 이유는 무엇인가요? 우선, stream_socket_XXX 관련 함수를 사용해봤습니다. 소켓 확장을 사용하면 어떨까요? 소켓 확장에 문제가 있으므로 다음을 참조하세요. https://github.com/krakjoe/pthreads/issues/581 stream_socket_recvfrom과 같은 고급 작업에서는 stream_set_timeout이 작동하지 않습니다. , 참조: http://php.net/manual/en/function.stream-set-timeout.php 프록시를 작성할 때 이러한 사항을 고려해야 합니다. 예를 들어, 원격 대상 서버에 연결할 때 시간 초과 제어가 없으며 스레드 풀이 쉽게 가득 찰 수 있습니다.

테스트에는 그냥 컬을 사용하세요. 그런데 현재는 원격 DNS 해상도만 지원됩니다. 이유는 무엇입니까? 이 장난감은 나중에 인터넷에 액세스하는 데 사용해야 하기 때문에: 컬 --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));
}

로그인 후 복사