问答workerman 模型子进程如何处理请求
如下
worker->count 5个子进程
一个 请求过来如何处理?
子进程并行处理还是串行执行?
其他进程会抢占处理吗?
是一个请求一个进程还是多个请求一个进程处理
其他进程又在干嘛
问答jenssegers/mongodb 中如何批量插入，遇到唯一索引就忽略错误？
#### 问题描述
在webman中使用`jenssegers/mongodb`包，如果集合中已经存在相同的数据，再插入相同数据就会报错。请问有其他的方法可以批量插入吗？.
```
#### 为此你搜索到了哪些方案及不适用的原因
- 查询了`jenssegers/mongodb`的文档，发现并没有针对数据的批量处理，例如在mysql中使用upsert() insertOrIngnore()等类型的方法
- 查询了mongodb手册发现，insertMany()可以增加参数ordered:false来使批量插入遇到唯一索引错误时，忽略此条，继续插入。但是`jenssegers/mongodb`包中未发现这类的写法
问答SocketIO客户端给服务端传递参数这个on一直在执行中，客户端再次连接服务端的时候 客户端控制台一直显示pending,难道on一直在执行的时候，客户端不能在连接了吗？
[](/upload/img/20220222/226214bc3b4960.png)
控制台：
分享webman_admin 工作流应用插件
## 详细介绍
基于 webman + ingenious 开发的一个工作流应用插件 PHP版本>= 8.0+。## 功能特性
支持常规的流程流转，比如跳转、回退、审批和任意跳转
支持转办、终止，任务最终回到发起人
支持会签（串行和并行）
支持角色、用户等参与人设置
支持监听器，参数传递，动态权限
支持互斥网关，## 配置
基础插件有用的数据库需手动配置
```php
config/thinkorm.php
<?// 数据库密码
'password' => 'root',
// 数据库连接端口
'hostport' => '3306',3,
],
// 数据库编码默认采用utf8
'charset' => 'utf8',
// 数据库表前缀
问答WEB消息推送框架 windows 环境下怎么安装
WEB消息推送框架 windows 环境下怎么安装 , 请提供流程图
问答请问如何获取进程ID以证明确实是多个进程在消费？
我想非抽象地了解下redis-queue工作情况，设置了多进程同时消费，请问如何获取进程ID以证明确实是多个进程在消费？'handler' => Webman\RedisQueue\Process\Consumer::class,
'count' => 8, // 可以设置多进程同时消费
问答A、B服务器安装了webman的GatewayWorker插件，怎么用sendToClient发消息
#### 问题描述
A、B服务器可以通过内网IP访问，A服务器和客户端建立连接，B服务器想通过sendToClient给客户端发消息,
A、B的process.php要怎么配置呢
```php
return
问答gatewayWorker 能实现向群组group发一条只对群内某个用户可见的消息吗
类似微信群发红包，其他用户抢了红包，群内聊天界面会出现提示消息，比如“xxx抢了你的红包”等等，这个消息只对发红包的用户可见，其他抢红包的人是看不到，workerman的IM 群聊功能如何实现呢？
分享HTTP协议下的IO阻塞任务，如何保证请求均匀分配到进程
比如以HTTP协议创建了5个进程，然后每个进程里的业务执行时间是2秒。然后并发4个用户，16次请求
ab -c 4 -n 16 'http://127.0.0.1:8080/'
结果请求并没有均匀分配到进程，某个进程对某个请求进行了阻塞
```log
2018TCP协议的worker进行处理，发现如果一次性发起多个请求时，TCP协议的worker也会出现类似上面的情况，然后通过上面的方法，也很完美的解决了这个问题。最后我觉得pauseAccept()、resumeAccept()应用场景很多啊，比如生存消费者模型中，消费者IO阻塞等待任务，又比如对时间点要求较高的爬虫任务，能尽量的均匀分配请求到进程，进而减少时间差官方文档目前还没有相应描述，我还是好不容易找了一篇文章中的关键字pauseAccept，然后搜索源码发现的。。。这真是两个神奇的方法，希望官方能在后面补充一下，对于我这类的小白就帮助大了，哈哈哈
分享使用workerman 压力测试结果，很满意
:1,"name":"cichenman","age":26,"tip":"\u5185\u5b58\u6570\u636e"}]}）
4.内网测试 （本地 127.0.0.1）
5.AB 压测 （参数：50W 请求 1000 并发 开启 Keep-Alive）
测试模式：
1. nginx + 纯静态 输出固定文本
2. nginx + php 输出固定文本
3.workerman 输出固定文本**具体代码贴在了评论区**
均采用：4 个进程，8G 内存，千兆内网环境测试，测试数据仅供参考，每种测试模式测试 10 次
问答【已解决】写安装引导时很奇怪的502或无响应问题，CPU占用会高
[截图](/upload/img/20250407/0767f39324b201.png)
无响应截图二
!, 数据库地址填写错误');
} elseif ($code == 1045) {
return $this->error('数据库链接错误, 账号或密码错误');
} elseif ($code == 1049) {
return $this->error('数据库链接错误, 数据库名称对应的数据库不存在');
}
return $this->error('数据库链接错误，' .(['msg' => $th->getMessage(), 'sql' => $sql]);
}
return $sql;
}
/**
* 链接Pdo数据库检查数据库信息是否正确
问答大佬救命。。我用官网的定时例子，但是服务端没收到消息呀，郁闷了
'/Workerman/Autoloader.php';
// 普通的函数
function send_mail($to, $content)
{
echo "send mail ...onWorkerStart = function ($task) {
$to = 'XX.XX.XX.XX:XXXX';
$content = 'hello workerman';
// 10秒后执行发送邮件任务，最后一个参数传递false，表示只运行一次
Timer::add(10, 'send_mail', array($to, $content), true);
};
// 运行worker
Worker
问答AngluarJS与workerman的兼容问题
我想把官网示例上的chat.js中的函数function onmessage(e)与function onSubmit()写到一个service中，以便两个不同的controller调用。但是这样服务器发送信息onmessage就收不到了，请问这是我的语法问题吗？或者有什么刚好的解决方案？求老大给个比较好的解决方案，简单地说就是如何将客户端的逻辑写进MVC的框架中？万分感谢
问答【已解决】咨询一个webman关于构造函数的问题 __construct（新）
#### 问题描述
在社区看到这样一个帖子是关于构造函数的；
https://www.workerman.net/q/5948
根据帖子的描述，在webman 1.5.1的版本中，每次请求构造函数内的方法都会有执行一次的组件；
#### 为此你搜索到了哪些方案及不适用的原因
是否是版本的变化，造成了执行结果的差异；
接下来安装phpdi等相关组件，且在配置中修改了container配置后，__construct函数中其它类的注入是就次性的，一次请求，其它请求进来直接共享了，但方法内的打印在每次请求中，也都执行了；
请教；谢谢；
问答关于重启偶尔出现not ready情况
[截图](/upload/img/20220713/1362ce86a0dc05.png)
按照我对Register注册进程的理解，是否会存在一种情况：
当BusinessWorker重启时，由于网络或者其他原因，导致Register没有触发onClose事件（因为socket并不保证一定会触发onCLose），导致这个问题的出现；
如果存在这种情况的话，我是否可以在Register用定时器去维护一个心跳，判断如果长时间没有数据交流
问答如何只使用wokerman进行全员广播
写了个聊天室，只用到了workerman,
想在来消息时候进行全员广播，发现只有某一个客户端收的到信息
```php
$worker->onMessage = function($conn,$data)
问答希望route类提供更多的接口
例如我的url 有1个参数id是加密过的，要用中间件解密的话，没有找到相关接口。只能到控制器里解密，很麻烦的。希望支持。laravel 是支持的，解密后，送回路由里
参考：
public function handle(Request $request, Closure $next, ...
分享关于webman启动流程的简单分析
### 二、说明
以下流程图是个人理解，有不对的地方请指出来，我将修正它。
同时声明下该流程的几个点
1. 该流程核心关注接收并响应请求的流程，针对定时器部分暂未列出
2.PHP_EOL;
}
else {
// 从客户端读取数据，如何确定是当前这个client发来的数据// 因为select拿到数据，说明一定是有新的数据被读到（返回的read是有新数据到达的socket）
$msg = fread($socket, 65535)通过debug调试发现，这时每次select都有write返回，也就是该新加进去的socket。所以当第一次将把主动监听的socket放进到read时（这里后面统一称为mainSocket），如果此时有客户端连接进来，那么下一次在select监听的时候，就会发现read中的mainSocket有就绪的状态
问答Gateway框架，请问新建的Worker文件怎么样发送消息通知Events.php接收呢？
在Applications/Chat下建立了一个Worker文件处理定时器，如果时间一到，怎么样发消息到Events.php里接受，然后处理业务逻辑返回WEB客户端？谢谢
问答页面的 socket.onmessage 与PHP workerman 的onmessage 触发同时触发吗 有限workerman触发在到页面触发吗
页面的 socket.onmessage 与PHP workerman 的onmessage 触发同时触发吗 有限workerman触发在到页面触发吗
赞助商
