问答定制协议错误数据清理问题
我自定义了一套协议,采用的TCP传输方式,协议主要作用是判断数据完整及有效性并进行初步处理转换成一个对象提交到ONMESSAGE里面去处理.现在有一个问题,当我在INPUT里面判断出来BUFFER里面的数据帧头是错误的,不符合我的协议规范要求,这时我需要将BUFFER清空并返回0,表示清空缓冲区,不调用DECODE并等待下一帧数据的到达.测试直接设置BUFFER=NULL无效,下一帧数据到达时会加上之前错误的数据,如果RETURN整个数据的长度又会触发DECODE及ONMESSAGE,这样我需要在后面两个回调里面再次去判断有效性,有点浪费资源.我希望数据到DECODE就已经是有保证的有效性的数据,不知道这个有什么好的解决办法?
问答gatawayworker接受TCP客户端发送过来的数据，总大小7K左右，怎么才能一次性将内容读取出来
现在再写一个项目，再项目中客户端会给服务器发送差不多7000字节的数据到服务器，但是每次服务器都收到N个分包，导致数据错乱，原因是有N个客户端同时给服务器发送数据。请问一下，有什么方法让服务器能够一次性将所有的数据都读取出来
问答请问在mvc中调用GatewayClient发送数据前，有方法判断GatewayWork是否正常吗？
请问在mvc中调用GatewayClient发送数据前，有方法判断GatewayWork是否正常吗？比如没启动，或者registerAddress错误连接不上之类。在GatewayWork没启动时，调用GatewayClient发送数据会因为连接不上registerAddress产生致命错误，请问有什么方法可以先做判断吗？还是只能写在try里做异常处理？
问答刚开始学gatewayworker，下载了一个案例是在前端页面用jquery发送send数据，请问send写在php代码中应该怎么写啊，有例子吗
谢谢大神分享一段php代码发送数据的参考
分享【限流插件】控制API 进行速率限制限流，防止暴力攻击
限流类（Throttler)提供了一种非常简单的方法，可以将用户要执行的活动限制为在设定的时间段内只能进行一定次数的尝试。这最常用于对 API 进行速率限制，或限制用户针对表单进行的尝试次数，以帮助防止暴力攻击。 该类可用于你根据设置的时间来进行限制的操作。插件地址： https://www.workerman.net/plugin/36
限流类
* 全局中间件，整个应用接口限流，
* 路由中间件，某些功能接口请求速率限制
缓存依据的是`Support\NspTeam\WebmanThrottler\Middleware\ThrottlerMiddleware::class,
]
];
```
> 你也可以启用路由中间件，控制接口请求速率限制
问答SSE 能否用在控制器发送，有参考案例吗
#### 问题描述
SSE 能否用在控制器发送
#### 为此你搜索到了哪些方案及不适用的原因
能发参考出来吗
!
问答A用户发起http请求，服务器发起ws获取客户端B数据，收到B数据后回复给A
#### 问题描述
1、A用户发起http请求，
2、http服务端，通过调用让Gateway的ws服务端向ws客户端B发送请求，
3、ws客户端B收到数据后，发送回复给ws服务端，
4、ws服务端收到数据后，让http服务器响应A的http请求
请问怎么实现，ws过程是异步的，好像A用户的http请求处理过程必须有等待，类似sleep来等待ws通讯完，才能拿到数据响应给A。#### 想到的方案
A用户也发起ws数据，这样大家都异步了，有个标识符，来回传就行了；还有其他出路吗？有没有什么方案、插件、工具，可以让A用户的请求挂起不堵塞，收到ws数据后，在响应A的http请求
问答GatewayWorker有没有根据client_id获取Group的接口
GatewayWorker有没有根据client_id获取Group的接口？比如群聊，不想从web端带一个groupId过去，也不想用GatewayClient进行推送,文档那里没写有
问答并发请求第三方同步数据问题
#### 问题描述
我们本地数据库data_account表大概有个2W个账号，其中账号有个认证状态，和使用数据量需要同步第三方数据(分别叫做接口A和接口B)，现在我需要每1分钟都去同步这2W个账号的认证状态和对应账号的数据使用量，然后更新数据到本地mysql数据表。第三方有限制并发请求不能超过50。#### 为此你搜索到了哪些方案及不适用的原因
百度了一圈，都是建议用Go之类的，因为不懂Go，然后大概用了下别人python代码(每次并发50)，发现老是出现:2013 (HY000): Lost
问答gatewayworker两个连接间通讯问题
问题描述：我做了一个这样的项目，这个项目目前已经做到了这两个部分：1.单片机控制传感器采集数据，并利用网关模块（通过互联网）将数据发送到云服务器。 2. 用户可以在网站上查看上传到服务器的数据。 现在我想让用户通过网站，比如在网站上点击某台设备对应的“采集数据”这个按钮 ，那么下面对应的单片机，进行数据采集。要实现这个功能，那服务器端应该在收到网站上用户请求的时候（通过用户和服务器之间的连接），找到相对应单片机的client_id,通过这个id发送数据给单片机，让单片机采集数据。我考虑了一下 单片机连接到gatewayworker以后用全局变量保存这个单片机的client_id。之后用户有请求就直接通过这个id向单片机发送数据。
问答TCP客户端发送数据很大，服务端接收时被拆分成多条，应该如何处理成一条？
客户端发送数据如下：
服务端接收数据如下：
请问服务端应该如何组装数据，或者说怎么处理成一条
问答gateway向硬件发送,第一次是成功的,第二次发送会自动断开(有检测心跳)
第一次发送成功的,硬件也能返回指令,但是当再次发送命令的时候,根据getClientIdByUid获取设备的uid却发现设备已断开(心跳检测是加了的),但是当差不多10秒后,设备又自动连上了,期间并没有触发
问答webman response能否增加一个功能，发送响应之后继续执行操作
目前有新项目在考虑用webman，之前都是swoole，有一个用法在webman好像没看到支持，但是在我们的实践中挺有用的，就是控制器在执行必要的操作之后，返回数据给前端，然后可以继续执行一个稍微慢一点的动作，比如发送验证邮箱或者短信等等，这些可以用自定义进程实现，但是额外起自定义进程又没必要
比如是否可以实现这样
```
$response = response();
// ....业务逻辑
// 设置http头
$response->header('Content-Type', 'application/json');
// 设置要返回的数据
$response->withBody('返回的数据');
// ### 提供一个类似的方法，可以结束响应，尽早给反馈给前端
$response->end();
//其他慢任务，如发送验证邮件
Mail::sendVerification
问答打二进制包后忽略的文件放在同目录不会引用?
#### 问题描述
打包二进制很好用,忽略了.env直接就可以放在同目录下自动引用了
我继续忽略了app/home/view目录想在外部允许修改模板,然后把app目录放在bin同目录下,访问报错
或者能否
问答Gateway主动向客户端发消息的字符串转十六进制出错
Gateway::sendToAll(pack("H*","55AA0405000403500A00A3"));
```
我使用sendTOall来测试并且用pack将字符串转为了十六进制[截图](/upload/img/20230208/0863e31cfbd6b3.png)
在使用socket工具接收服务器主动发送的消息的时候发现 接收的消息后面有个“U?”请问这个是什么意思，应该怎么解决，
##方案
另外想请问一下 ，关于使用Gateway转十六进制 应该怎么操作，求大佬赐教，小白一个
问答workerman 中udp的问题
自己查找了资料，看的有点懵逼不太了解
# 疑问：
## 一 、 udp的校验和
我看一些文章udp在ip层内已经做过校验和了，那么是不是在构建通信数据的时候就不需要做校验和这一步操作了？## 二 、 udp的发送报文形式
udp是报文发送的，那么是不是就是我的每个sendto操作都是一个报文发送，客户端都需要接受一次，不需要像数据流那样规定包头来获取数据的长度？（之前写一个TCP 的项目）
udp构建JSON数据后转十六进制数据，为什么要这样操作呢？（有大神的请详解下或者给个讲解链接，万分感谢）
大小端问题：php的bin2hex转16进制是大端转换，解析也是unpack（'H*',$data）解析，那么要求客户端构建数据后使用16进制大端发送就行了是吧## 三 、 udp的重发机制
udp是无顺序的且会丢失数据的，我构思的是在udp发送需要时，如果客户端收到的是有缺失帧序号的那么就发送信息到服务器，要求服务器重新发送这一帧的数据。
文档在其它项目中主动推送消息
# 在其它项目项目中主动推送消息
## 需求
有时候需要在非GatewayWorker环境中向客户端推送数据。例如在一个普通的Web项目中通过GatewayWorker推送数据（前提是已经部署了GatewayWorker，客户端已经连接GatewayWorker）。目前有三种比较方便方法推送数据。- 通过GatewayClient发送的数据不会经过Event.php，而是直接经由Gateway进程转发给客户端。
- GatewayClient无法接收客户端发来的数据。用一个特殊的账号当做管理客户端，通过这个账号推送数据
此方法通俗易懂，可以通过现有客户端直接操作，具体代码根据自己的业务实现
## 方法三、开启一个内部Gateway端口，用于推送数据
方法二虽然简单$client)exit("can not connect");
// 模拟超级用户，以文本协议发送数据，注意Text文本协议末尾有换行符（发送的数据中最好有能识别超级用户的字段），这样在Event.php
问答在webman中可以直接调用GatewayWorker的接口进行推送吗？
现有项目是基于TP6+GatewayWorker，在TP6中需要进行推送时是通过GatewayClient来完成的。目前有部分接口用webman来写的，那在webman中需要推送时是不是还需要通过GatewayClient来完成。如果是通过在webman中安装GatewayWorker插件来起的服务，是不是就不需要通过GatewayClient，可以直接调用呢？目前不知道怎样直接调用。
问答gatewayworker如何群发指令到部分设备端
问题需求：群发指令到部分设备端
解决思路：将该部分设备分组，然后利用sendtogroup群发指令
疑问1：对设备进行按需分组，请问是需要通过客户端发送含有标志性字符的指令，比如“group：team”，然后gatewayworker通过该标志性字符来将其对应的clientid加入team组中吗？如果客户端发送的指令没有标识符，在服务端的gatewayworker是不是就无法按需分组了？疑问2：我的所有指令都含有设备id，如果客户端发送的指令中没有标识符，服务端要实现分组，是不是需要通过自己来筛选指定id加入分组？疑问3：在客户端通过将指定设备放入数组，然后用for等循环语句遍历数组，并向对应设备逐一发送指令，这样会对系统造成影响吗？
问答如何建立一个内存数据中心
因为workerman是多进程模型 所以在操作同一数据源的时候会才是数据不一致的问题，这时候就需要用到锁的机制。楼主是否可以个解决方案，比如 多进程的时候 如果 制定一个 内存数据中心(可以是php作为自身内存操作)然后所有请求都通过内存数据计算，再延迟写入mysql ，保证数据的一致性
赞助商
