问答【已解决】gateway-worker的onClose得不到$_SESSION数据
#### 问题描述
发送消息如果不走进判断里关闭连接时可以获得$_SESSION数据，但进判断里就得不到了。
问答服务端推送消息至客户端字节大小有限制
// $client = stream_socket_client('tcp://192.168.85.128:5678', $errno, $errmsg, 1);
// 推送的数据，包含uid字段，表示是给这个uid推送
echo 'ERRER:'.$errmsg;
$data = array('uid'=>'uid1', 'data'=>'这里2000个字节的时候会返回fail 字节少的时候返回ok');
// 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
fwrite($client, json_encode($data)."$client;
echo fread($client, 8192);
}
发送比较多字节的时候会返回fail 字节少的时候返回ok
ERRER:0=$
问答GatewayWorker使用websocket协议，交互数据格式为json，会有粘包的问题存在吗
假设同一个客户端并发请求，或者服务端并发的下发数据
会有粘包的问题吗？如果有的话怎么解决呢？
我看到有说制定协议，制定协议约定好了比如格式为json，结尾为\n，那么出现粘包的问题是通过\n切割吗？
问答GatewayWorker平滑重启造成客户端中断链接[已解决]
正常情况下GatewayWorker平滑重启不会造成客户端中断链接, 但是如果在平滑重启的那一刻, 客户端有发送数据进来, GatewayWorker就会报下面的错误:
SendBufferToWorkerSee http://wiki.workerman.net/Error3
客户端也同时中断了链接, 但尴尬的是worker进程却不会收到onClose消息, 造成服务器一些资源没有被释放, 怎么破呢?
问答我在tp6.0上安装了Workerman，在GatewayWorker原生框架开启服务，但是在tp上通过websocket协议去连接这个GatewayWorker开启的进程连接不到
()
{
$task_connection = new AsyncTcpConnection('websocket://127.0.0.1:9502');
// 发送数据上开启服务的代码：
```php
class Task
{
//设置Worker子进程启动时的回调函数，每个子进程启动时都会执行。public function onConnect($connection)
{
var_dump(1111);
}
//当客户端通过连接发来数据时(Workerman收到数据时)触发的回调函数
public function onMessage($connection, $data)
{
//处理异步任务
// $task_dataWorkerman\WebServer;
// task worker，使用Text协议
$task_worker = new Worker('websocket://0.0.0.0:9502');
// task进程数可以根据需要多开一些
文档SSE
它的本质是客户端发送一个携带`Accept: text/event-stream` 头的http请求后，连接不关闭，服务端可以在这个连接上不断的给客户端推送数据。* SSE 只能传输utf8文本，二进制数据需要编码成utf8后传送；WebSocket 默认支持传送utf8和二进制数据。
* SSE 自带消息类型；WebSocket 需要自己实现。text/event-stream则说明是SSE请求
if ($request->header('accept') === 'text/event-stream') {
// 首先发送一个connection->send(new Response(200, ['Content-Type' => 'text/event-stream'], "\r\n"));
// 定时向客户端推送数据message事件，事件携带的数据为hello，消息id可以不传
$connection->send(new ServerSentEvents(['event' => 'message
问答wm中使用sql更新数据库
在弄聊天室的时候，为什么我在GatewayWorker/Lib/Dd.php下配置我的数据库信息，在Chat/Event.php下的onMessage方法下写添加聊天记录的sql之后，用户发消息没显示呢另外一个问题是，如果想把消息存到数据库，是不是每次发消息都要操作一次数据库呢？谢谢您！
问答异步消息推送
使用Gatewayworker做了一个服务端，使用tcp协议和客户端进行通信，用于推送订单数据给店铺，一个店铺对应一个客户端。在redis中存储客户端的身份标识和client_id，然后thinkphp调用GatewayClient推送数据给相应的客户端。现在问题是这样的，如果某一个店铺**同时**收到了n个订单，Gatewayworker是不是会瞬间将这些订单推送给客户端呢？要想让客户端来得及反应，这时候是不是需要做异步消息队列了，然后设置间隔时间一条一条推送给客户端。或者有更好的解决方案呢？
希望大神可以给予解答，感激不尽！
问答我是API开发的后端，后端发送给前端的消息如何通过gatewayworker发送呀，是在后端代码直接调用GatewayClient这个API就行了吗？
我想实现一个简单的后台点击审核是否通过，客户端实时接收审核成功或失败的消息，我现在遇到的问题是gatewayworker怎么跟后端连接在一起，后端发送给前端的消息如何通过gatewayworker发送呀
问答使用GatewayClient连接GatewayWorker后，用sendToClient发送消息后直接1006
GatewayWorker版本号:3.0.12
Workerman版本号:3.5.19
GatewayClient https://github.com/walkor/GatewayClient/releases/tag/v3.0.13
数据包和网络均正常，中断代码1006，不知道是何原因。
文档二开必读
# webman AI 二次开发必读
> **注意**
> 以下二开文档是基于 webman AI 5.1.0 及以上版本的，如果你的版本低于此版本，请先升级到最新版本。强烈建议新建一个应用插件用来存放二次开发代码，当然也可将二开代码放置于主项目，但是不能直接修改AI的源码，否则升级会导致代码覆盖。接下来的章节都是基于新建插件的方式二开AI，如果你选择将二开代码放置于主项目，代码是类似的，只不过目录及命名空间不同。## 二开原理
为了不入侵AI的源码，我们可以通过以下方法二次开发AI
* 利用中间件更改页面内容(包括插入css、js、html等，下同)
* 利用路由覆盖更改页面内容，也就是将原有路由指向新的控制器* 利用中间件给某些控制器的添加业务逻辑
* 利用事件监听器介入注册、登录、退出、支付、菜单列表、大模型请求、大模型响应、图片生成等事件，完成二次开发
下面的章节将详细介绍以上几种方法。
问答mysql 超过了连接数据 too many connections
#### 问题描述
我这边有五十个物联网项目，架构上使用了分库管理和GatewayWorker框架，因为要求数据实时性高，
所以采用了异步任务去处理，防止堵塞，比如我开启50个异步任务进程。会出现一个项目每个进程new 一次数据库连接。越多项目就越多连接数，这个有什么好的办法吗？
问答给udp客户端发消息
目前服务端是：workerman建udp和websocket服务端，udp连接设备，websocket连接用户侧，udp将收集的数据通过websocket发给用户，websocket实时的和服务器进行交互获取最新数据，webman则提供控制api，需要对设备进行控制的命令用api的形式控制，没有用websocket是因为涉及到第三方等其他因素，相当于是用了workerman全家桶了
#### 已经尝试过的方法xiuwang提出的
```php
$client = stream_socket_client('udp://ip:port'); stream_socket_sendto($client, 'udp数据');
```
，，测试过，这种方案客户端无法收到数据，但现实发送成功
方案二：socket_sendto 方案也测试，客户端也没有办法收到数据
方案三：建立一个异步UDP客户端 [AsyncUdpConnection]、测试过，客户端也无法收到数据
方案四：引入swoole里面的协程UDP客户端，然后指定ip和port发送消息，客户端也没有收到
#### 为此你搜索到了哪些方案及不适用的原因
以上方案不管适不适用
问答发现一个webman的websocket的时候，传输gzip数据，解析数据会出现 gzdecode data error
;
$res = json_decode(urldecode(gzdecode($in)), true);
p($res);
```
可以正常接受解压数据[截图](/upload/img/20220901/0163106fabc26f.png)
但是在webman socket数据就会出问题
gzdecode 出现data error
```
/** {
createTime: 命令发送时间
data:{} 修改的命令
id: "7a" websocket的id
returnMessage: "success"
status: "0" 0告诉前端需要根据data的命令修改 1无意义
type: 0：连接成功，1：发送给当前连接的用户，2：发送信息给其他用户，3：发送选区位置信息，999：[截图](/upload/img/20220901/0163106f4f27bf.png)
目前怀疑是 回调的onMessage $data数据返回有问题导致无法正解析
2022年9月21日09:52
问答关于一个进程的问题，我不是很明白，求解答。
比如在电脑端打开了websocket连接,这个框架返回一个进程id，接到id后，异步交给thinkphp动态生成一个包含进程id及验证的的二维码,手机扫码,如果点击页面上的确定就会发送数据（包括了进程id但是我这个时候刷新了电脑页面，就会重新请求，分配了一个新的进程id。但是我这个时候才点击手机页面上的确定发送数据（数据包含的是原来旧的进程id），发现能通过 !Gateway::isOnline() 这个判断，说明这个旧的进程还是在线的,原来旧的进程id并没有立即消失。现在我是通过心跳来进行验证进程在线与否。我想问一下当刷新页面时，能不能不分配一个新的进程id而继续用原来的进程id,或者说有什么解决办法吗？
问答压力测试GatewayWorker的并发连接结束后，其中一个gateway进程cpu一直长期100%
#### 问题描述
生产环境是2台16核32G的配置，按照手册分布式部署，配置gateway进程16个，和worker进程数100个，
使用压力测试系统并发2000个链接，只链接，不发送业务处理。在压力测试下，gateway进程cpu个别跑满，其他的也大都在70%，压力测试关掉后很长一段时间，有一个gateway进程cpu始终100%，其他gateway进程cpu基本回落到0，该状态下，业务系统可以正常链接上gateway，但是发送数据无法被接收到。我们之所以做这个压力测试，是为了复现我们业务异常并发下，也同样导致了gateway的某个进程cpu跑满，而其他进程都很空闲，不知道是什么原因，而业务系统处于无法收发的状态下。
问答TCP连接单次握手2组数据
连接服务器
客户端第一次数据传输确认设备
服务器回馈确认
客户端第二次数据传输设备定位信息
服务器做插入处理
连接关闭
请问在第二次传输的时候，怎么可以获取到第一次传输的数据呢 ？或者用什么方式保存第一次传输的数据
问答作为一位CV工程师，使用此框架太难了
# 来个好心的大哥指教一下啊~
#### 问题描述
我在webman里安装了GatewayWorker，使用时候不知道怎么将在onMessage接受到的数据转发到控制器里去做逻辑处理。#### 为此你搜索到了哪些方案及不适用的原因
就好比说GatewayWorker手册里面-》与webman结合时，没有示例，提示如需使用mysql redis等组件参考webman手册，但是去webman手册里，根本没有如何使用GatewayWorker的手册，我太难了
#### 其他解决方案
搜索答案的时候有看到说将接收到的数据发送给前端，让前端以ajax方式再将数据发送到后端，这样合理吗？感觉有点麻烦，gatewaywork里没有内置的方法直接转发到后端控制器里吗？
问答GatewayWorker
初学者，请教几个问题
1.GatewayWorker中，假如开启了5个BusinessWorker进程，此时有10个客户端连接上来，
每个work进程维持2个连接，假如每个连接都需要进行数据操作，此时每个server端通过 websocket 建立连接，
用户完成一个操作，触发一个 消息推送 事件，我在框架里面是把
GatewayClient\Gateway 这个文件加入到了框架内部，然后在web后端(也就是框架内部)，通过
GatewayClient\Gateway 去推送消息，确实并没有经过Events.php ，也就是如文档中所说
“GatewayWorker不处理任何业务逻辑，GatewayWorker仅仅当做一个单向的推送通道”，
感觉这样的话，GatewayWorker 作为server端，只是起到了，开启进程，监听端口，相当于一个中转站的作用
作为辅助 web端 的一个角色，不知道这样理解，是否正确端保存上传的图片，这样的功能，应该如何操作呢
前端页面js/后端server端，不知道是不是跟传统的web应用开发 类似
5.顺便问下，PHPSocket.IO 跟 workman ，还有 GatewayWorker
问答workerman 后台进程在，但是statistic里面无数据
workerman 后台进程在，但是statistic里面无数据，有数据请求过来。求解决在在线等
赞助商
