kiri-client/src/AsyncClient.php

<?php
/**
 * Created by PhpStorm.
 * User: whwyy
 * Date: 2018/5/24 0024
 * Time: 11:34
 */
declare(strict_types=1);

namespace Http\Client;

use Exception;
use Http\Message\Stream;
use JetBrains\PhpStorm\Pure;
use Kiri\Abstracts\Logger;
use Kiri\Kiri;
use Swoole\Client as SwowClient;

/**
 * Class Client
 * @package Kiri\Kiri\Http
 */
class AsyncClient extends ClientAbstracts
{

    /**
     * @param string $method
     * @param $path
     * @param array $params
     * @return void
     * @throws Exception
     */
    public function request(string $method, $path, array $params = []): void
    {
        $this->withMethod($method)
            ->coroutine(
                $this->matchHost($path),
                $this->paramEncode($params)
            );
    }


    /**
     * @param $path
     * @return $this
     */
    public function withCAInfo($path): static
    {
        return $this;
    }

    /**
     * @param $url
     * @param array|string $data
     * @throws Exception 使用swoole协程方式请求
     */
    private function coroutine($url, array|string $data = []): void
    {
        try {
            $this->generate_client($data, ...$url);
        } catch (\Throwable $exception) {
            Kiri::getDi()->get(Logger::class)->error('rpc', [$exception]);
            $this->setStatusCode(-1);
            $this->setBody(jTraceEx($exception));
        }
    }


    /**
     * @param $data
     * @param $host
     * @param $isHttps
     * @param $path
     * @throws Exception
     */
    private function generate_client($data, $host, $isHttps, $path): void
    {
        $this->client = new SwowClient(SWOOLE_TCP, FALSE);
        if (!$this->client->connect($host, $this->getPort())) {
            throw new Exception('链接失败');
        }
        if ($isHttps || $this->isSSL()) {
            $this->client->enableSSL();
        }
        $this->client->set($this->settings());
        if (!empty($this->getAgent())) {
            $this->withAddedHeader('User-Agent', $this->getAgent());
        } else {
            $this->withAddedHeader('User-Agent', ' Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/96.0.4664.93 Safari/537.36');
        }

        $path = $this->setParams($path, $data);

        $content = $this->getData()->getContents();

        $this->withAddedHeader('Accept', ' text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9');
        $this->withAddedHeader('Accept-Encoding', 'gzip, deflate');
        $this->withAddedHeader('Content-Length', $this->getData()->getSize());

        $array = [];
        $array[] = strtoupper($this->getMethod()) . ' ' . $path . ' HTTP/1.1';
        if (!empty($this->getHeader())) {
            foreach ($this->getHeader() as $key => $value) {
                $array[] = sprintf('%s: %s', $key, $value);
            }
        }
        $array = implode("\r\n", $array) . "\r\n\r\n";
        $this->client->send($array . $content);

        $revice = $this->client->recv();

        [$header, $body] = explode("\r\n\r\n", $revice);

        $header = explode("\r\n", $header);

        $status = array_shift($header);

        $this->setBody($body);
        $this->setStatusCode(intval(explode(' ', $status)[1]));
        $this->setResponseHeader($header);
    }


    /**
     * @param $path
     * @param $data
     * @return string
     */
    private function setParams($path, $data): string
    {
        if ($this->isGet()) {
            if (!empty($data)) $path .= '?' . $data;
        } else {
            $data = $this->mergeParams($data);
            if (!empty($data)) {
                $this->withBody(new Stream($data));
            }
        }
        return $path;
    }


    /**
     *
     */
    public function close(): void
    {
        $this->client->close();
    }

    /**
     * @return array
     */
    #[Pure] private function settings(): array
    {
        $sslCert = $this->getSslCertFile();
        $sslKey = $this->getSslKeyFile();
        $sslCa = $this->getCa();

        $params = [];
        if ($this->getConnectTimeout() > 0) {
            $params['timeout'] = $this->getConnectTimeout();
        }
        if (empty($sslCert) || empty($sslKey) || empty($sslCa)) {
            return $params;
        }

        $params['ssl_host_name'] = $this->getHost();
        $params['ssl_cert_file'] = $this->getSslCertFile();
        $params['ssl_key_file'] = $this->getSslKeyFile();
        $params['ssl_verify_peer'] = TRUE;
        $params['ssl_cafile'] = $sslCa;

        return $params;
    }
}