php socket 发送HTTP请求 POST json

<?php
namespace et\http;
 
/**
 * Created by PhpStorm.
 * User: mingzhanghui
 * Date: 2018-09-18
 * Time: 16:19
 */
class HttpRequest {
    const BUFSIZE = 4096;
    const DEFAULT_OPTIONS = [
        'port' => 80,
        'timeout'=> 30
    ];
 
    const DEFAULT_HEADRES = [
        'Content-Type' => 'application/x-www-form-urlencoded'
    ];
 
    public static function mergeDefaultOptions(Array& $to, Array $default) {
        foreach ($default as $key => $value) {
            if (!array_key_exists($key, $to)) {
                $to[$key] = $value;
            }
        }
    }
 
    /**
     * @param $host string remote server '192.168.1.219:7102' without http://
     * @param $uri string remote uri '/service/pageinfo/'
     * @param $headers
     * @param string $body
     * @param array $options
     * @return string
     * @throws \Exception
     */
    public static function post($host, $uri, $headers = [], $body = "", $options = []) {
        self::mergeDefaultOptions($options, self::DEFAULT_OPTIONS);
 
        $socket = fsockopen($host, $options['port'], $errno, $errstr, $options['timeout']);
        if (!$socket) {
            throw new \Exception(sprintf("%s(%d)", $errstr, $errno));
        }
 
        fwrite($socket, sprintf("POST %s HTTP/1.0\r\n", $uri));
        fwrite($socket, "User-Agent: Socket_Backstage\r\n");
        fwrite($socket, sprintf("Content-length: %d\r\n", strlen($body)));
        fwrite($socket, "Accept: */*\r\n");
 
        self::mergeDefaultOptions($headers, self::DEFAULT_HEADRES);
        foreach ($headers as $name => $value) {
            fwrite($socket, $name.": ".$value."\r\n");
        }
        fwrite($socket, "\r\n");
 
        fwrite($socket, $body."\r\n");
        fwrite($socket, "\r\n");
 
        $header = "";
        while ($str = trim(fgets($socket, self::BUFSIZE))) {
            $header .= $str;
        }
        $resp = "";
        while (!feof($socket)) {
            $resp .= fgets($socket, self::BUFSIZE);
        }
        return $resp;
    }
 
    public static function get($host, $uri, $data, $port=80, $timeout = 30) {
        $socket = fsockopen($host, $port, $errno, $errstr, $timeout);
        if (!$socket) {
            throw new \Exception(sprintf("%s(%d)", $errstr, $errno));
        }
        $qs = http_build_query($data, '', '&');
 
        fwrite($socket, sprintf("GET %s?%s HTTP/1.0\r\n", $uri, $qs));
        fwrite($socket, "User-Agent: Socket_Backstage\r\n");
        fwrite($socket, "Content-type: application/x-www-form-urlencoded\r\n");
        fwrite($socket, sprintf("Content-length: %d\r\n", strlen($qs)));
        fwrite($socket, "Accept: */*\r\n");
        fwrite($socket, "\r\n");
        fwrite($socket, "\r\n");
 
        $header = "";
        while ($str = trim(fgets($socket, self::BUFSIZE))) {
            $header .= $str;
        }
        $resp = "";
        while (!feof($socket)) {
            $resp .= fgets($socket, self::BUFSIZE);
        }
        return $resp;
    }
 
    /**
     * $.post(url, data, function(data) { ... })
     * @param $url
     * @param $data
     * @return mixed
     * @throws \Exception
     */
    public static function post_url($url, Array $data) {
        $components = parse_url($url);
        if ($components === false) {
            throw new \Exception('url is not valid');
        }
        if ($components['scheme'] != 'http') {
            throw new \Exception('scheme is not http');
        }
        $host = $components['host'];
        $path = empty($components['path']) ? '/' : $components['path'];
 
        $headers = [
            'Content-Type' => 'application/x-www-form-urlencoded'
        ];
        $body = http_build_query($data, '', '&');
 
        return self::post($host, $path, $headers, $body, self::DEFAULT_OPTIONS);
    }
}

<?php
/**
 * Created by PhpStorm.
 * User: mingzhanghui
 * Date: 2018-09-18
 * Time: 10:46
 */
include 'HttpRequest.php';
 
// $response = \et\http\HttpRequest::get('www.baidu.com', '/', []);
// $body = http_build_query($data, '', '&');
 
$headers = ['Content-Type' => 'application/json'];
// $body = "{\"query\":{\"bool\":{\"must\":[{\"match_phrase_prefix\":{\"request\":\"/cgi-bin/service\"}},{\"range\":{\"@timestamp\":{\"gte\":\"2017-09-11 09:26:10\",\"lte\":\"2018-09-13 09:27:10\",\"format\":\"yyyy-MM-dd HH:mm:ss\"}}},{\"range\":{\"request_time\":{\"gte\":5}}}]}},\"sort\":[{\"request_time\":{\"order\":\"desc\"}}],\"size\":10}";
 
function buildQueryBodySlow($uri, $begin, $end, $requestTime = 5, $size = 10) {
    $o = new \stdClass();
    $o->query = new \stdClass();
    $o->query->bool = new \stdClass();
    $o->query->bool->must = [
        0 => ['match_phrase_prefix' => [
            'request' => $uri
        ]],
        1 => ['range' => [
            '@timestamp' => [
                "gte"=> $begin,
                "lte"=> $end,
                "format"=> "yyyy-MM-dd HH:mm:ss"
            ]
        ]],
        2 => ['range' => [
            'request_time' => ['gte' => $requestTime]
        ]]
    ];
    $o->sort = [
        0 => [
            'request_time'=> [
                'order'=>'desc'
            ]
        ]
    ];
    $o->size = $size;
 
    return json_encode($o);
}
 
$body = buildQueryBodySlow(
    '/cgi-bin/service',
    "2017-09-11 09:26:10",
    "2018-09-13 09:27:10",
    5,
    1
);
 
// post json
$response = et\http\HttpRequest::post(
    '172.16.0.245',
    '/filebeat-2018.09.12/_search?pretty',
    $headers,
    $body,
    ['port'=>9200]
);
 
echo '<pre>';
print_r($response);