您当前的位置： 首页 > 慢生活 > 程序人生 网站首页程序人生

workerman常用组件-GlobalData变量共享组件-GlobalData 组件客户端

发布时间：2021-12-12 20:13:58编辑：雪饮阅读（）

 GlobalData 组件客户端

(要求Workerman版本>=3.3.0)
 
__construct
void \GlobalData\Client::__construct(mixed $server_address)
实例化一个\GlobalData\Client客户端对象。通过在客户端对象上赋值属性来进程间共享数据。
 
参数
GlobalData server 服务端地址，格式<ip地址>:<端口>，例如127.0.0.1:2207。
 
如果是GlobalData server集群，则传入一个地址数组，例如array('10.0.0.10:2207', '10.0.0.0.11:2207')
 
说明
支持赋值、读取、isset、unset操作。
同时支持cas原子操作。
 
 
实例：（为了方便，这里用于客户端连接的服务端也同时建立在同一个脚本中）：
<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';
 
// GlobalData Server
$global_worker = new GlobalData\Server('127.0.0.1', 2207);
 
$worker = new Worker('tcp://0.0.0.0:6636');
// 进程启动时
$worker->onWorkerStart = function()
{
    // 初始化一个全局的global data client
    global $global;
    $global = new \GlobalData\Client('127.0.0.1:2207');
};
// 每次服务端收到消息时
$worker->onMessage = function(TcpConnection $connection, $data)
{
    // 更改$global->somedata的值，其它进程会共享这个$global->somedata变量
    global $global;
    echo "now global->somedata=".var_export($global->somedata, true)."\n";
    echo "set \$global->somedata=$data";
    $global->somedata = $data;
};
Worker::runAll();
?>
那么实例运行并有telnet连接后有触发到上面这个脚本的onMessage时：
[root@localhost workerman]# /usr/local/php734/bin/php -c /usr/local/php734/lib/php/php.ini start.php start
Workerman[start.php] start in DEBUG mode
-------------------------------------------- WORKERMAN ---------------------------------------------
Workerman version:4.0.22          PHP version:7.3.4
--------------------------------------------- WORKERS ----------------------------------------------
proto   user            worker              listen                    processes    status
tcp     root            globalDataServer    frame://127.0.0.1:2207    1             [OK]
tcp     root            none                tcp://0.0.0.0:6636        1             [OK]
----------------------------------------------------------------------------------------------------
Press Ctrl+C to stop. Start success.
 
now global->somedata=NULL
set $global->somedata=adsa
 
 
now global->somedata='adsa
'
set $global->somedata=kk
 
telent连接并触发上面脚本的onMessage方法：
[root@localhost workerman]# telnet 127.0.0.1 6636
Trying 127.0.0.1...
Connected to 127.0.0.1.
Escape character is '^]'.
adsa
kk