问答实例B向实例A中的客户端推送数据该怎么做效率最高?
目前有这样一个需求 使用的是GatewayWorker
以前定时器是运行在实例A中的,但是随着推送业务量的增加会导致进程阻塞,影响客户端的上行效率,所以现在打算专门再跑一个实例B专门处理下行业务的推送.实例A 所有的客户端连接和上行数据处理
实例B 仅使用定时器处理io阻塞业务, 查询到数据库中有推送需求时向实例A中的指定客户端推送数据.
想问一下要实现以上功能效率最高的方式是什么?
问答请问下基于AsyncTcpConnection实现的WS客户端，如何发送PING（0x9）数据
请问下基于AsyncTcpConnection实现的WS客户端，如何发送PING（0x9）数据？
问答GateWay添加支持原数据Ping包
在示例包中看见GateWay已经支持ping pong的逻辑，但是只能发送相应协议打包好的数据
建议添加一个判断支持发送原生的数据用于ping发送
例如websocket有原生的ping协议，这样可以减少些流量，也能使onWebSocketPing，onWebSocketPong等方法能有效利用上
简单的修改了一下：
GatewayWorker/Gateway.php
增加 $pingRaw = false
问答用于打包二进制时独立出来
#### 打开二进制后一旦修改点字符什么的，都需要重新打包！
而由于业务逻辑，假设当前有3个plugin应用。其中1个应用(随时有业务代码变更)我想独立出来，
另外2个(不常修改)打包在二进制内
我的想法：
在根目录下自定义新建一个文件夹做应用，在打包时把这个文件夹独立出来
目前问题：
单纯路由文件url是没问题
问答使用了二进制协议传输文件文件过大时会自动断开
我使用了GateWay 传输较大文件时，使用了前端文件切片上传 在发送文件到60%多时总是出现数据丢失情况。
问答php如何像客户端那样向socket服务器推送数据？
我在本地如何用php语言向socket服务器发送数据，并收到服务器推送结果
web-msg-sender好像是**客户端->服务端**，**服务端->客户端**之间的沟通，那么我如果用php向socket服务器推送数据呢？这个要如何实现，我的假想是socket服务器那里提供一个接口，然后接口里引入socket服务，再进行相应推送，代码如下
```php
$sender_io = new SocketIO(2120);
// 客户端发起连接事件时，设置连接socket的各种事件回调
//
$post = $_POST;
if($post) {
$sender_io->emit('post_data', $post
问答gatewayworker高并发的问题
但是 Gateway::getAllClientIdCount() 在2000并发的时候可以获取数字，2500的失败的时候获取的数字是0.
以下是成功的时候，查看到的状态信息：
我看gateway 进程连接数是1000左右，两个进程就2000出头，是不是跟这个限制有关？似乎我这个进程是缩水到每到个进程 1000 个连接数上线
我看对应进程的限制： cat /proc/322938/limits 里面的 Max open files 是65535。log.Println("read:", err)
return
}
log.Printf("recv: %s", message)
}
}()
// 定时器，隔50秒向服务器发送* 50)
defer ticker.Stop()
for {
select {
case <-done:
return
case <-ticker.C: // 定时器到时间 发送消息
问答游戏跨进程数据读写承载压力大
用gatewayworker做的捕鱼，房间数据用GlobalData原子实现，4个玩家在同一个房间不在同一个进程，每次发射子弹(每秒5发)，都要判断取当前房间鱼数组判断当前命中鱼是否存在，击杀后修改数组，房间出鱼更新也要往数组里加 ，都是原子实现, 阿里云8核ic5开24个business 进程 ，gateway 和 register 服务在另一台服务器 ，400多同时在线 大概一百多房间，8个cpu
分享workerman实现微信公众号带参数二维码扫码识别用户
把`二维码参数`，转发到websocket服务`wss://www.iyuu.cn:2129`，websocket服务保存转发来的信息建立映射关系；
5.;
// 开启一个内部端口，方便内部系统推送数据，Text协议格式 文本+换行符
$inner_text_worker = new Worker('text://0.0.0.0:5678，里面有uid，表示向那个uid的页面推送数据
$data = json_decode($buffer, true);
if (isset($data['uid'])) {
$uid == $ticket){
return;
}
// 通过workerman，向uid的页面推送数据
$ret = sendMessageByUid($uid, $buffer);ticket = $message['ticket'];
}
/* 保存uid到connection的映射，这样可以方便的通过uid查找connection，
* 实现针对特定uid推送数据
问答用AsyncTcpConnection向服务器发送指令，获取服务器返回的数据。
imageMogr2/auto-orient/strip%7CimageView2/2/w/700)
在cmd下执行 php test.php，可以正常收发数据。但指令是由用户发送，所以要用PHP写个接口获取用户的指令，然后运行workerman返回指令对应的数据。
想请教下接口获取用户发来的指令后，怎么运行workerman？
问答首次跟设备链接 发送数据的问题
因为有多台设备 我需要把某台的唯一标识发送给设备端 但是 唯一标识 我只在建立链接的时候 发送一次给他就好 这种操作要写在哪个函数上
问答外部网站向RedisQueue发送数据没有收到
使用GatewayWorker架设了个服务端
采用RedisQueue来处理信息队列
在Events.php里的onWorkerStart里创建了订阅
$redisQueue=new Client('redis1';
$data= ['some', 'data'];
$result=self::redis_queue_send($redis, $queue, $data);
}
```
在测试中，发现外部网站使用上面那样的发送，有发送成功了，但服务端没有收到。在服务端里采用
$redisQueue->send('User-1',$data);
来发送，是可以收到的。
不知是哪里有问题。
问答webman下 http进程 向 websocket 的 Gateway进程发送消息
#### 问题描述
我看教程推荐使用 GatewayClient，但是我发现 GatewayWorker\Lib\Gateway 也可以发送
!
文档在其它项目中推送
# 在其它项目中利用Workerman给客户端推送数据
**问：**
我有一个普通的web项目，想在这个项目中调用Workerman的接口，给客户端推送数据。/components/channel-examples.md)（支持多进程/服务器集群，需要下载Channel组件）
- [基于Worker推送](https://www.workerman.net/q/508)(单进程，最简单)
**基于webman参考下面连接**
- [webman push插件](https://www.workerman.net/plugin/2)
**基于GatewayWorker参考下面连接**
- [在其它项目中通过GatewayWorker推送](https://www.workerman.net/doc/gateway-worker/push-in-other-project.html)(支持多进程/服务器集群，支持分组、组播、单个发送)
**基于PHPSocket.IO参考下面连接**
- [web消息推送](https://www.workerman.net/web-sender
问答Gateway::sendToCurrentClient包长度限制
使用Gateway::sendToCurrentClient()发送比较长的数据，数据被拆开了，客户端收到两次onMessage。这个长度的限制在哪里设置？谢谢
问答gateway tcp 4-5分钟后再发送数据 服务端收不到 然后自动断开
gateway tcp 4-5分钟后再发送数据 服务端收不到 然后自动断开
```php
$gateway_hardware = new Gateway("Hardware://0.0.0.0:9001");
// 进程名称，主要是status时方便识别
$gateway_hardware->name = 'SBGatewayHardware';
$gateway_hardware->count =gateway_hardware->pingInterval = 60;
// 心跳未响应断开时间
$gateway_hardware->pingNotResponseLimit = 0;
// 心跳数据defined('GLOBAL_START'))
{
Worker::runAll();
}
```
在服务端不下发心跳 客户端2小时后上发信息就提示连接断开
问答Gatewayer worker websocket里面向大模型数据,socket无法接收用户数据
当worker进程里面往GPT（使用的是webman/openai扩展）,让GPT按SSE返回数据，在接收GPT返回数据过程当中，用户通过websocket发送数据过来，网关端可以检测到数据已接收，但是无法给到worker进程。直到worker进程接收完GPT返回的数据之后，此时，worker进程才接收到用户发送过来的数据
#### 代码
```
$body = [
'stream' => true,lastConversationId) {
static $test = new GptOutStreamDealService('');
// 当openai接口返回数据时转发给浏览器
问答请教下pcntl 系列函数中信号机制的问题
假如是这样一种场景： 为了验证我的一些猜想，在PHP脚本内部, 我在父进程发送SIGTERM信号给其派生的所有子进程（也就是使用posix_kill函数发送SIGTERM信号）, 期间使用了pcntl_signal注册信号，并设定了父进程的信号处理函数， 根据我理解的理论知识，如果没有设定SIGTERM信号处理函数，默认情况下posix_kill会执行SIGTERM信号的原始行为即终止子进程, 但是如果设定了SIGTERM信号处理函数（函数只是做了个echo而已）, posix_kill的SIGTERM信号的原始行为就会被改变，但是经过试验，我发现所有的子进程还是被终止退出了....., 请问老大是我理解的信号机制有问题呢还是代码编写有问题另外我已经模拟编写了一个多进程PHP脚本，你看是否能帮看下这个脚本，谢谢？~~
问答GatewayWorker Summary 显示的内存没有变小
在进行压力测试时，只是测试在线保持数量，客户端和服务端并没有发送任何数据：
这里是我简单写的压测程序：[**`https://github.com/liamhao/websocket-pressure-test### 第一步：
先通过`php start.php start`启动`GatewayWorker`，这时输入`php start.php status`查看进程状态，结果如下图所示，`Summary`[截图](/upload/img/20220429/29626b49cac77f.png)
### 第二步
开始压测，当连接数达到`37`万左右时，`Summary`字段显示内存占用`2052M`：[截图](/upload/img/20220429/29626b4990d651.png)
### 第三步
停止压测，将连接数将为`0`时，`Summary`字段仍然显示内存占用`2052M`，并没有降低里面的数据到底是什么？在以上的基础上，不重启`GatewayWorker`的情况下，进行第二次压测，内存并不会在`2052M`的基础上继续增加。想知道具体原因和实现的原理，谢谢。
问答想了解下数据是如何分发到子进程的
关闭端口复用时：在子进程分支之前开始监听
打开端口复用时：在子进程分支之后开始监听
这两种方式有什么区别呢
还有就是无论哪种，在分支之后相当于每个进程都在监听同一个端口，那数据是怎么分发到一个进程去处理而不是所有进程都进行处理呢
赞助商
