问答长连接参数问题！大大帮看看哦！
需要以 websocket 协议链接服务端
发送请求链接的参数如下：
1.4 消息参数类型(HeaderType)
系统中通信的数据，都是放到参数中，各个参数的顺序不固定。目前分为通讯参数和应用参数，通讯参数针对不同的消息类型固定，记录链接标记一些信息。应用参数是CustomType类型，是key:value列表，key是字符串类型，value是系统定义的类型。[attach]249[/attach]
请问大大这里 CustomType类型 参数应该怎么写才对呢。
$connection_to_baidu->send($str);
问答第三方系统调用text协议通信超时
);
var_dump($errno, $errmsg);
// 推送的数据，包含uid字段，表示是给这个uid推送
$data = array('action'=>'sendToAll', 'info'=>'哈哈哈哈哈哈哈');
// $data = array('action'=>'editUser', 'info'=>'哈哈哈哈哈哈哈');
// 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
fwrite($client, json_encode($data)."\n");
// 读取推送结果
$res = fread($client, 8192);
fclose($client); //群发消息
case 'sendToAll':
$user_id::sendToAll(self::format_return_message('message', $message));
break;
```
如上代码，如果去掉判断直接发送给客户端就正常，
问答workerman一个请求被多个进程接收到,重复执行
workerman开了5个进程
客户端发送一次请求，workerman的多个进程接收到消息，执行了onMessage，workerid和connectionid都不一样，这个请求被执行了多次
问答AI 关于文心一言的发送返回提示错误
sent数据
```javascript
{"temperature":0.5,"stream":true,"messages":[{"role":"user","content":"你好"}],"modeluser_message_id":"1697772176902197","assistant_message_id":"169777217690212","role_id":34}
```
对比了跟官网是是一样的
返回数据[截图](/upload/img/20231020/206531f4f57b08.png)
错误信息是 参数校验不合法
!
问答win下如何关闭worker进程
基于workerman-chat-for-win-master例程，在win下编写了控制台程序调用start_for_win.bat，调用时隐藏了bat的cmd窗口。控制台程序运行时能够顺利run wokerman的各个进程，问题是在win下如何统一关闭wokerman进程？
请大神们讲解一下。
问答执行数据库迁移命令时报错
#### 问题描述
执行数据库迁移命令时报错，有大神能解惑下吗?创建了几个数据库迁移文件，执行php vendor/bin/phinx status -e development命令后，报如下错误。
如果只保留一个迁移文件，就能执行成功。
问答请问 websocket如何向tcp端口发送信息？
现在需要将网页上的信息发送给设备。请问该怎么做呢？我试着在 TcpServer的onWorkerStart 里建立一个 websocket 的监听，但是不起作用。
问答为啥我用workerman发送给客户端数据的header里面有两个 Content-Type ？
'/runtime/workerman-' . date('m') . '.log';
$worker = new Worker('http://0.0.0.0:8053');
// 启动 2 个进程对外提供服务
问答使用GatewayWorker做直播间聊天
想问一下各位大神：
现在项目做一个直播系统，目前是微信和PC端的，聊天室这块用的GatewayWorker，然后项目采用前后端分离模式，我后台PHP用的TP5前端用的VUE，现在的模式是，没有直接使用GatewayWorker的Enent类，自己用TP5写的接口然后再调用GatewayWorker的接口来聊天，这样做的话，每第一次进直播间就会请求一次bind接口（后台的），然后每次发消息又要请求一次
问答数据库连接默认何时关闭?
咱们的框架数据库连接如果不手动关闭，默认是执行完php文件后自动关闭吗
问答如何在网关服务捕获Gateway::sendToClient()的数据
如何在网关捕获Gateway::sendToClient()的数据
问答手机浏览器熄屏后不能继续发送心跳，或者有什么办法亮屏后重连继续发送心跳
电脑浏览器上没问题，但是手机上一旦锁屏后，就会停止发送心跳，然后就与服务器断开
```html
<script>
var fromid = 98;
var count = 1;new WebSocket("ws://esp8266.b.com:8282");
ws.onopen = function(){
setInterval(show,10000);//心跳发送
问答进程阻塞的问题。客户端请求到返回花费超过30秒
## 问题描述
在线人数多的时候。客户端发送了一个请求。业务处理逻辑只花了`0.1353秒`。
但是客户端发送过来的时间到返回时间总得却花费了接近`10万毫秒`。从进入 onMessage 到 send 时间是比较短。但是在客户端发送请求，到调入到onMessge里却等待了`超过1分钟`.
请问是什么原因导致的？是我用法不对还是什么原因？
问答使用webman-shared-cache共享缓存，定时上报大并发时,上报进程busy
#### 问题描述
**需求：**
使用webman提供一个http服务，接收大量的请求（1000w+/天），并将请求根据请求中的参数task_id存储到apcu共享内存中，由新开的进程定时获取共享内存种的数据**问题：**
开了10个上报进程，每个上报进程每10秒会调用Cache::search()获取需要上报的任务，然后加锁此任务，对该任务下的数据进行上报，上报完成后释放任务锁。随着程序启动时间越长，上报进程会出现busy的情况。此时重启上报进程会恢复[idle]状态，持续一天时间，相同的业务量继续出现busy的情况。tenantId, $taskId, $messages);
}
}
});
}
```
负载均衡node-1
**两周未重启进程情况为[截图](/upload/img/20240531/3166594be54909.png)
负载均衡node-2
**一天未重启进程情况为:**
!
问答各位吴彦祖们，求限制QPS思路
背景：
对方提供了个产品信息接口，只支持拉操作，限制QPS为20，产品规格和价格都可能实时变化，现在设计思路就是通过Timer把该接口的产品每隔5分钟丢去队列中，再通过队列数量来进行拉取。问题：
队列数量设置为10；curl中配合usleep通过记录上次请求时间毫秒数来计算延迟请求，控制每次CURL相隔500毫秒。但是对方监控中发现，实际请求QPS会达到30多或40，后来通过减少队列数量到5，QPS才保持在20以内，
请问问各位吴彦祖对于这类限制QPS查询频率的有没什么好的方法实现？->get();
foreach ($rs as $row){
/*防止上一轮任务没跑完又重新添加进来了
*/
$key = 'apiName_'.队列发起请求的时候，会计算本次请求毫秒数 - 上次请求毫秒数，如果大于1秒，则执行查询，否则通过usleep来延迟本次查询。
问答关于webman多进程的一个问题
我在webman的server.php中设置了count=10，10个进程。
然后index控制器中写入了sleep(1)，其他没有改动。内网中使用php的curl_multi发起了20个并发请求到webman中，在我的理想中应该是2秒结束curl的运行（10个进程处理20个请求，分两批呗，各占用1秒），但实际上用了4秒 甚至更多。然后我将curl_multi改为了10个并发请求，理想中应该是1秒完成，但测试结果发现还是2秒或更多
继续修改，将curl_multi改为5个并发请求，心想着count=10，我这5个请求怎么着也是一起完成吧测试后发现还是1~2秒中跳动，即便我将count=100或更多都是一样的结果。然后在sleep(1)前加了一个echo time(); 在控制台发现感觉不管我curl_multi访问多少个请求，都是对半处理，永远无法同时，10个并发 webman就同时处理5个，100个并发那就同时处理
问答请教GateWay多实例通讯
项目采用GateWayWorker框架，如果需要2个异步任务去执行耗时操作的话，是不是要建3个实例，A实例接数据，B C实例跑任务，那A实例是通过AsyncTcpConnection去链接B C实例吗，看了手册中的例子假如B 实例
```php
$task_worker->onMessage = function($connection, $task_data)
{
// 假设发来的是json数据
$task_data = json_decode($task_data, true);
// 根据task_data处理相应的任务逻辑....$task_result = ......
// 发送结果
$connection->send(json_encode($task_result));
};
```
A实例中onMessage
问答直播数据量大怎么处理？
在这样的情景下，数据一旦大了用什么来处理？谢谢！
问答thinkphp 如何结合wkmqtt 进行主题的下发
#### 问题描述
请教下大佬，现在的执行方案是下发主题的时候，每次都需要实例一个phpmqtt 进行主题的下发；我想改为在每次下发的时候，thinkphp 业务代码调用wkmqtt客户端下发；有什么好的思路或者代码参考吗
文档发布插件
# 发布到应用市场获取收益
由于二次开发都是基于应用插件方式开发的，所以很容易将其发布到应用市场，其它人一键安装后即可使用。如果你觉得你的插件很有用，可以将其发布到应用市场，供其他人使用并获取收益。打包应用插件参考 https://www.workerman.net/doc/webman/app/pack.html
发布应用插件参考 https://www.workerman.net/doc/webman/app/publish.html
# 应用插件征集
AI数字人、AI音乐生成、AI视频生成、思维导图、文件解析等等，只要是有趣的、实用的、有创意的应用都可以发布到应用市场，供其他人使用并获取收益。
赞助商
