huangjingfen/pro_v3.5.1/crmeb/services/wechat/CustomHttpClient.php

<?php
// +----------------------------------------------------------------------
// | Author: ScottPan Team 
// +----------------------------------------------------------------------

namespace crmeb\services\wechat;

use Symfony\Contracts\HttpClient\HttpClientInterface;
use Symfony\Contracts\HttpClient\ResponseInterface;
use Symfony\Contracts\HttpClient\ResponseStreamInterface;
use Symfony\Component\HttpClient\NativeHttpClient;
use Symfony\Component\HttpClient\Response\AsyncContext;
use Swoole\Coroutine\Http\Client;

/**
 * 携程curl请求
 * Class CustomHttpClient
 * @author 等风来
 * @email 136327134@qq.com
 * @date 2024/1/24
 * @package crmeb\services\wechat
 */
class CustomHttpClient implements HttpClientInterface
{

    /**
     * @var string
     */
    protected string $baseUrl = '';

    /**
     * @var int
     */
    protected int $timeout = 3;

    /**
     * @var array
     */
    protected array $httpConfig = [];

    /**
     * CustomHttpClient constructor.
     * @param string $baseUrl
     * @param array $httpConfig
     */
    public function __construct(string $baseUrl, array $httpConfig = [])
    {
        $this->baseUrl = $baseUrl;
        $this->httpConfig = $httpConfig;
    }

    /**
     * 发起请求
     * @param string $method
     * @param string $url
     * @param array $options
     * @return ResponseInterface
     * @author 等风来
     * @email 136327134@qq.com
     * @date 2024/1/24
     */
    public function request(string $method, string $url, array $options = []): ResponseInterface
    {
        // 合并传入的选项和默认选项
        $options = array_merge(self::OPTIONS_DEFAULTS, $this->httpConfig, $options);

        $ssl = strstr($this->baseUrl, 'https://') !== false;
        $baseUrl = str_replace(['https://', 'http://', '/'], '', $this->baseUrl);

        // 使用 Swoole Client 完成请求
        $client = new Client($baseUrl, $ssl ? 443 : 80, $ssl);

        $client->set([
            'timeout' => !empty($options['timeout']) ? $options['timeout'] : $this->timeout,
            'ssl_cert_file' => $options['cert'] ?? null,
            'ssl_key_file' => $options['ssl_key'] ?? null
        ]);

        $client->setMethod($method);
        $headers = [];
        // 设置请求头
        foreach ($options['headers'] as $key => $value) {
            if (is_string($key)) {
                $values = [];
                if (is_array($value)) {
                    foreach ($value as $item) {
                        [$type, $val] = strstr($item, ':') !== false ? explode(':', $item) : [null, null];
                        if ($type && $val) {
                            $values[] = $val;
                        }
                    }
                    $headers[$key] = implode(',', $values);
                } else {
                    $values[] = $value;
                    $headers[$key] = implode(',', $values);
                }
            } else {
                [$type, $val] = strstr($value, ':') !== false ? explode(':', $value) : [null, null];
                $values[] = $val;
                $headers[$type] = implode(',', $values);
            }
        }

        $client->setHeaders($headers);

        if (!empty($options['query'])) {
            $url = $url . (strstr($url, '?') !== false ? '&' : '?') . http_build_query($options['query']);
        }
        if (!empty($options['json'])) {
            $client->setData($options['json']);
        } else if (!empty($options['body'])) {
            $client->setData($options['body']);
        }

        // 发起请求
        $client->execute('/' . $url);

        // 创建响应对象
        $response = new SwooleResponse($client);

        // 关闭客户端连接
        $client->close();

        return $response;
    }

    /**
     * @param iterable|ResponseInterface $responses
     * @param float|null $timeout
     * @return ResponseStreamInterface
     * @author 等风来
     * @email 136327134@qq.com
     * @date 2024/1/25
     */
    public function stream(iterable|ResponseInterface $responses, float $timeout = null): ResponseStreamInterface
    {
        // 创建 ResponseStreamInterface 对象并进行流式处理
        $stream = new AsyncContext($responses, $this->httpClient, $timeout);

        // 返回流对象
        return $stream;
    }

    /**
     * @param array $options
     * @return $this
     * @author 等风来
     * @email 136327134@qq.com
     * @date 2024/1/25
     */
    public function withOptions(array $options): static
    {
        $this->httpConfig = array_merge(self::OPTIONS_DEFAULTS, $options);
        if (!empty($this->httpConfig['base_uri']) && $this->httpConfig['base_uri'] !== $this->baseUrl) {
            $this->baseUrl = $this->httpConfig['base_uri'];
        }
        return $this;
    }
}