问答“通过 Webman 中的 gRPC 集成释放云原生开发的力量”
gRPC 强调高吞吐量、低延迟连接、集成服务发现、负载平衡、身份验证和更小的消息大小，与传统 REST API 相比，可带来显着的性能提升。通过添加 gRPC 集成，Webman 可以让开发人员轻松地在服务之间构建极快的内部 API。这将使得诸如实时数据流和聚合之类的用例成为可能，而这些用例很难通过 REST 实现。集成这些功能可以将 Webman 打造成一个专为云原生开发量身定制的前瞻性框架。它打开了支持尖端用例并减少开发开销的大门。
问答tp6框架使用异常退出
"msg" => '您已经绑定过了']));
}
} elseif ($arr->type === 'msg') {
// 指定UID发送消息sendMessageByUid($arr->toUId, $arr->content);
}
return true;
}
/**
* 指定uid推送数据$connection->send($message);
//TODO 判断是否在线不在线则将消息存如MySQL type状体为 0 当此用户在次链接时把所有消息在发送回去，并更新type字段为1
}else{
//TODO 当前发送用户没有绑定
}
}
/**
* 当连接建立时触发的回调函数$connection
*/
public function onConnect($connection)
{
}
/**
* 当连接断开时触发的回调函数
问答在workman中，PHP当做后台语言怎么样才能给前台js页面主动发送代码啊？
我的功能需求是：后台主动像前端js推送动态（例如你被赞了，评论了这些）。从下午弄到现在总算摸清楚workerman了，但是我现在遇到一个问题，就是workman好像无法主动往客户端推送消息？有一个onmessage但是也要客户端主动发起啊，这样的话和长轮询一样了。到底有木有一个方法是专门提供主动推送消息的呢？
http://wenda.workerman.net/?
问答AsyncTcpConnection
tryToConnectGateway方法
$gateway_connection = new AsyncTcpConnection("GatewayProtocol://$addr");
// 然后发送一些数据connect();
}
```
由于AsyncTcpConnection的初始status状态都是connecting状态，所以send的时候都会先直接把buffer先存起来，然后直接return ，进入到且刚刚send中没有写入socket的数据是从哪里开始写进去的呢？
（新手，问题若太简单，请勿喷。）
问答admin插件中自带的数据库表，我想增加一些字段，这个会影响到后续升级吗
#### 问题描述
admin插件中自带的数据库表，我想增加一些字段，这个会影响到后续升级吗
问答event-loop:Workerman\Events\Swoole情况下高并发db查询如何优化？
[](//www.workerman.net/upload/20211031/31617e80a1a196.png)
如题， 并发测试报错。
代码：
只在控制层中调用了模型的查询，无其它操作。
问答group中的成员连接不同的Gateway和businessworker进程能通信吗
那么他们两个可能在不同的Gateway进程，不同的businessworker进程。这样用sendToGroup或者sendToUid可以送到他们两个吗？
问答webman下GatewayWorker如何使用多协议？
[截图](/upload/img/20240410/1066165e1c5516.png)
我在做一个物联网项目，用的是webman+GatewayWorker，需要用到websocket对接前端页面，还有GatewayWorker支持modbus吗，有没有相关示例？
问答webman onMessage里每日0点推送消息
#### 问题描述
业务是这样的，通过自定义进程起的长连接，在onmessage里怎么每日0点给在连接着的客户端传消息。因为要区分平台，某些平台需要在0点推送，在onmessage里$conn对象保存平台，在对应平台里起Crontab
问答BusinessWorker 根据业务拆分
#### 问题描述
假设项目中业务负载不一样，且相差很大，如果根据业务拆分不同的BusinessWorker，部署在不同的服务器，gateway根据规则路由到不同的服务器 [https://www.workerman.net/doc/gateway-worker/router.html], 如果是这样，节点之间数据如何共享？
问答stream_socket_sendto() expects parameter 1 to be resource, bool given 请问这是什么原因
Gateway::joinGroup($client_id, $group);
入组后直接推送
Gateway::sendToGroup($group, $data_push);
就出现上面的报错，数据可以正常推送出来
问答用户量多了，发现有busy进程
[attach]2155[/attach]
然后逻辑上没问题，发现workerman.log里面出现了这个超时，这是啥啊？求大佬解惑
问答在高并发下老是出现锁表或违反唯一约束
#### 问题描述
我服务端是采用Workerman+GatewayWorker+TP5
在使用中，如果并发不高的话，基本没问题，
但是一但有高并发时，同时需要插入或更新批量数据时，有时会出现锁表或者违反唯一约束了$objectItem['commentUserList']:[];//文章和相关评论和点赞的数据
if($commentUserList){
$commentUserList=array_column$wml->saveAll($likeData);
}
$is_remind=false;
if($remindData){
$wmr=new MomentsRemind();//这是如果是自已发的);
$is_remind=true;
}
```
#### 为此你搜索到了哪些方案及不适用的原因
之前也有使用INSERT IGNORE INTO来插入，不过也不是理想，想问下，像这种的在高并发下时要如何避免出现锁表或唯一约束呢
问答[已解决]如果同时和进程数量的肉鸡同时访问不同链接的404访问 是不是 所有进程就都阻塞了
#### 问题描述
这里写问题描述
404返回速度 大概500ms左右
如果同时和进程数量的肉鸡同时访问不同链接的404访问 是不是 所有进程就都阻塞了，导致整个站点无法访问
注：每次访问链接都不一致
问答webman的redis-queue不同的队列设置不同的消费进程
文档中
为不同的队列设置不同的消费进程
默认情况下，所有的消费者共用相同的消费进程。但有时我们需要将一些队列的消费独立出来，例如消费慢的业务放到一组进程中消费，消费快的业务放到另外一组进程消费。'/queue/redis/slow'
]
]
];
```
问题一：
按照文档设置后，是fast和slow各自开8个进程吗？问题二：
在linux下，还是只需要php start.php start就ok了吗
问答gateway四个进程分别占满一半cpu
gatewayworker框架，开启了四个business进程、四个gateway进程。S 08:50 0:10 WorkerMan: worker process IMBusinessWorker none
```
服务器配置信息：
内存：62g
cup核数：10核
Speed
问答webman动态修改上传文件大小、如何更新全部进程的配置
需要不重启修改上传文件大小
在控制器中使用
```
use Workerman\Connection\TcpConnection;
public function index(){
TcpConnection::$defaultMaxPackageSize = 20 * 1024 * 1024;
}
```
有1个进程这个代码可以动态更新文件上传大小
可是有4个进程的话。。需要每个进程都执行这段代码才会设置成功 否则没有设置的进程收到上传文件的请求就会中断
请问有不有可以直接设置每个进程的大小方法。。
补充:
如图 需要执行多次 4个进程才能全部修改
问答webman的crontab运行次数问题
#### webman定时任务我设置每秒运行一次，到线上感觉是每秒运行了几次呢，是启动的多个进程同时调度运行了吗。现在还没排除是一秒内上一次没执行完，下一秒又运行了。并且都是在同一时间，所以我怀疑是定时任务被多个进程分别执行了。use Workerman\Http\Client;
$http = new Client();
$http->get($url);
我看了下有说获取workerid来限制只有第0个才运行，尝试了几个写法都没对或者是需要使用redis来限制只运行一次吗。
问答gatewayworker 默认页面输出
刚下载的源码,运行之后http访问在浏览器中默认输出了相关访问数据.
没找到是在哪里输出的.有谁知道么
问答用nginx反向代理webman的sse服务加上ssl时无法连接
connection
* @param Request $request
* @author :lance
* @description:{服务连接时进行消息推送event-stream则说明是SSE请求
// if ($request->header('accept') === 'text/event-stream') {
// 首先发送一个new ServerSentEvents(['event' => 'message', 'data' => 'hello', 'id' => 1]));
// 定时向客户端推送数据Timer::del($timer_id);
return;
}
// 发送message事件，事件携带的数据为hello，消息id可以不传
$connection->send(new ServerSentEvents(['event' => '
赞助商
