问答woker定时任务定时取redis队列取数据，然后插入到mongodb中，但是会有一定规律性的出现无法插入的问题
woker定时任务定时取edis取队列数据，然后插入到mongodb中。当redis队列长期没有数据的时候，然后又在队列里新增一条数据，workerman的定时器取出来后却没有插入到Mongodb中，再次在队列中放入一条数据后，workerman的定时器取出队列的数据后又能插入到例如：今天早晨我队列中没有数据，当提交一条数据到队列中后，定时器一执行便将队列中数据取出，但是这一次并没有插入到Mongodb中，不过接下来再次提交数据到队列中后，就不会出现这个问题了。
问答如何用dd或dump获取到查询构造器生成的sql语句
在控制器中用
Db::table('part')->where('id','>',6)->get()->dump();
只是在控制台输出了获取到的数据，并未看到SQL语句的输出
问答tcp短线重连时候不能正常连上gatewayWorker
环境：客户端实行心跳检测，并正常绑定了uid='A',假设client_id='00000a',
条件：当网线断开或其他因素不能正常发送心跳时，先close（原来的fd），在重新connect服务器，时候，发现gateway没有执行onConnect，但是能够正常执行onMessage，并再次bindUID='A'，(并且已经分配到新的client_id='0000000b')问题是
当其他硬件想通过uid='A'发送给我的客户端设备时，却告知client_id='00000a'，已经掉线，为什么不能直接发送给断网重连后的client_id='0000000b0呢'？
问答GatewayWorker 的一些理解
我本来打算自己弄一个的 但是群里有人说 GatewayWorker 已经实现了
所以就 看了一下官方文档 以及代码
目前的疑惑 不是很大 大佬可以给些建议
### 注册(Register)
我感觉但是感觉在注册中心实现感觉更合理 (可能会导致负载 或者攻击 2233)
网关的IP+端口 这些信息客户基本是未知的 感觉注册 那边地方可以提供给客户相当于(DNS服务器)
然后客户得到 网关的IP+端口 进行访问服务$客户映射表[客户ID]=['处理进程ID'=>$BusinessWorkerID','客户其他信息....'];
一个用户5KB 内存
3000W 用户占用内存 需要150GB 如果 单机1-5个以上网关相当于150GB*5=750GB
如果用户数量10W 完全不用担心内存问题
问答wokerman think-worker 内存一直增长
TDengine
服务器每天接收 来自Mqtt的中转Http消息大约3500万条（腾讯限制只能发http了，其它收费较高）
使用 workerman 开启http服务 开启12个进程
将收到的数据插入到TDengine时序数据库，保存最新的一条数据至MySQL数据库。将进程改为48个进程后问题依旧，只是增长的速度慢了一点而已。时间长了之后还是一样的。
问答同时做了监听http 和 websocket 为何 onmessage方法的参数不同
前任留下的代码
这里起了一个监听 http 的服务 通过 php脚本去发送请求 onmessage 回调方法的参数是一个连接
websocket 的 onmessage 的参数是 clientid
!
问答用定时器调一个函数，但是报错了，大佬帮忙看下，谢谢！！！
我这个函数是用来向服务端发消息的，用的是php自带的socket,我是想每隔5分钟向服务端发送一个消息，所以就想用workerman的定时器来实现，但是现在报错了，郁闷！！！
分享Workerman 自定义的协议如何解决粘包拆包
Input 方法
在这个方法里，可以在服务端接收前对数据包进行解包，检查包长度，过滤等。返回 0 就将数据包放入接收端的缓冲内继续等待，返回指定长度则表示取出缓冲区内长度。2. encode 方法
该方法是服务端在发送数据包到客户端前，对数据包格式的处理，也就是封包，这个就要前后端约定好了。只是根据 TCP 的一套拥塞算法机型粘合或拆解的发送。所以从字面上看，粘包就是几个数据包一起发送，原本应该是两个包，客户端只收到了一个包。粘包测试
只需要在客户端模拟两个数据包连在一起，但是要以 #分隔，看看服务端接收的时候是一几个包进行处理的。
!拆包测试
拆包模拟只需要将一个数据包分成两次发送，看看服务端接收的时候能不能显示或者说能不能按约定好的格式正确显示。
!
问答使用redis异步订阅，出现的问题，求大佬指点
worker exit with status 65280
```
服务端代码如下：
```php
// 当$sender_io启动后监听一个http端口，通过这个端口可以给任意uid或者所有uid推送数据uidConnectionMap;
if ($uidConnectionMap) {
$value = json_decode($message, true);
$data = ;
// 在编码数组里，就进行发送
$code = $data;
if($code){
//$sender_io->emit('data', $data);
$sender = $sender_io
问答如何获取Socket的消息头和消息体的长度，把这个消息协议给客户端.
[](//www.workerman.net/upload/20210817/17611b70546cee.jpg)
我需要知道这两个参数，但是后台不知道，只能我自己查了。我看了Websocket这个类，试了几个参数但是还是不行。
客户端现在是可以连接，但是发送数据什么的都解析异常，原因就出在这里。
问答gateway 进程模型
[](http://www.workerman.net/img/GatewayWorker.png)
上图中，worker3从gateway2 收到信息，怎么会从gateway1 进行信息转发？上图中，worker3从gateway2 收到信息，怎么会从gateway1 进行信息转发？难道是gateway1 和 gateway2 保存的都有client1-8 的信息吗？
问答webman包含GatewayWorker吗？
想问一下 webman 内 是否 包含了GatewayWorker的功能
问答未执行完成的定时器 在接受新的信息的时候会重置？
[截图](/upload/img/20221215/15639a9ffc6865.png)
代码如上 业务流程是 设备登录后 数据库返回设备没有接收到的指令 间隔5秒发送一回 发送给设备 让设备执行指令现在的情况是 设备登录后 要接收2条指令 大约10秒钟 可是如果在这10秒内发送消息给服务器 测试发现 应该发送的指令会重置 重新重第一条在发送 给人的感觉是定时器重新开始运行了
我在想
问答think-orm在webman2.1使用mongo数据库bug
#### 问题描述
think-orm在webman2.1使用mongo数据库出现TypeError: think\db\connector\Mongo::query()
#### 程序代码
```
文档快速开始
开发者也可以参考[使用其它数据库组件](others.md)章节使用ThinkPHP或者其它数据库。## 关于连接池
* 每个进程有自己的连接池，进程间不共享连接池。
* 不开启协程时，业务在进程内排队执行，不会产生并发，所以连接池最多只有1个连接。* 开启协程后，业务在进程内并发执行，连接池会根据需要动态调整连接数，最多不超过`max_connections`，最少不小于`min_connections`。* 因为连接池连接数最大为`max_connections`，当操作数据库的协程数大于`max_connections`时，会有协程排队等待，最多等待`wait_timeout`秒，超过则触发异常。## 数据库使用示例
```php
<?
问答stomp队列插件 推送消息不起作用
[截图](/upload/img/20220927/27633274fe5f9c.png)
出现图里面的错误 发送不起
问答服务端推送消息客户端接收不到
#### 问题描述
这里写问题描述
服务端onClose接收到消息了， 但是还能接收客户端心跳检测，而服务端发送推送消息失败
分享让windows开发支持代码热更新，workerman-filemonitor for windows
workerman-filemonitor只能用于linux，但是我们平时开发都是用的windows。基于workerman-filemonitor二次修改，可完美实现windwos开发时的代码热更新。经过测试，windows下不能直接在filemonitor启动的进程中获取我们需要的父进程，所以需要在你启动的gateway文件中添加如下代码（该代码一定要放在Worker::runAll()之前）Timer::add($this->_interval, [$this, 'monitor']);
}
};
}
//监听器，kill进程
问答关于gatewayworker中使用redis
$user_list = array_values($user_list);
});
```
使用redis的时候zRange 在测试服务器上可以正常获取到数据没有数据也会返回空数组
问答新建一个worker服务，可以单独推送Gateway中连接的用户吗?
请问我启动了一个单独的Worker进程，想推送Gateway中的用户是不是只能在worker进程中使用gatewayClient处理？
赞助商
