问答关于cpu核心数和进程数量的综合问题
linux系统
一、请问config下的 server.php
'count' => cpu_count() * 2,
这个核心数是啥意思，有啥用
二、使用了redis-queue队列'handler' => Webman\RedisQueue\Process\Consumer::class,
'count' => 16, // 可以设置多进程同时消费'/queue/redis'
]
],
这个进程是开多少，一秒就同时开多少进程同时处理吗？那么应该按照什么设置标准
第三、咨询一下使用宝塔部署webman 也有一个进程数量 应该填写多少呢
问答workerman接收大量数据的问题
现在有一个程序，接收大量的数据 ，并且用一个进程进行较耗时的处理。我想问，处理过程中，买没接收的数据存在哪呢，会不会因为数据量太大，导致数据丢失了？
问答直接运行正常，打包二进制后运行报错，日志不可写
#### 问题描述
在webman中自定义命令，是用workman启动监听之后，会自动生成workman日志，但是在打包二进制后，文件写入失败。
文档关闭未认证的链接
# 关闭未认证连接
**问题：**
如何关闭规定时间内未发送过数据的客户端,
比如30秒内没收到一条数据就自动关闭这个客户端连接,
目的是为了让未认证的连接必须在规定时间内认证
**答案：**
**方法一、利用GatewayWorker的心跳做**
GatewayWorker
GatewayWorker中可以利用心跳来解决这个问题，GatewayWorker有设置客户端多久不回复心跳服务端就关闭连接的属性，可以利用这个机制关闭未及时认证的客户端。start_gateway.php
```php
// 心跳间隔
$gateway->pingInterval = 30;
// 发给客户端你的心跳数据
$gateway->pingData = '{"Gateway::closeClient($client_id);
}
}
............略
}
}
```
**方法二，
问答如何保存GatewayWorker实时检测硬件在线状态
能用GatewayWorker获取到硬件的心跳包了，我现在在数据库中筛选出需要检测的设备号码，有可能有几千几万的数据量，如何有效的去实时检测，这些设备的在线状态？前期方案，筛选出来的数据是一个数组，在检测到硬件发送来过的心跳包之后，用循环去查询数组中是否存在该设备号码，如存在，修改状态（默认状态为离线），但是如果用循环去比较的话，是不是效率不高啊
问答关于webserver中的数据库使用问题
在webserver中能否使用workerman自带的数据库类？如果可以，在使用上有什么需要注意的地方？后来在GatewayWorkerman中使用了数据库类，按照手册进行
[attach]72[/attach]
发现这个问题，不知道哪里出了问题
问答数组的值会自动改变
我做了一个小游戏，客户端向服务器发送 '{"type":"update","boatId":"20001","y":"10"}' json数据，服务端把y 值存到数组$POSITION中，如果有新的用户进入，会先发送 '{"type":"init"}'，服务端判断type为init则吧数组中的数据发送到客户端。那么问题是：每次有新的客户端打开，或者刷新页面，客户端收到的数组数据总是会变。打印$POSITION发现值每次都不一定固定。怎么回事儿？boat1' => $POSITION,
'boat2' => $POSITION,
'boat3' => $POSITION,
)));
return;
//更新数据
问答多数据库怎么维护连接
多进程处理任务，但每个任务涉及的数据库可能不一样（多租户），怎么维护数据连接呢
目的是开多个worker进程处理不同租户的异步任务
最大总连接数 = 进程数量 * 租户数量
租户有1000，进程10个，那么每个进程维护的数量就是1万
问答GatewayWorker 进程busy
worker 进程 busy
按照手册调试过程如下： [调试busy进程](http://doc.workerman.net/debug/busy-process.html)
!`netstat -lntp | grep 6042`看一下这个端口是哪个进程
pid 4399 正好是其中一个 gateway 进程
4.使用`kill -SIGALRM 4377`后，strace 的进程打印一些数据后退出[截图](//www.workerman.net/upload/20200629/295ef9d4f2890d.png)
后续不知道该怎么调试了，status 显示 gateway 进程都是 idle
问答gatewayworker获取设备端mac地址失败
如下图所示，上边的是打印的mac地址，下边是在events文件里的onMessage()函数里写的代码，打印mac地址和ip，但是打印出来的mac地址确是本地局域网的mac地址，而且可能是因为设备用的是移动物联卡的缘故现在想请问大神以下几个问题
问题一：能否通过gatewayworker获取设备的mac地址？问题二：如果可以，仅仅通过设备和gatewayworker建立连接后，该设备发送过来的一条登录指令(该指令不含mac信息)，可以获得该设备的mac地址吗？问题三：如果不可以，gatewayworker是否可以获取其他能确认设备身份的信息？
问答gatewaker 怎么实现多个动态的队列？
是这么个情况，我的一个接口接收的数据需要分组转发。因为接收数据不是匀速，有时快有时慢，但转发的接收方有限制接收速度。
比方说我收的数据中的前十条发到第一个分组，后十条发送到第二个分组，依此类推。接收方每个分组有个速度限制，最少间隔2秒每条数据，每个分组都时这样。所以我想要用多个队列来缓冲这个数据，实现每个分组最快2秒转发一条。问题来了，接收方有几十个分组，我想利用接收的数据中的分组参数来动态的初始化队列。
即第一个分组的数据来了，我初始化一个队列。例如：
要转发给第3 个分组的数据来了
$q3 = new queue();
因为接收的数据的分组不确定。
我怎么样才能不在OnMessage中初始化多次？
问答关于在控制器中使用SSE
#### 问题描述
前端使用`event-source-polyfill`来SSE请求，因为需要携带token，后端在控制器中写了让如下方法。'Content-Type' => 'text/event-stream'
], "\r\n"));
//定时向客户推送数据Timer::del($timer_id);
return;
}
// 发送message事件，事件携带的数据为hello，消息id可以不传
$connection->send(new ServerSentEvents(['event' => '是不能在控制器里面实现吗
问答Workerman\MySQL 经常性个别请求写入数据库失败
现在是大部分sql可以正常写入数据库，部分sql没有写入数据库。请问这是什么情况。
第一张图片是实例化了数据库
第二张图片是吧第一张图片的代码引入Events.php
文档支持多少并发
# Workerman支持多少并发
**并发**概念太模糊，这里以两种可以量化的指标**并发连接数**和**并发请求数**来说明。**并发连接数**是指服务器当前时刻一共维持了多少TCP连接，而这些连接上是否有数据通讯并不关注，例如一台消息推送服务器上可能维持了百万的设备连接，由于连接上很少有数据通讯，所以这台服务器上负载可能几乎为假设10W吞吐量每秒是这台服务器的极限，如果每个客户端每秒发送1个请求给服务端，那么这台服务器能够支撑10W个客户端。**并发请求数**受限于服务器cpu处理能力，一台24核workerman服务器可以达到**45W**每秒的吞吐量(QPS)，实际值根据业务复杂度以及代码质量有所变化。## 注意
高并发场景必须安装event扩展，参考安装配置章节。另外需要优化linux内核，尤其是进程打开文件数限制，请参考附录内核调优章节。
问答无法修改request的post、get数据，求其它解决办法
#### 问题描述
前端post过来的数据比如说有n个值，但都被加密最后变成一个值：encrypt_data=xxx，后端中间件需解密encrypt_data后把值重新装进post里面，但webman不支持修改post的数据，以前使用thinkphp是支持的，目前想到的办法：
1、把解密的值复制给 request()->xxx = xxx ,控制器或模型中就可以调用了；感觉不是很科学，不够完美，控制器模型里面获取值的地方都要改掉感觉也不完美也麻烦，也担心后续框架升级会有影响问题
原则是不喜欢修改框架本身自带的功能，不知道还有哪些办法
#### 为此你搜索到了哪些方案及不适用的原因
搜索答案中都不支持修改post get数据
问答底层Http类无法解析请求数据
为什么创建一个http服务，向游览器发送数据，打包tcp服务为http过程中，为什么我在Http类，打印任何方法都不能断点。这里和缓冲有什么关系吗？
问答【已解决】websocket嵌套两层AsyncTcpConnection，无法在第二层调用第一层的$connection->send()
解决办法是，让进程B决定什么时候断开AsyncTcpConnection。通过websocket进程A，调用AsyncTcpConnection执行繁忙任务进程B，再在进程B中通过AsyncTcpConnection连接smtp邮件服务器（假设叫进程C），然后在smtp服务器（进程C）返回信息后，想调用进程B的$connection->send()，把smtp的结果发回websocket进程A，但是进程A收不到，请问为什么？如下图：run()是进程B，发送aaa可以收到，发送bbb收不到
第二次打印：
!
问答需要不断的返回数据给客户端
#### 问题描述
需求是用户访问了这个页面, 发送了数据, 然后需要实时更新这个页面的数据
文档简单的开发示例
$http_worker->count = 4;
// 接收到浏览器发送的数据时回复hello world给浏览器
$http_worker->onMessage = function(TcpConnection$ws_worker->count = 4;
// 当收到客户端发来的数据后返回hello $data给客户端
$ws_worker->onMessage = function(TcpConnection## 实例三、直接使用TCP传输数据
**创建tcp_test.php**
```php
<?$tcp_worker->count = 4;
// 当客户端发来数据时
$tcp_worker->onMessage = function(TcpConnection $connection, $data)
{
// 向客户端发送hello $data
$connection->send('hello ' .
分享也来说说TP与Workerman的集成
最近想在TP的项目中使用Workerman,经查看一些资料发现我现在使用的方式和大家不太一样,所以发出来大家可以指点一二
突然发现无法发链接,把内容复制过来一下好了
原理
TP与Workerman集成的难处在于CLI模式下TP默认第一个参数为入口文件,第二个参数为控制器路径,之后为参数
Workerman默认第一个参数为文件,第二个参数在WIN下无用,Linux下为start等指令
那么问题来了,在TP中使用Workerman一般都是在控制器层,而不是新增入口文件的方式
这样的话第二个参数的用途上两个框架会产生冲突,一般的解决方式有改动Workerman源码,直接在新入口文件中使用Workerman等但是通过观察两个项目的源码发现,Workerman是靠$argv进行参数判断,而TP则使用$_SERVER['argv']进行控制器映射
这样的话在可控的范围内可以通过讨巧的方式干涉$argv参数的形式进行集成'win':'linux';
4.根据当前环境引入Workerman的自动加载文件:Vendor('Workerman_for_'.
赞助商
