zhamao/connection-manager

基于Swoole的,使用共享内存表的进程间连接管理器

1.0.2 2020-11-03 12:31 UTC

This package is auto-updated.

Last update: 2024-08-29 05:16:22 UTC


README

https://packagist.org.cn/packages/zhamao/connection-manager

一个基于Swoole.Table的简易Websocket/HTTP连接属性扩充管理器,兼容Swoole多进程的。

基于Swoole的,使用共享内存表的进程间连接管理器

安装

通过Composer

composer require zhamao/connection-manager

用法

1.在Swoole\Server->start()前执行初始化:

$result = ZM\ConnectionManager\ManagerGM::init(1024);

参数如下:

  • $max_conn: (必填) 设置服务器最大接收的连接属性储存的数目
  • $conflict_proportion: (选填) hash冲突的最大百分比 (默认0.2),有关此参数,见Swoole文档
  • $options: (选填) 自定义属性参数的键名参数列表,用于添加自定义字段 (默认为空数组)

以下是带丰富参数的用例初始化方式:

$result = ZM\ConnectionManager\ManagerGM::init(1024, 0.2, [
    [
        "key" => 'connectToken',
        "type" => 'string',
        "size" => 128
    ]
]);

参数初始化的必填字段为keytype,其中type限定为以下类型:stringintfloatint1int2int8

size属性在typestring时必须填写,为字符串的最大长度。储存过程中如果字符串输入过长,会自动截断。

2.在Swoole服务器的onOpenonRequest事件最开始执行的代码:

use Swoole\Http\Request;
function onOpen($server, Request $request) {
    ZM\ConnectionManager\ManagerGM::pushConnect($request->fd);
}
function onRequest(Request $request, $response) {
    ZM\ConnectionManager\ManagerGM::pushConnect($request->fd);
}

参数如下:

  • $fd: (必填) 设置服务器最大接收的连接属性储存的数目
  • $name: (选填) 连接对象的类型名称 (默认default)
  • $options: (选填) 自定义属性参数的键名参数列表,用于添加和设置自定义字段 (默认为空数组)

高级用例:

$fd = 3;
ZM\ConnectionManager\ManagerGM::pushConnect($fd, 'wechatBot', ["connectToken" => 'abcde']);

3.在Swoole服务器的onClose事件执行的代码(销毁连接对象):

function onClose($server, $fd) {
    ZM\ConnectionManager\ManagerGM::popConnect($fd);
}

4.在Swoole服务器的messagerequest事件下可以用的方法:

$fd = 4;// 从 Frame 或 Request 对象中获取的 $->fd 值。
$obj = ZM\ConnectionManager\ManagerGM::get($fd);
if($obj === null) {
    // 如果 fd 对应的连接不存在,则会返回 null
    echo "连接不存在!" . PHP_EOL;
}
// 函数返回一个 `ConnectionObject` 对象,用于提取数据。
echo $obj->getFd(); // 返回 fd 连接标识符
echo $obj->getName(); // 返回连接类型名称
echo $obj->getOption("connectToken"); // 返回自定义字段的数据
echo $obj->getOptions(); // 返回所有自定义字段的数据
// 对象也可以直接操作改变内容
$obj->setName("qqBot"); // 改变连接的类型名称
$obj->setOption("connectToken", "qwerty"); //改变自定义字段的数据

// 此方法可以获取此类型名称下所有连接的 `ConnectionObject` 对象数组
$conns = ZM\ConnectionManager\ManagerGM::getAllByName("wechatBot");