WebSocket 控制器

所有从客户端发过来的数据都会打进控制器，我们开发项目时候，处理请求基本都是在控制器里做。

定义

<?php
namespace ImiDemo\WebSocketDemo\MainServer\WSController\Index;

use Imi\ConnectionContext;
use Imi\Controller\WebSocketController;
use Imi\Server\WebSocket\Route\Annotation\WSRoute;
use Imi\Server\WebSocket\Route\Annotation\WSAction;
use Imi\Server\WebSocket\Route\Annotation\WSController;

/**
 * 数据收发测试
 * @WSController
 */
class Test extends WebSocketController
{
    /**
     * 登录
     * 
     * @WSAction
     * @WSRoute({"action"="login"})
     * @return void
     */
    public function login($data)
    {
        ConnectionContext::set('username', $data->username);
        $this->server->joinGroup('g1', $this->frame->getClientId());
        return ['success'=>true];
    }
}

首先控制器类必须有@WSController注解，对应动作必须有@WSAction和@WSRoute注解。

注解

@WSController

注释目标：类

表明一个类是控制器类

通常：

@WSController

指定匹配 http 路由：

// 只有握手 /test 这个路径才可以触发该 WebSocket 动作
@WSController(route="/test")

@WSRoute

指定 WebSocket 路由解析规则。

// 解析 $data['action'] === 'login'
@WSRoute({"action"="login"})
// 解析 $data['a']['b']['c'] === 'login'
@WSRoute({"a.b.c"="login"})
// 解析 $data['a'] == '1' && $data['b'] == '2'
@WSRoute({"a"="1", "b"="2"})

当然对象也是支持的：

// 解析 $data->a->b->c === 'login'
@WSRoute({"a.b.c"="login"})

指定匹配 http 路由：

// 只有握手 /test 这个路径才可以触发该 WebSocket 动作
@WSRoute(condition={"action"="login"}, route="/test")

路由匹配成功，就会执行这个动作。

动作响应数据

响应当前这个请求

直接在方法中返回一个数组或对象，在Http 控制器中@WSConfig中设定的处理器，就会把这个转为对应数据响应给客户端。

return ['success'=>true];

分组发送

$this->server->groupCall('组名', 'push', ['success'=>true]);

当然，并不是每个请求都需要有响应数据，什么都不return或者return null就是不响应数据。

类属性

$server

详见：链接

$frame

当然，你还可以直接通过请求上下文代理类，在任意地方使用：

\Imi\Server\WebSocket\Message\Proxy\FrameProxy::getFormatData();

方法

公用方法：

/**
 * 获取客户端的socket id.
 *
 * @return int|string
 */
public function getClientId();

/**
 * 数据内容，可以是文本内容也可以是二进制数据，可以通过opcode的值来判断.
 */
public function getData(): string;

/**
 * 获取格式化后的数据，一般是数组或对象
 *
 * @return mixed
 */
public function getFormatData();

/**
 * WebSocket的OpCode类型，可以参考WebSocket协议标准文档
 * WEBSOCKET_OPCODE_TEXT = 0x1 ，文本数据
 * WEBSOCKET_OPCODE_BINARY = 0x2 ，二进制数据.
 */
public function getOpcode(): int;

/**
 * 表示数据帧是否完整.
 */
public function isFinish(): bool;

/**
 * 获取客户端地址
 */
public function getClientAddress(): \Imi\Util\Socket\IPEndPoint;

Swoole 方法：

/**
 * 获取 \Swoole\Websocket\Frame 对象
 */
public function getSwooleWebSocketFrame(): \Swoole\Websocket\Frame;