如何在 Hyperf 框架中正确使用 composer 客户端？-composer-PHP中文网

如何在 Hyperf 框架中正确使用 composer 客户端？

穿越時空

发布： 2025-11-25 17:11:02

原创

965人浏览过

在 Hyperf 中使用 hyperf/guzzle 组件发起 HTTP 请求，需通过 ClientFactory 创建协程安全的客户端实例。1. 安装 hyperf/guzzle 组件；2. 依赖注入 ContainerInterface 获取 ClientFactory；3. 调用 create 方法配置客户端并发送请求，使用 __toString() 读取响应体；4. 利用 parallel() 并发处理多个请求以提升性能；5. 避免直接 new GuzzleHttp\Client 或静态调用，防止协程错误。正确配置超时与连接参数可保障服务稳定。

如何在 hyperf 框架中正确使用 composer 客户端？

在 Hyperf 框架中使用 Composer 客户端，主要是指通过 hyperf/guzzle 组件发起 HTTP 请求，因为 Hyperf 本身没有内置的“Composer 客户端”，但常被误解为操作 Composer 包管理器。实际上，用户通常想表达的是：如何在 Hyperf 中安全高效地调用外部 API 或服务。以下是正确做法。

安装 Guzzle HTTP 客户端组件

Hyperf 使用 hyperf/guzzle 作为其官方推荐的 HTTP 客户端封装，基于 Guzzle 构建并适配 Swoole 协程环境。

执行以下命令安装：

composer require hyperf/guzzle

登录后复制

配置并使用 HTTP 客户端

直接在控制器或服务类中注入或创建一个客户端实例。注意：不要在协程环境中使用原生 cURL 或同步的 Guzzle，必须使用适配 Swoole 的方式。

示例：创建一个简单的 GET 请求

爱图表

AI驱动的智能化图表创作平台

305

查看详情

use Hyperf\Guzzle\ClientFactory;
use Psr\Container\ContainerInterface;

class ApiService
{
    protected ClientFactory $clientFactory;

    public function __construct(ContainerInterface $container)
    {
        $this->clientFactory = $container->get(ClientFactory::class);
    }

    public function getData()
    {
        // 创建一个 Guzzle 客户端实例
        $client = $this->clientFactory->create([
            'base_uri' => 'https://api.example.com',
            'timeout' => 5.0,
        ]);

        $response = $client->get('/users');
        return json_decode($response->getBody()->__toString(), true);
    }
}

登录后复制

说明：

ClientFactory 是 Hyperf 提供的工厂类，用于创建协程安全的 Guzzle 客户端。
通过依赖注入获取 Container，再从中取出 ClientFactory 实例。
使用 __toString() 获取响应内容，因为 Swoole 的 Stream 不支持直接转换。

处理并发请求提升性能

利用 Swoole 协程优势，可同时发起多个请求而不会阻塞。

use Hyperf\Utils\Coroutine;

public function fetchMultiple()
{
    $uris = [
        'user' => '/api/user',
        'posts' => '/api/posts',
        'comments' => '/api/comments'
    ];

    $clients = [];
    foreach ($uris as $key => $uri) {
        $clients[$key] = $this->clientFactory->create([
            'base_uri' => 'https://api.example.com',
        ]);
    }

    $data = parallel([
        function () use ($clients) {
            $response = $clients['user']->get('/user');
            return json_decode($response->getBody()->__toString(), true);
        },
        function () use ($clients) {
            $response = $clients['posts']->get('/posts');
            return json_decode($response->getBody()->__toString(), true);
        },
    ]);

    return $data; // 返回两个结果的数组
}

登录后复制

parallel() 函数是 Hyperf 提供的并发工具，适合需要同时获取多个资源的场景。