搜索-workerman社区

问答请问worker间数据如何同步？

用Gateway框架进行分布式部署。现在有个问题，用户1连接分配在worker1,用户2连接分配在worker2。那用户2想获取用户1的数据，他们如何进行数据的交流啊。谢谢！

问答webman怎么在onWorkerStart中实例化数据库？

webman怎么在onWorkerStart中实例化数据库？以保证每个进程只需要连接一次数据库即可，降低数据库连接数

问答gatewayworker查看进程状态，total_request请求数相同

gatewayworker查看进程状态，total_request请求数为何都是一样的？

问答有100个任务要处理，如何分发任务

1 从数据库获取数据，数据遍历发送Http请求, 2 那也是要等待返回数据，串行执行，时间并没减少疑问难道得用 curl_multi ```php // 创建一个Worker监听2345端口，使用http协议通讯 $http_worker = new Worker("http://0.0.0.0:2345"); // 启动4个进程对外提供服务 $http_worker->count

问答多进程如何共享大型数组？

php进程中数组占用5Gb内存，随着不断循环计算数据在不断的变化。其他进程，如何去读取这个数组里面的数据？通过redis、GlobalData等都不行，因为要保存到redis、GlobalData需要先把数组序列化，然后保存。然后读取的又需要反序列化，非常耗时间有没有什么办法？没有办法共享这个数组的内存地址给其他进程？ 2. 有没有其他不比php数组性能差的数据结构？

关于数据库这样实例化多次mysql连接性能上会不会比只实例化一次好点 ```php class Events { public static $db = ; /** * 进程启动后初始化数据库连接123456", "test"); } } // 使用 self::$db->select("*")->from("test")->query(); ``` 你们是怎么用的你们是不是做了数据库连接池有没有demo 给我参考下，谢谢大神们其实我知道上面这种方式不妥应为php是单进程多少客户端连接就会产生多少个进程用gateway的话服务都是交给businessworker这个进程处理所以有没有办法把数据库连接交给businessworker这个进程 Events 直接让businessworker 去操作数据库这样是不是就能再businessworker上做连接池呢还要个问题就是每个worker进程是通过什么形式维护各自连接的多个客户端的？不同客户端直接的信息是怎样分割开来的?

问答同一服务器多个GatewayWorker好还是一个GatewayWorker多个进程好

同一服务器上因为部署多个使用多个GatewayWorker的项目，我现在开启的3个GatewayWorker服务，通讯有点延迟，各位大神麻烦问下，开启一个GatewayWorker服务多个进程使用好，还是开启多个GatewayWorker好，那种的对通讯延迟的改善好点

问答socket数据包是否可以用WebSocket进行解码

如果我想接收继电器发过来的socket数据，用Demo里的Protocols/WebSocket.php类是否可以用来解包呢。之前没太接触过这方面，望不吝赐教

问答可不可以将数据库读取的用户所有数据都保存在$_SESSION里？

/question/2112 我游戏里的操作是，玩家登录后从数据库读取用户信息，然后global &user,&bag.........让我以为是再调用这个global &user,&bag的时候数据失效了，钻入了进程间不共享的情况。现在问题找到，我想用户的数据库数据只给自己用，不和其他玩家有互换。想到$_SESSION是和client_id对应的。但是对于用户数据特别多的情况，会不会引发性能的问题，因为手册里说每次通信都会携带这个$_SESSION，并且这么存保险的保险，还请大神抽空解答一下。另外，数据库的实例&db是否也可以这样放进去$_SESSION=&db; 谢谢！

问答php8.1版本打包二进制运行使用mongodb创建索引报错

#### 问题描述 php8.1版本打包二进制运行使用mongodb创建索引报错，进行打包下载的php8.1.micro.sfx中的mongodb版本过低；在不打包的情况下运行项目，请求执行创建mongodb

问答workerman重启后，之前的进程依然在执行onWorkerStart方法

因业务场景需求，我在workerman的回调方法onWorkerStart中，加入了定时工作内容（使用的workerman的Timer类），每隔20秒执行一次数据库操作但是重启workerman后（phpstart.php restart），发现同时有2个进程在执行onWorkerStart方法的内容（重启前的workerman与重启后新开的workerman，或者是我理解错了，但是确实这个方法有2个进程在同时执行），请问这个是为什么呢，另外，之前的进程会于数个小时后，才会自己注销并停止onWorkerStart的代码执行因为目前2个方法同时执行会影响到数据内容，所以必须在重启时，强制删除前一个进程才能保证功能的正常运行，当前是找运维在服务器中强制删除前一个进程，请问有什么别的更好的办法吗？还有，因为之前开发的时候，socket连接中储存了用户的一些数据，所以没有使用平滑重启，是否必须使用平滑重启才可以？请大佬们不吝赐教，非常感谢

问答负载均衡webman自定义进程

关于负载均衡webman自定义进程 // 监听的协议 ip 及端口（可选） 'listen' => 'udp://0.0.0.0:12345', 发送数据 $client = stream_socket_client个服务器，貌似乱套了负载均衡内每个服务器的listen监听的0.0.0.0是否需要改成对应服务器的内网ip呢,每个服务器防火墙是不是也要开启对应的udp端口 stream_socket_client发送数据时地址是否也要改成对应服务器的内网

问答向客户端app做推送,是用workerman还是gatewayWorker？

目前的web项目中要实现服务端向客户端app做主动推送，是用workerman还是gatewayWorker？

问答不同的worker进程能共用一个超全局的变量对像存取数据么？

在业务逻辑进程里经常需要存取数据，而且业务逻辑都是在event.php 这个进程里由于会有多个进程，导致直接用变量根本没有办法数据唯一性。现在都是用redis 来做的，多个进程和redis 进行读取。redis 需要不断序列化反序列化存储读取。我想用一个超全局的内存对像来代替redis 应该怎么做呢？能不能在开始启动的 start.php 里建一个 static 变量，公开出来给每个worker 进程使用呢？实际上就是多个进程共用内存的方案。。

问答服务器向设备发送心跳检测，好像未关闭通道

#### 问题描述目前在做设备物联网，分成了客户端`client_gateway`和设备端`device_gateway`，因为设备电池比较小，硬件大佬要做低功耗，就说服老板取消了定时发送心跳，搞的现在设备在线状态都不准确了今天想起可以反向发送心跳检测，就试了下，确实发出去了，但是也出现了新问题：设备不再发送心跳，为了省电（我也不知道究竟能省多少电...）客户端（小程序）模式不变定时发送心跳给服务器 `device_gateway`增加了服务端发送心跳 ```php // 服务端定时向客户端（设备）发送的数据（在设备不发心跳的情况下）_SESSION['device_info'])) { $target = 'device'; //出现 not_log 时不进行下线处理service->create_device_log($device_info['device_id'], 4, '设备下线了'); //发送给客户端

问答通过AsyncTcpConnection循环访问https接口的json数据问题

```php use \GatewayWorker\Lib\Gateway; use \Workerman\Connection\AsyncTcpConnection; use \Workerman\Events(); // worker名称 $worker->name = 'M-BtcTrade-COM'; // bussinessWorker进程数量 $worker->count = 1; // 服务注册地址\n"; //输出数据进行处理 .................................................. ......................defined('GLOBAL_START')) { Worker::runAll(); } ``` 以上代码是每秒钟循环中抓取一下5个URL返回的JSON数据现在的问题是在$con->onMessage还未完全处理完数据之前，$con 对象就被下次循环重建了，从而造成数据丢失，请问如何修改代码才能避免这个问题的出现呢？

问答在规定的时间发送了心跳，还是会断开链接

用GatewayWorker，每隔一秒发送心跳，服务端也有响应，怎么还是会连接断开，每次在5秒左右就自动断开了。 !

问答onWorkerStart里面是stream流数据，前端连接不上的问题，求解答

#### 问题描述，谢谢解答 **onWorkerStart里面是stream流数据，导致前端连接失败，因为在不停的推送数据，默认没有执行完成，求1个思路，感谢。$promise = $client->getAsync('这里是一个流链接地址，会不停的推送如下图所示的数据', [ 'headers' => $headers,($body); if ($line) { var_dump($line); // 在这里我想实现，把line数据推送给前端连接对象$body->eof()) { ]逐行读取影响了，因为在不停的推送数据，没有执行完成 // 上面的while注释掉，前端可以连接成功 } }{ $connection->send('heartbeat'); } }; // 向所有验证的用户推送对应的数据 function broadcast($msg, $symbol

问答使用GatewayWorker心跳问题

#### 问题描述我使用的是webman，安装的GatewayWorker代码如下：我使用的tcp服务，硬件那边主动连接我处理一些请求之后返回结果给硬件端。现在是在硬件跟我请求处理的时候可能时间会大于pingInterval设置的时间，这样我服务器就会给硬件发送ping 的心跳包，但是在处理请求的时候硬件那边说不能接受其它无关数据。就是发送这个ping包不可以。我想问下这样有什么好的解决办法吗，我把pingData设置为空可以吗。如果为空会怎么样。public static function onMessage($client_id, $message) { Log::notice($message); // 发送响应给客户端

问答我用GatewayClient 连接了GatewayWorker，目前正常通信

我用GatewayClient 连接了GatewayWorker，目前正常通信，也能给指定设备发送信息，查询状态，现在在events.php中的message中处理设备注册入库和上下线状态处理，手册上说尽量不要再event的message中写逻辑代码，我想在PHP后台获取每次设备发送的信息然后进行处理入库，要怎么样实现接收每个设备发送上来的信息呢！