Heim  >  Artikel  >  Backend-Entwicklung  >  Detaillierte Erklärung, wie PHP Socket zum Senden von HTTP-Anfragen verwendet

Detaillierte Erklärung, wie PHP Socket zum Senden von HTTP-Anfragen verwendet

*文
*文Original
2018-01-05 10:10:142134Durchsuche

Als PHP-Programmierer werden Sie auf jeden Fall mit dem http-Protokoll vertraut sein. Nur wenn Sie ein tiefes Verständnis des http-Protokolls haben, können Sie Ihr Programmierniveau verbessern. Vor Kurzem habe ich etwas über die HTTP-Programmierung in PHP gelernt und mir wurden viele Dinge klar. Ich hoffe, es mit allen teilen zu können. Dieser Artikel muss von Entwicklern mit einer bestimmten HTTP-Grundlage gelesen werden. Ich hoffe, es hilft allen.

Heute zeige ich Ihnen, wie Sie Socket zum Senden von GET- und POST-Anfragen verwenden.

Ich glaube, dass viele Leute, wie ich, die meiste Zeit den Browser verwenden, um GET- und POST-Anfragen an den Server zu stellen. Kann ich also andere Methoden verwenden, um GET- und POST-Anfragen zu stellen? Die Antwort muss ja sein. Jeder, der das HTTP-Protokoll kennt, weiß, dass der Browser, der eine Anfrage sendet, im Wesentlichen darin besteht, eine Anfrageinformation an den Server zu senden. Diese Anfrageinformation besteht aus einer Anfragezeile, einem Anfrageheader und einem Anfragetext (optional). Der Server gibt Antwortinformationen basierend auf den Anforderungsinformationen zurück. Die Verbindung geht verloren.

Das Format der HTTP-Anfrage ist wie folgt:

<request-line>
<headers>
<blank line>
[<request-body>]

Das Format der HTTP-Antwort ist dem Format der Anfrage sehr ähnlich:

<status-line>
<headers>
<blank line>
[<response-body>]

Wir können HTTP zum Senden von Anfragen verwenden. Prinzipiell können Sie die Verwendung von Sockets zum Senden von HTTP-Anfragen noch einmal überdenken.

Die ursprüngliche englische Bedeutung von Socket ist „Loch“ oder „Buchse“. Es wird auch allgemein als „Socket“ bezeichnet und wird zur Beschreibung einer IP-Adresse und eines Ports verwendet. Es ist ein Handle für eine Kommunikationskette und kann zur Implementierung der Kommunikation zwischen verschiedenen virtuellen Maschinen oder verschiedenen Computern verwendet werden. Hosts im Internet führen im Allgemeinen mehrere Dienstsoftware aus und stellen mehrere Dienste gleichzeitig bereit. Jeder Dienst öffnet einen Socket und ist an einen Port gebunden. Verschiedene Ports entsprechen unterschiedlichen Diensten. Unter diesem Gesichtspunkt ist es tatsächlich genauso einfach, Sockets zum Betreiben von Remote-Dateien zu verwenden wie zum Lesen und Schreiben lokaler Dateien. Stellen Sie sich lokale Dateien vor, die über Hardware übertragen werden, und Remote-Dateien, solange sie über Netzwerkkabel übertragen werden.

Daher kann das Senden einer Anfrage als Herstellen einer Verbindung betrachtet werden –>Socket-Schnittstelle öffnen (fsockopen()) –>Anfrage schreiben (fwrite()) –>Antwort lesen (fread()-) > ;Schließen Sie die Datei (fclose()). Gehen wir ohne weiteres direkt zum Code:

<?php 
interface Proto {
  // 连接url
  function conn($url);
  //发送get查询
  function get();
  // 发送post查询
  function post();
  // 关闭连接
  function close();
}
class Http implements Proto {
  const CRLF = "\r\n";
  protected $errno = -1;
  protected $errstr = &#39;&#39;;
  protected $response = &#39;&#39;;
  protected $url = null;
  protected $version = &#39;HTTP/1.1&#39;;
  protected $fh = null;
  protected $line = array();
  protected $header = array();
  protected $body = array();
  public function __construct($url) {
    $this->conn($url);
    $this->setHeader(&#39;Host: &#39; . $this->url[&#39;host&#39;]);
  }
  // 此方法负责写请求行
  protected function setLine($method) {
    $this->line[0] = $method . &#39; &#39; . $this->url[&#39;path&#39;] . &#39;?&#39; .$this->url[&#39;query&#39;] . &#39; &#39;. $this->version;
  }
  // 此方法负责写头信息
  public function setHeader($headerline) {
    $this->header[] = $headerline; 
  }
  // 此方法负责写主体信息
  protected function setBody($body) {
     $this->body[] = http_build_query($body);
  }
  // 连接url
  public function conn($url) {
    $this->url = parse_url($url);
    // 判断端口
    if(!isset($this->url[&#39;port&#39;])) {
      $this->url[&#39;port&#39;] = 80;
    }
    // 判断query
    if(!isset($this->url[&#39;query&#39;])) {
      $this->url[&#39;query&#39;] = &#39;&#39;;
    }
    $this->fh = fsockopen($this->url[&#39;host&#39;],$this->url[&#39;port&#39;],$this->errno,$this->errstr,3);
  }
  //构造get请求的数据
  public function get() {
    $this->setLine(&#39;GET&#39;);
    $this->request();
    return $this->response;
  }
  // 构造post查询的数据
  public function post($body = array()) {   
    $this->setLine(&#39;POST&#39;);
    // 设计content-type
    $this->setHeader(&#39;Content-type: application/x-www-form-urlencoded&#39;);
    // 设计主体信息,比GET不一样的地方
    $this->setBody($body);
    // 计算content-length
    $this->setHeader(&#39;Content-length: &#39; . strlen($this->body[0]));
    $this->request();
    return $this->response;
  }
  // 真正请求
  public function request() {
    // 把请求行,头信息,实体信息 放在一个数组里,便于拼接
    $req = array_merge($this->line,$this->header,array(&#39;&#39;),$this->body,array(&#39;&#39;));
    //print_r($req);
    $req = implode(self::CRLF,$req); 
    //echo $req; exit;
    fwrite($this->fh,$req);
    while(!feof($this->fh)) {
      $this->response .= fread($this->fh,1024);
    }
    $this->close(); // 关闭连接
  }
  // 关闭连接
  public function close() {
    fclose($this->fh);
  }
}

Verwenden Sie diese Klasse, um eine einfache GET-Anfrage zu senden:

<?php
//记得引用Http类
$url="http://home.***.net/u/DeanChopper/";
$http=new Http($url);
$response=$http->get();
print_r($response);

Der Rückgabewert ist Information. Sie können die Antwortinformationen weiterverarbeiten, um den gewünschten Inhalt zu erhalten.

Sehen wir uns das nächste spezifische Beispiel an

<?php
/**
 * 使用PHP Socket 编程模拟Http post和get请求
 * @author koma
 */
class Http{
  private $sp = "\r\n"; //这里必须要写成双引号
  private $protocol = &#39;HTTP/1.1&#39;;
  private $requestLine = "";
  private $requestHeader = "";
  private $requestBody = "";
  private $requestInfo = "";
  private $fp = null;
  private $urlinfo = null;
  private $header = array();
  private $body = "";
  private $responseInfo = "";
  private static $http = null; //Http对象单例
   
  private function __construct() {}
   
  public static function create() {
    if ( self::$http === null ) { 
      self::$http = new Http();
    }
    return self::$http;
  }
   
  public function init($url) {
    $this->parseurl($url);
    $this->header[&#39;Host&#39;] = $this->urlinfo[&#39;host&#39;];
    return $this;
  }
   
  public function get($header = array()) {
    $this->header = array_merge($this->header, $header);
    return $this->request(&#39;GET&#39;);
  }
   
  public function post($header = array(), $body = array()) {
    $this->header = array_merge($this->header, $header);
    if ( !empty($body) ) {
      $this->body = http_build_query($body);
      $this->header[&#39;Content-Type&#39;] = &#39;application/x-www-form-urlencoded&#39;;
      $this->header[&#39;Content-Length&#39;] = strlen($this->body);
    }
    return $this->request(&#39;POST&#39;);
  }
   
  private function request($method) {
    $header = "";
    $this->requestLine = $method.&#39; &#39;.$this->urlinfo[&#39;path&#39;].&#39;?&#39;.$this->urlinfo[&#39;query&#39;].&#39; &#39;.$this->protocol;
    foreach ( $this->header as $key => $value ) {
      $header .= $header == "" ? $key.&#39;:&#39;.$value : $this->sp.$key.&#39;:&#39;.$value;
    }
    $this->requestHeader = $header.$this->sp.$this->sp;
    $this->requestInfo = $this->requestLine.$this->sp.$this->requestHeader;
    if ( $this->body != "" ) {
      $this->requestInfo .= $this->body;
    }
    /*
     * 注意:这里的fsockopen中的url参数形式为"www.xxx.com"
     * 不能够带"http://"这种
     */
    $port = isset($this->urlinfo[&#39;port&#39;]) ? isset($this->urlinfo[&#39;port&#39;]) : &#39;80&#39;;
    $this->fp = fsockopen($this->urlinfo[&#39;host&#39;], $port, $errno, $errstr);
    if ( !$this->fp ) {
      echo $errstr.&#39;(&#39;.$errno.&#39;)&#39;;
      return false;
    }
    if ( fwrite($this->fp, $this->requestInfo) ) {
      $str = "";
      while ( !feof($this->fp) ) {
        $str .= fread($this->fp, 1024);
      }
      $this->responseInfo = $str;
    }
    fclose($this->fp);
    return $this->responseInfo;
  }
   
  private function parseurl($url) {
    $this->urlinfo = parse_url($url);
  }
}
// $url = "http://news.***.com/14/1102/01/AA0PFA7Q00014AED.html";
$url = "http://localhost/httppro/post.php";
$http = Http::create()->init($url);
/* 发送get请求 
echo $http->get(array(
  &#39;User-Agent&#39; => &#39;Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/35.0.1916.153 Safari/537.36&#39;,
));
*/
 
/* 发送post请求 */
echo $http->post(array(
    &#39;User-Agent&#39; => &#39;Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/35.0.1916.153 Safari/537.36&#39;,
), array(&#39;username&#39;=>&#39;发一个中文&#39;, &#39;age&#39;=>22));

Verwandte Empfehlungen :

Detaillierte Erklärung der Dateiberechtigungsänderungsfunktion chmod von PHP

Detaillierte Erklärung, wie PHP das implementiert Hook-Mechanismus

Detaillierte Erläuterung der Verwendung von PHP zum Finden des längsten gemeinsamen Teilstrings zweier Strings

Das obige ist der detaillierte Inhalt vonDetaillierte Erklärung, wie PHP Socket zum Senden von HTTP-Anfragen verwendet. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn