问答请问如何做到接收http请求，推送mqtt消息？
connect();
};
$worker->onMessage = function(TcpConnection $connection, $args)
{
global $mqtt;
// 已经处理请求数此处报错
$mqtt->publish($topic, json_encode($data));
$connection->send('Status Code: 200 OK');
// 如果请求数达到mqtt->close();
Worker::stopAll();
}
};
Worker::runAll();
```
业务大概是：需要一个http服务端用来接收http的请求，拿到数据经过处理以后，在用mqtt进行推送。服务端启动时不会报错，但是当进程达到设定好的5000次执行关闭并重新开启的时候，由于mqtt还没连接上，就收到http请求并且执行mqtt->publish()了，导致mqtt报错，No connection
问答workerman TCP客户端发送服务端 单包大小问题
TCP 客户端发送服务端单包25316个字符
接收端 有时候 收到时一包 有时候收到时两包 请问怎么解决 ？
只能分包吗？
问答关于客户端获取返回数据
假设gatewayworkerman服务叫a，客户端c1连接到a上向另外一个连接到a的客户端c2发送了一个消息，c2接收到该消息后去执行一段业务逻辑，然后返回结果如何给c1返回去啊？
问答超大数组update数据库，采用什么方案比较好呢？
#### 问题描述
mysql里面有个字段用于存放用户的数据，每个用户都会增加一个json数组，例子：100个用户，就有100个json数组，
```php
[{"uid":1646,"nickName{"uid":1646,"nickName":"微信大sss号"}，{"uid":1646,"nickName":"微信大sss号"},................]
```
方案1：每个用户新增数据都是取之前的数据【弊端】实际测试我的业务，当达到140多人时，text类型已经存不下了，然后改成longtext，当达到500人时（500个json数组），更新速度越来越慢，I/O应该很高（读写）。userInfoJsonStr = json_encode($userInfoJson, JSON_UNESCAPED_UNICODE);
//单独用户uid
$uid = $userData['id'];
//数据库前缀$edit_id;
```
#### 为此你搜索到了哪些方案及不适用的原因
user_data存放超大json数组（只关注这个字段）
!
问答关于判断一个请求的head头是否发送完毕\r\n\r\n的问题
在workerman中，监听一个http地址，源码Protocols/Http.php中有判断请求的headr头是否发送完毕的方法
[attach]1462[/attach]
但是如果我指定一个head头的值为\r\n\r\n，然后却判断不出来，还是在head头发送完毕的\r\n\r\n中将strpos($recv_buffer, "\r\n\r\n")判断成了true
nginx和socketn\r\n都不行
[attach]1463[/attach]
请求方法
[attach]1464[/attach]
workerman中的模拟方式类似，只不过将fread函数的大小调成了
问答$gateway->count 进程数不支持WINDOW服务器吗
$gateway->count 进程数不支持WINDOW服务器吗
问答找不到数据库Unknown database 'test_park'
#### 问题描述
带下划线“_”数据库名“test_park”的数据库识别不了，无其他符号的数据库“test”识别成功,两个数据库配置一样
#### 程序代码
数据库设置
```
return[
// 默认数据库
'default' => 'mysql',
'connections' => [
'mysql' => [
'driver
问答【市场】数据导出系统 问题反馈
用于收集市场中[数据导出系统](https://www.workerman.net/app/view/export)用户所遇到的问题
问答救命啊，同样代码Linux和window处理不同
，方便内部系统推送数据，Text协议格式 文本+换行符
$inner_text_worker = new Worker('tcp://0.0.0.0:5678');
$inner_text_worker，向uid的页面推送数据
$ret = sendMessageByUid($uid, $buffer);
// 返回推送结果
$connection->send($ret$connection->uid = $data;
/* 保存uid到connection的映射，这样可以方便的通过uid查找connection，
* 实现针对特定uid推送数据connection->uid))
{
// 连接断开时删除映射
unset($worker->uidConnections);
}
};
// 向所有验证的用户推送数据，向uid的页面推送数据
$ret = sendMessageByUid($uid, $buffer);
// 返回推送结果
$connection->send($ret
问答gateway两个通信协议的问题
现在项目需要用到两个协议，一个是http，一个是自定义的json，因此有两个gateway，一个负责监听http，一个负责监听json，而我的需求是，当http有发送数据时，将这个数据转为json，然后转发到连接json gateway的客户端，但现在发现http发过来的数据会调用http的gateway，转发给json客户端时发送时client_id显示为空，我感觉是这个client_id是保存在json的gateway那里的，所以http的gateway不能获取到，请问怎么让http的gateway监听到数据时能够转发到json上的客户端连接？？
问答gateway中的http和json两个协议共用的问题
现在项目需要用到两个协议，一个是http，一个是自定义的json，因此有两个gateway，一个负责监听http，一个负责监听json，而我的需求是，当http有发送数据时，将这个数据转为json，然后转发到连接json gateway的客户端，但现在发现http发过来的数据会调用http的gateway，转发给json客户端时发送时client_id显示为空，我感觉是这个client_id是保存在json的gateway那里的，所以http的gateway不能获取到，请问怎么让http的gateway监听到数据时能够转发到json上的客户端连接？？
问答workerman有主动发起websocket链接的方法吗？
我现在的需求是后台管理员触发某个操作之后会给客户端指定用户或者所有用户推送一条消息。我是个新手，用的是wokerman，没有用gatewayWorker，我看网上的解决方案是：
https://wenda.workerman.net/question/508
我用了上面的代码，但是发现了一个问题直接链接到我的主websocket服务，然后向某个用户推送，现在函数：
stream_socket_client 好像只能使用tcp协议，不能使用 websocket 协议。
问答businessWorker进程和客户端的关系
businessWorker进程对应多少个客户端？我看手册说onworkerstop在进程生命周期内都只会触发一次。那么心跳检测的时候是如何触发这个函数的呢。如果触发了是否意味着相应的businessWorker进程已经结束了？
问答请教下获取数据格式规范
#### 问题描述
大家在用ORM获取列表的时候需要关联数据，需要对数据遍历格式化吗
比如需要关联设备表获取设备名称
模型关联
"process": {
"id": 1,
"name": "
问答socketIo 发送消息为 字符串go的时候报错了
#### 问题描述
如图 发送消息goo都没问题 ，发送为go就报错了。无意间测试聊天发现的。
问答socket客户端的心跳数据处理问题
现在我用workerman搭建了一个socket服务端,client.php客户端作为微信公众号的地址，现在服务端有个心跳检测，数据是{"type":"ping"},我建立了长连接后接收服务端的socket数据，我这样写的：
```php
$in = '{"type":"test"}';
$out = '';
if(!http_text($FromUserName,$ToUserName,$infoStr);//回复微信消息
socket_close($socket);
```
在while循环那里一直接收心跳数据，下面的回复微信公从号的信息无法执行，导致公众号无法服务，怎么能避免接收心跳数据呢？
问答web-admin 数据添加 updated_at 和 created_at 时间不对
#### 问题描述
新建 的一张表 有 created_at 和 updated_at 字段 用于保存 创建时间和更新时间 ,添加数据的时候就突然会出现 这两个 时间 有会 8 小时相差问题，看截图[截图](/upload/img/20231129/296566de313ee5.png)
数据从页面提交时间 都是晚上 10点 左右
插入数据库生成的sql语句 里面的时间就变成了中午2点多。
其他插入的数据时间
#### 程序代码或配置
时区配置没有变过，一直都是默认的
```
'debug
问答workerman 发送接收socket包，一个包的上限是多少字节呀？
workerman 发送接收socket包，一个包的上限是多少字节呀？求大佬们告知。
问答自定义进程，如何自动消费
deleteMessage($receiptHandle);
pcntl_signal_dispatch();
}
}
```
二：receiveMessage(30);
print ($res->getMessageBody());
//一堆事务数据库操作receiptHandle);
pcntl_signal_dispatch();
}
}
```
三、请问是“ //一堆事务数据库操作
赞助商
