PHP7.4用pcntl fork进程配合MongoDB出现Broken pipe报错如何解决

问题根因确认 #

你的推测完全正确，pcntl_fork 会复制父进程的内存空间与套接字资源，父子进程会共享同一份MongoDB连接，任意一方关闭连接或者销毁连接对象时，都会直接断开底层套接字，导致其他进程访问时抛出 Failure during socket delivery: Broken pipe (32) 错误。这是PHP MongoDB驱动在多进程场景下的已知共性问题。

官方推荐最优解决方案 #

方案1：子进程初始化后第一时间重置MongoDB连接（最常用） #

fork操作完成、进入子进程逻辑后，不要做任何MongoDB相关操作，先主动清空原有连接，重新初始化连接实例：

• 如果你使用原生MongoDB驱动：直接销毁继承的MongoDB\Driver\Manager实例，重新创建新的Manager对象即可
• 如果你使用Yii2的yii2-mongodb组件，执行如下代码即可重置连接：

// 子进程启动后第一时间执行
Yii::$app->get('mongodb')->close();
Yii::$app->set('mongodb', new \yii\mongodb\Connection([
    // 复制原有mongodb组件的配置参数即可
    'dsn' => 'mongodb://your-host:27017',
    'databaseName' => 'your_db',
    // 其他原有配置项保持不变
]));

重置完成后再在子进程中执行任务相关的数据库操作即可。

方案2：fork前关闭父进程连接 #

如果父进程fork之后短时间内不需要操作数据库，可以在调用pcntl_fork前先关闭MongoDB连接，fork完成后父子进程各自按需重新创建连接，从根源上避免连接共享问题。

注意事项 #

• 子进程中不要复用任何父进程创建的MongoDB查询对象、活动记录(ActiveRecord)实例，这些对象可能持有旧连接的引用，必须重新实例化
• 不要在父进程的信号处理回调中操作MongoDB，避免和子进程的连接操作冲突
• 你当前使用的1.9.1版本MongoDB PHP扩展已完整支持上述重置逻辑，无需升级扩展即可生效

内容的提问来源于stack exchange，提问作者Random Dude