php-websocket hyperf/websocket-server/client 客户端和服务器实时双向数据传输

2021-12-07 15:15:03 浏览数 (1)

WebSocket 服务

WebSocket是一种通信协议，可在单个TCP连接上进行全双工通信。WebSocket使得客户端和服务器之间的数据交换变得更加简单，允许服务端主动向客户端推送数据。在WebSocket API中，浏览器和服务器只需要完成一次握手，两者之间就可以建立持久性的连接，并进行双向数据传输。

Hyperf 提供了对 WebSocket Server 的封装，可基于 hyperf/websocket-server 组件快速搭建一个 WebSocket 应用。

安装

代码语言：javascript复制
composer require hyperf/websocket-server
复制代码

配置 Server

修改 config/autoload/server.php，增加以下配置。

代码语言：javascript复制
<?php

'servers' => [
    [
        'name' => 'ws',
        'type' => Server::SERVER_WEBSOCKET,
        'host' => '0.0.0.0',
        'port' => 9502,
        'sock_type' => SWOOLE_SOCK_TCP,
        'callbacks' => [
            SwooleEvent::ON_HAND_SHAKE => [HyperfWebSocketServerServer::class, 'onHandShake'],
            SwooleEvent::ON_MESSAGE => [HyperfWebSocketServerServer::class, 'onMessage'],
            SwooleEvent::ON_CLOSE => [HyperfWebSocketServerServer::class, 'onClose'],
        ],
    ],
],
复制代码

配置路由

目前暂时只支持配置文件的模式配置路由，后续会提供注解模式。

在 config/routes.php 文件内增加对应 ws 的 Server 的路由配置，这里的 ws 值取决于您在 config/autoload/server.php 内配置的 WebSocket Server 的 name 值。

代码语言：javascript复制
<?php

Router::addServer('ws', function () {
    Router::get('/', 'AppControllerWebSocketController');
});
复制代码

创建对应控制器

代码语言：javascript复制
<?php
declare(strict_types=1);

namespace AppController;

use HyperfContractOnCloseInterface;
use HyperfContractOnMessageInterface;
use HyperfContractOnOpenInterface;
use SwooleHttpRequest;
use SwooleServer;
use SwooleWebsocketFrame;

class WebSocketController implements OnMessageInterface, OnOpenInterface, OnCloseInterface
{
    public function onMessage(Server $server, Frame $frame): void
    {
        $server->push($frame->fd, 'Recv: ' . $frame->data);
    }

    public function onClose(Server $server, int $fd, int $reactorId): void
    {
        var_dump('closed');
    }

    public function onOpen(Server $server, Request $request): void
    {
        $server->push($request->fd, 'Opened');
    }
}
复制代码

接下来启动 Server，便能看到对应启动了一个 WebSocket Server 并监听于 9502 端口，此时您便可以通过各种 WebSocket Client 来进行连接和进行数据传输了。

代码语言：javascript复制
$ php bin/hyperf.php start

[INFO] Worker#0 started.
[INFO] WebSocket Server listening at 0.0.0.0:9502
[INFO] HTTP Server listening at 0.0.0.0:9501
复制代码

WebSocket 协程客户端

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

安装

代码语言：javascript复制
composer require hyperf/websocket-client
复制代码

使用

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

代码语言：javascript复制
<?php
declare(strict_types=1);

namespace AppController;

use HyperfDiAnnotationInject;

class IndexController extends Controller
{

    /**
     * @Inject()
     * @var HyperfWebSocketClientClientFactory
     */
    protected $clientFactory;

    public function index()
    {
        // 对端服务的地址，如没有提供 ws:// 或 wss:// 前缀，则默认补充 ws://
        $host = '127.0.0.1:9502';
        // 通过 ClientFactory 创建 Client 对象，创建出来的对象为短生命周期对象
        $client = $this->clientFactory->create($host);
    }
}
复制代码

自动关闭连接开关

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

代码语言：javascript复制
<?php

$autoClose = false;
$clientFactory->create($host, $autoClose);
复制代码

官网及交流

Github <- 点 Star 支持我们 Hyperf 官网

相关链接

  • Hyperf 的详细介绍：点击查看
  • Hyperf 的下载地址：点击下载
网站 socket编程 php

0 人点赞