登录/注册

WebSocket 协程客户端

Hyperf 提供了对 WebSocket Client 的封装,可基于 hyperf/websocket-client 组件对 WebSocket Server 进行访问;

安装

composer require hyperf/websocket-client

使用

组件提供了一个 HyperfWebSocketClientClientFactory 来创建客户端对象 HyperfWebSocketClientClient,我们直接通过代码来演示一下:

<?php
declare(strict_types=1);

namespace AppController;

use HyperfDiAnnotationInject;
use HyperfWebSocketClientClientFactory;
use HyperfWebSocketClientFrame;

class IndexController
{
    /**
     * @Inject
     * @var ClientFactory
     */
    protected $clientFactory;

    public function index()
    {
        // 对端服务的地址,如没有提供 ws:// 或 wss:// 前缀,则默认补充 ws://
        $host = '127.0.0.1:9502';
        // 通过 ClientFactory 创建 Client 对象,创建出来的对象为短生命周期对象
        $client = $this->clientFactory->create($host);
        // 向 WebSocket 服务端发送消息
        $client->push('HttpServer 中使用 WebSocket Client 发送数据。');
        // 获取服务端响应的消息,服务端需要通过 push 向本客户端的 fd 投递消息,才能获取;以下设置超时时间 2s,接收到的数据类型为 Frame 对象。
        /** @var Frame $msg */
        $msg = $client->recv(2);
        // 获取文本数据:$res_msg->data
        return $msg->data;
    }
}

关闭自动关闭

默认情况下,创建出来的 Client 对象会通过 defer 自动 close 连接,如果您希望不自动 close,可在创建 Client 对象时传递第二个参数 $autoClosefalse

$autoClose = false;
$client = $clientFactory->create($host, $autoClose);
原文地址:https://www.bookstack.cn/read/hyperf-1.1.20/websocket-client.md
文章来源与用户投稿或网络采集,如果您是本文的作者,发现版权或转载方式问题请右侧邮箱联系管理员。

抢沙发

我们不是孤独的个体,留下足迹,保持联系,成为团体...
姓名
电子邮件
个人主页