问答负载均衡webman自定义进程
关于负载均衡webman自定义进程
// 监听的协议 ip 及端口 （可选）
'listen' => 'udp://0.0.0.0:12345',
发送数据
$client = stream_socket_client个服务器，貌似乱套了
负载均衡内每个服务器的listen监听的0.0.0.0是否需要改成对应服务器的内网ip呢,每个服务器防火墙是不是也要开启对应的udp端口
stream_socket_client发送数据时地址是否也要改成对应服务器的内网
问答webman 进程重启问题
看文档理解到，目前是基于内存超过限制重启工作进程，应该再加一个进程处理请求次数，如处理100次结束进程。
开发的时候，通过配置1个工作进程执行一次请求，退出进程，起到开发调试自动重启的效果
问答webman ai的消息数控制
#### 问题描述
这里写问题具体描述
webman ai助手的消息数没有控制住，后台设置了必须登录但是没登录也可以使用。在AI通用设置里面可以设置每个模型的消息限制，但是好像没起作用啊
问答onWorkerStart里面是stream流数据，前端连接不上的问题，求解答
#### 问题描述，谢谢解答
**onWorkerStart里面是stream流数据，导致前端连接失败，因为在不停的推送数据，默认没有执行完成，求1个思路，感谢。$promise = $client->getAsync('这里是一个流链接地址，会不停的推送如下图所示的数据', [
'headers' => $headers,($body);
if ($line) {
var_dump($line);
// 在这里我想实现，把line数据推送给前端连接对象$body->eof()) { ]逐行读取影响了，因为在不停的推送数据，没有执行完成
// 上面的while注释掉，前端可以连接成功
}
}{
$connection->send('heartbeat');
}
};
// 向所有验证的用户推送对应的数据
function broadcast($msg, $symbol
分享分享一个自用的docker webman开发环境
因为自己用的MacOS下开发有代码改动不会自动reload
就用docker run一个轻便的alpine环境来进行启动
### 首先去下载一个Linux版本的PHP，解压后把二进制文件放进项目根目录
问答向GatewayWorker搭建的TCP服务器发送JSON数据报错
> 如下图所示
问答woker进程busy，gateway进程内存和cpu占用极高
项目是车辆GPS对接，通过JT808协议，两种对接方式
1.平台转发（TwxGateway）
客户端少，大概10几个，每个客户端转发大量数据，正常情况下最多的大概每秒100-200组数据
2.设备直传（pass_808）
一万多客户端，每个客户端大概30S一组数据
如下图，会出现转发的gateway大量占用内存，top之后cpu基本上100%
!www.workerman.net/upload/20210324/24605ae96b0e4a.png)
卡在recvfrom（59，
kill -SIGALRM之后，依旧会卡在该处
lsof -nPp 分析后，发现是在接收本地数据[截图](//www.workerman.net/upload/20210324/24605aea0762da.png)
worker进程已经分布式部署，依旧会时常卡死，是否考虑为单个gateway数据传输过大，导致gateway进程cpu占满，以至于worker进程一直卡在从gateway取数据，处于busy状态
或者有其他问题，该如何判定解决
问答发送大数据就这样。。。
SendBufferToWorker fail. May be the send buffer are overflow. See http://wiki.workerman.net/Error2 for detail
问答为何最大TCP连接数为 254
Workerman\Lib\Timer;
$_SESSION==0;
$http_worker= new Worker('tcp://10.163.58.200:1234');
// 启动4个进程对外提供服务$http_worker->count = 4;
// 接收到浏览器发送的数据时回复hello world给浏览器
$http_worker->onMessage = function($connection, $data)
{
if($data=='yes')
{
echo @$_SESSION+=1;
echo "\n";
}
// 向浏览器发送hello world
问答通过AsyncTcpConnection循环访问https接口的json数据问题
```php
use \GatewayWorker\Lib\Gateway;
use \Workerman\Connection\AsyncTcpConnection;
use \Workerman\Events();
// worker名称
$worker->name = 'M-BtcTrade-COM';
// bussinessWorker进程数量
$worker->count = 1;
// 服务注册地址\n";
//输出数据进行处理
..................................................
......................defined('GLOBAL_START')) {
Worker::runAll();
}
```
以上代码是每秒钟循环中抓取一下5个URL返回的JSON数据
现在的问题是在$con->onMessage还未完全处理完数据之前，$con 对象就被下次循环重建了，从而造成数据丢失，请问如何修改代码才能避免这个问题的出现呢？
问答workerman 实现不同用户推送不同消息问题
需求：根据client端发送的不同uid，server端推送对应uid比较感兴趣的一些话题给不同的用户
每个client 端都有唯一一个uid发送给服务端：
ws.send(JSON.stringify({"type":"attention","uid":UID}));
此时uid=416
server端发送数据的时候：
ws.send(JSON.stringify({"type":"send","uid":"416","content":input.value}));
在onMessage中处理：
```php
switch($message_data)
{
// 发送数据给用户 message: {type:send, to_client_id:xx, content:xx}
case 'send':
// 向某个浏览器窗口发送消息
if($message_dataGateway::sendToUid($message_data, json_encode($new_message));
}
// 向所有浏览器发送消息
问答已解决【webman】数据库没有真正写入数据
刚开始启动webman运行，很正常，可以按照正常的流程去运行，数据也能正常的更新到数据库里。**我使用数据库软件，phpMyadmin和HeidiSQL查看数据库，均无法查到我后面接口请求的数据，只能查到1个小时前的数据。**
程序是正常运行的，没有任何报错，运行逻辑也很清晰。**但是当我重新启动webman，我请求余额列表的数据，包括用户余额的数据，后面新增的数据都不存在了，请求的都是1个小时前的数据，因为后面的数据根本就没有实际写入到数据库里面。**我被这个问题困扰了2天，后面我尝试使用webman/log这个插件，分析一下SQL数据，奇怪的是，竟然不会出现之前那种，请求正常，但是不会实际写入数据库这种情况了，竟然一切都恢复正常了。**
我之前也怀疑是事务没提交，但是根据运行流程，事务是肯定运行了，并且也能成功返回数据，只要我不重启webman，这些数据会一直存在，也会新增，只不过，只要我重启webman，一切都会回到之前。
问答workerman 如何控制某个进程停止监听端口？
1.开了2个进程监听http。其中一个进程执行了一段代码后需要停止监听http执行其他代码,怎么控制？2.使用 Worker::listen(void) 之后，收到某个信号时，需要停止监听然后执行其他代码，怎么控制？
问答workerman源码读取socket数据
baseRead方法中
读取socket代码如下：
$buffer = @fread($socket, self::READ_BUFFER_SIZE);
前后代码中并没有看到 while() 之类的验证数据读取完之类的代码假如把上述代码改为每次读取10个字节 $buffer = @fread($socket, 10);
请问是怎么样的机制保证每次从socket 读取完数据的？然道这个和event loop 处理事件 中设置的 \Event::PERSIST参数有关吗？\Event::PERSIST 的解释如下：
如果一个事件被设置了EV_PERSIST，那么这个事件就是持续化的，意思就是这个事件会保持挂起状态，即使回调函数被执行。
问答向客户端app做推送,是用workerman还是gatewayWorker？
目前的web项目中要实现服务端向客户端app做主动推送，是用workerman还是gatewayWorker？
问答GatewayWorker在windows下写入数据库的问题
'utf8',
);
}
```
Event.php
引入空间：
```php
use \Workerman\Worker;
use \Workerman\Lib\Timer;
use \GatewayWorker\Lib\Gateway;
use \GatewayWorker\Lib\Store;
use \GatewayWorker\Lib\Db;
在onConnect方法里：
if(self::$grouptime
问答服务器向设备发送心跳检测，好像未关闭通道
#### 问题描述
目前在做设备物联网，分成了客户端`client_gateway`和设备端`device_gateway`，因为设备电池比较小，硬件大佬要做低功耗，就说服老板取消了定时发送心跳，搞的现在设备在线状态都不准确了今天想起可以反向发送心跳检测，就试了下，确实发出去了，但是也出现了新问题：
设备不再发送心跳，为了省电（我也不知道究竟能省多少电...）客户端（小程序）模式不变定时发送心跳给服务器
`device_gateway`增加了服务端发送心跳
```php
// 服务端定时向客户端（设备）发送的数据（在设备不发心跳的情况下）_SESSION['device_info'])) {
$target = 'device';
//出现 not_log 时不进行下线处理service->create_device_log($device_info['device_id'], 4, '设备下线了');
//发送给客户端
问答Business worker 能不能只发送不接收消息？
我现在的业务是 独立一处一个进程来 做Timer，timer里面有一个工作是sendtoclient。一开始我是想用普通的worker，但是这样好像不能传数据给客户端了，必须要通过channel告诉原businessworker 然后让他传。我想问能不能 我把创建的Timer worker进程设置为 business worker，连上Gateway但让gateway不把client的消息转发给这个进程，这个进程却可以传消息出去。
问答$worker->onMessage事件没有触发，收到的数据必须是\n结束吗？没有\n是否可以触发
$worker->onMessage事件没有触发，收到的数据必须是\n结束吗？没有\n是否可以触发
我从一个类似单片机的板子上接收到的socket数据，结尾不是以\n结束的，所以没有出发$worker->onMessage事件，这个有定义吗？以什么结束才触发$worker->onMessage事件
问答workman后端给服务端再给客户端发消息，客户端的消息怎么再给后端？
进程启动后创建一个text Worker以便打开一个内部通讯端口
$worker->onWorkerStart = function($worker)
{
// 开启一个内部端口，方便内部系统推送数据，里面有uid，表示向那个uid的页面推送数据
$data = json_decode($buffer, true);
$uid = $data;
//通过workerman，向uid的页面推送数据
$ret = sendMessageByUid($uid, $buffer);
// 返回推送结果
$connection推送
$data = array('uid'=>'uid1', 'percent'=>'88%');
// 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
fwrite\n");
// 读取推送结果
echo fread($client, 8192);
现在的问题是：后端能通过服务端给客户端发送消息，那么客户端怎么通过服务端给后端传送数据？
赞助商
