问答请问下webman中怎么才能使用workerman/http-client
如果是使用自定义类 要怎么触发workerman/http-client来发送请求获取数据?
问答Thinkphp5.1+workerman，websocket通讯mysql产生大量sleep进程
[attach]1432[/attach]
Thinkphp5.1+workerman，websocket通讯过程中，每查询一次数据库，就会产生一条sleep进程，最后导致mysql产生大量sleep进程，请问各位大神如何解决呢
文档不支持的函数/特性
# 不支持的函数
不支持的函数/语句 | 替代方案 | 说明
----|------|----
pcntl_fork | 提前设置好进程数|
php://input | [`$request->rawBody()`](http/request.md)| 用于HTTP协议下的应用获取POST的原始数据
exit | return | 使用exit会导致进程退出，如果要返回请直接用return语句
die |return | 使用die会导致进程退出，如果要返回请直接用return语句
header cookie session相关函数 |参考 [`$request`](http/request.md) 和[`$response`]([http/response.md) 类 |
set_time_limit| 无 | 只能设置为0，否则会导致workerman进程在一定时间后退出
问答如何通过监控重启服务呢?
#### 想到的解决方案
简单粗暴的方法就行通过`php start.php restart -d` 去执行重启命令, 但是因为db里面的数据是随时可能发生变化的, 不能每次都去手动的执行重启, 因此想到了借鉴内存溢出重启/文件监控的方案, `posix_kill($ppid, SIGUSR1)` 但是测试了下是直接重启的当前进程, 我新增的进程不会,所以应该要如何搞呢, 有指令可以发送重启的命令吗?测试过了reload不符合我的业务逻辑,必须用restart
```
这是我插件自定的process, kafkaConfig是DB读出来的数据
$process = [];
foreach ($kafkaConfig'handler' => \app\queue\kafka\Events::class,
'count' => $value['count'], // 进程数'',
]
];
}
}
return $process;
新起一个监控进程monitor_kafka_config
检测DB数据...发生改变,执行一下命令
问答使用了 Timer客户端就不发送心跳了
#### 问题描述
服务端开启Timer 定时器给客户端发送消息后，客户端的心跳 服务端就收不到了。
问答workerman在高并发的问题,想要生产环境使用,求大神解答
您好 请问大神们 Workerman的 GatewayWorker 框架 的 mysql 连接池是怎么维护的?
在哪里设置的 MaxOpen 和 MaxIdle 等参数?gateway 在高并发下的多用户处理流程;
business_worker 信息处理流程和mysql连接池管理机制
在考虑是否可以投放到生产环境.和投放到生产环境的参数配置.
问答Gateway进程中的connections数一直在上涨，但实际上没有新的客户端加进来。
做了集群，Gateway和Register是在同一台服务器上，BuinessWorker单独一台服务器，都是局域网，
Gateway起了2个进程，
BuinessWorker起了8个进程，
我们的客户端数量是可数的，也就2千不到，但启动服务后，status 中的 connections一直在慢慢增长，
于是我在Gateway服务中onWebSocketConnect写了日志看是否是客户端的问题导致的重复连接，发现并没有新的连接数，但connections一直在涨，基本上每2秒涨1个，甚至一下子涨了10几个连接数，慢慢的，服务器连接数上去后，导致客户端掉线，目前几台服务器iptables都是关了的;
1，请问连接数狂涨是什么情况2，另外我发现客户端端口后，不会走onClose方法？net.netfilter.nf_conntrack_tcp_timeout_time_wait = 120
net.netfilter.nf_conntrack_tcp_timeout_established = 3600
```
/proc/进程
问答我在网页端 JS连接 WebSocket 总是失败
进程启动后创建一个text Worker以便打开一个内部通讯端口
$worker->onWorkerStart = function($worker)
{
// 开启一个内部端口，方便内部系统推送数据，里面有uid，表示向那个uid的页面推送数据
$data = json_decode($buffer, true);
$uid = $data;
//通过workerman，向uid的页面推送数据
$ret = sendMessageByUid($uid, $buffer);
// 返回推送结果
$connectionconnection->uid = $data;
/* 保存uid到connection的映射，这样可以方便的通过uid查找connection，
* 实现针对特定uid推送数据($worker->uidConnections as $connection)
{
$connection->send($message);
}
}
// 针对uid推送数据
问答thinkphp6 适配国产数据库【已解决】
#### 问题描述
哪些国产数据库支持适配tp6框架？
#### 为此你搜索到了哪些方案及不适用的原因
神舟适资料较少配难度较大。
达梦授权太贵。
tidb没用过。
问答webman不支持接收application/octet-stream的数据流？【已解决】
#### 问题描述
webman是不是不支持接收Content-Type: application/octet-stream的数据流？用PHP原生代码var_dump(file_get_content('php://input'));可以正常获取数据流
但是在webman中file_get_content('php://input')
问答admin后台 关于应用插件开发 权限的问题，请教各位怎么在插件中使用admin的权限控制
#### 问题描述
请教各位，如果自己开发一个应用插件，应该怎么使用admin框架中的权限控制
#### 为此你搜索到了哪些方案及不适用的原因
我看官方吧中间件加上了admin
<?admin\api\Middleware;
return [
'admin' => [
Middleware::class
]
];
# 但是我也添加了，并不能实现控制我看官方的控制如果没有权限，返回的是空白！
问答GatewayWorker连接mysql数据库报错
错误代码如图，请问是什么原因
问答AsyncTcpConnection如何进行拆包
大家好，我这边使用AsyncTcpConnection作为客户端来和服务端保持长连接，因为服务端也会主动推送信息到这边，服务器那边每条数据都会有四个字节来记录长度以防止粘包，那么AsyncTcpConnection
问答GatewayClient 怎么给分布式部署的多台gateway发送消息
#### 问题描述
这里写问题描述
GatewayClient 怎么给分布式部署的多台gateway发送消息？
问答新项目【webman+gatewayworker】报错
#### 问题描述
webman+gatewayworker报错
按照【 https://www.workerman.net/doc/gateway-worker/webman.html 】的步骤先创建webman项目，再进入后require gatewaorker 后启动，但是报如下的错
ArgumentCountError: Too few arguments to function Webman\GatewayWorker\Register::__construct(), 0 passed in /www/wwwroot/scnet/vendor/workerman/webman-framework
问答gatewayWorker通信正常，但用gatewayClient连不上gatewayWorker！！！
我的gatewayWorker**从前端可以正常连接并进行通信**，但是在后端调用gatewayClient就**死活连不上！！！！！！attach]1800[/attach]
start_gateway.php
[attach]1802[/attach]
start_register.php
[attach]1801[/attach]
gatewayWorker
问答PM2 管理守护 webman
Go 的程序
管理 go 的配置很简单，就一个 二进制文件
webman 的启动命令
直接用
```
pm2 start "php start.php start -d"
```
是不行的
问答在webman中使用thinkorm组件配置主从多个数据库，连接错误
#### 配置thinorm主从数据库，读写异常
参考文档：https://www.kancloud.cn/manual/think-orm/1258000 配置如下：
```php
return ['default' => 'mysql',
'connections' => [
'mysql' => [
// 数据库部署方式:0 集中式(单一服务器// 数据库密码
'password' => getenv('DB_PASSWORD'),
// 数据库连接端口
'hostport' => getenv('DB_PORT'),
// 数据库连接参数
'params' => [
// 连接超时3秒trigger_sql' => false,
// 自定义分页类
'bootstrap' => ''
],
],
];
```
如上配置，使用了数组配置了两个数据库
问答使用GatewayClient调用getAllClientSessions获取不到任何数据
使用GatewayClient获取所有在线客户端（getAllClientSessions）的时候，返回的总是空数据（GatewayClient跟worker不在同一个服务器，使用了Gateway::$registerAddress设置公网ip，并且是可以连通的），看了下代码，发现getAllGatewayAddressesFromRegister这个函数里面返回的地址全部都是"127.0.0.1：端口);
```
这个返回的是{"event":"broadcast_addresses","addresses":}这种，那我就测试了下，在GatewayClient本机上面启动另外一个worker，发现getAllClientSessions返回的都是本机上面的worker客户端信息
问题总结：Gateway::$registerAddress设置公网服务器的情况下，getAllClientSessions函数获取到的是当前服务器的客户端信息
问答请教一个UDP接收数据并显示的问题
请教一下各位：我在同一个实例里面放置两种协议，其中UDP拿来接收硬件推上来的数据，HTTP用于WEB显示数据。我该怎么操作？
赞助商
