问答webman包含GatewayWorker吗？
想问一下 webman 内 是否 包含了GatewayWorker的功能
分享基于webman + layui 重构的admin管理后台
- [x] `公司管理` 设置公司常用信息，前端标签调用
- [x] `部门管理` 配置系统组织机构（部门、小组），树结构展现支持数据权限。
- [x] `岗位管理` 配置系统用户所属担任职务。- [x] `角色管理` 角色菜单权限分配、设置角色按机构进行数据范围权限划分。
- [x] `插件管理` 可开发定制属于自己的插件，可安装升级社区插件！！！- [x] `数据字典` 对系统中经常使用的一些较为固定的数据进行维护。- **插件开发** 支持自定义插件开发，可定制自己的插件，并支持一键打包/升级/测试。执行命令：php start.php restart # 重启开发服务
守护进程：php start.php start -d # 启动守护进程 一般为生产环境/修改文件后无法自动重载
问答未执行完成的定时器 在接受新的信息的时候会重置？
[截图](/upload/img/20221215/15639a9ffc6865.png)
代码如上 业务流程是 设备登录后 数据库返回设备没有接收到的指令 间隔5秒发送一回 发送给设备 让设备执行指令现在的情况是 设备登录后 要接收2条指令 大约10秒钟 可是如果在这10秒内发送消息给服务器 测试发现 应该发送的指令会重置 重新重第一条在发送 给人的感觉是定时器重新开始运行了
我在想
问答GatewayWorker 如何使用rabbitmq
请问 GatewayWorker 如何使用rabbitmq？
文档Redis队列
'db' => 0, // 数据库
'max_attempts' => 5, // 消费失败后，重试次数重试次数通过参数 `max_attempts` 控制，重试间隔由
`retry_seconds` 和 `max_attempts`共同控制。它不保证消息%100送达redis。如果进程重启，恰好本地内存队列里数据没有同步完毕，会造成消息丢失。`Client::send()`异步投递适合投递不重要的消息。异步投递首先会将消息保存在本地内存中，当进程空闲时将消息发送给redis。如果redis接收速度慢于消息生产速度，或者进程一直忙于其它业务没有足够的时间将内存的消息同步给redis，就会导致消息挤压。
问答workbunny/webman-rabbitmq 只推送不消费进程 不会自动创建交换机吗?
#### 问题描述
只推送不消费进程 不会自动创建交换机吗?
分享让windows开发支持代码热更新，workerman-filemonitor for windows
workerman-filemonitor只能用于linux，但是我们平时开发都是用的windows。基于workerman-filemonitor二次修改，可完美实现windwos开发时的代码热更新。经过测试，windows下不能直接在filemonitor启动的进程中获取我们需要的父进程，所以需要在你启动的gateway文件中添加如下代码（该代码一定要放在Worker::runAll()之前）Timer::add($this->_interval, [$this, 'monitor']);
}
};
}
//监听器，kill进程
问答webman 怎么向某个client_id对应的连接发消息
原来gateway 有指定client_id 发送，webman里怎么指定
public static function onMessage($client_id, $message)
{
Gateway::sendToClient($client_id,'已经发送,正在断开');
}
问答微信模板消息大批量群发
#### 如何使用workerman进行微信模板消息的推送？
微信小程序有10万人订阅了活动通知，比如这些人要在9点收到活动的通知消息。如何及时的推送消息呢？
分享Workerman 自定义的协议如何解决粘包拆包
Input 方法
在这个方法里，可以在服务端接收前对数据包进行解包，检查包长度，过滤等。返回 0 就将数据包放入接收端的缓冲内继续等待，返回指定长度则表示取出缓冲区内长度。2. encode 方法
该方法是服务端在发送数据包到客户端前，对数据包格式的处理，也就是封包，这个就要前后端约定好了。只是根据 TCP 的一套拥塞算法机型粘合或拆解的发送。所以从字面上看，粘包就是几个数据包一起发送，原本应该是两个包，客户端只收到了一个包。粘包测试
只需要在客户端模拟两个数据包连在一起，但是要以 #分隔，看看服务端接收的时候是一几个包进行处理的。
!拆包测试
拆包模拟只需要将一个数据包分成两次发送，看看服务端接收的时候能不能显示或者说能不能按约定好的格式正确显示。
!
问答think-orm读mongo数据webman/log报错
#### 问题描述
think-orm 读取 mongo 数据时，webman/log报错
#### 报错信息
```
#18 {main}Error: Call to undefined method
问答使用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
文档__construct
AsyncTcpConnection可以让Workerman作为客户端向远程服务端发起异步连接，并通过send接口和onMessage回调异步发送和处理连接上的数据。'/vendor/autoload.php';
$task = new Worker();
// 进程启动时异步建立一个到www.baidu.com连接对象，并发送数据获取数据
$task->onWorkerStart= function($task)
{
// 不支持直接指定http，但是可以用tcp模拟http协议发送数据
$connection_to_baidu = new AsyncTcpConnection('tcp://www.baidu.com:80');
// 当连接建立成功时，发送http请求数据
$connection_to_baidu->onConnect = function，可以通过判断$worker->id来做到，例如下面是只在0号进程发起连接
if ($worker->id !
问答workerman调用bindUid uid和client_id映射的数据保存在哪里呢？没找到
workerman调用bindUid uid和client_id映射的数据保存在哪里呢？
问答GatewayWorker 的一些理解
我本来打算自己弄一个的 但是群里有人说 GatewayWorker 已经实现了
所以就 看了一下官方文档 以及代码
目前的疑惑 不是很大 大佬可以给些建议
### 注册(Register)
我感觉但是感觉在注册中心实现感觉更合理 (可能会导致负载 或者攻击 2233)
网关的IP+端口 这些信息客户基本是未知的 感觉注册 那边地方可以提供给客户相当于(DNS服务器)
然后客户得到 网关的IP+端口 进行访问服务$客户映射表[客户ID]=['处理进程ID'=>$BusinessWorkerID','客户其他信息....'];
一个用户5KB 内存
3000W 用户占用内存 需要150GB 如果 单机1-5个以上网关相当于150GB*5=750GB
如果用户数量10W 完全不用担心内存问题
问答望各位吴彦祖们给予思路【webman】
1、类似一堆字典信息，想法是通过service加载，在service中定期更新，然后不同进程通过service来调用这些数据。尝试把方法放在container中，但发现container是根据worker数量来一一对应的，如4个worker的话就会有4个container，但实际我只需要1个进程维护字典信息并提供接口读取。2、通过redis_queue把日志内容写入数据库中，但发现数据能写入，但是status里的redis_consumer的total_request达到2800+，但数据库中只有几条记录，php start.php
问答workerman怎样给指定硬件终端推送信息？
**网页设置下发消息给某终端，那么服务器怎样把要下发的信息推送给指定的终端？**
问答crontab 如何调用控制器方法
public function onWorkerStart()
{
new Crontab('1 * * * * *', function(){
//如何调用控制器
问答guzzle 并发5个请求 可以设置间隔时间吗？
#### 问题描述
这里写问题具体描述
想实现
1 第一个请求出去 3秒后 再第二个请求出去 依次下去
2 每个请求返回时间大于5秒
3 使用 Promise\unwrap($queue)实现并发
赞助商
