发表新帖

关于不同进程共用链接的疑问

想在Yii 2.0 中 Command 实现开启子进程处理任务
在子进程中会用到Redis
想知道如下代码是否存在`不同进程使用一个链接`的情况

### 相关代码
```php
class DataCleanController extends Controller
{
    // 实施监测的应用
    private const APPS = [
        ['pkg' => 'com.xxx.xxx', 'type' => 'xxx',],
    ];

private const CACHE_KEY_START_POINT_PREFIX = 'data:c:adTransferRelation:startPoint:';
    private const CACHE_KEY_RELATION_PREFIX = 'data:c:adTransferRelation:';
    private const INTERVAL = 2;
    private const CACHE_TTL_RELATION = 30;

// 进程最大处理次数
    private const MAX_HANDLE = 10000;

public function actionRun()
    {
        $this->stdout("开始处理\n", Console::FG_GREEN);

// 父进程
		
        // Redis 链接
        \yii::$app->redis->get();

// 进程管理器
        $pm = new Manager();

foreach (self::APPS as $app) {
            $pm->add(function (Pool $pool, int $workerId) use ($app) {
                // 子进程
                /** @var Process $process */
                $process = $pool->getProcess($workerId);

// Redis 链接
                \yii::$app->redis->get();

// 已处理次数
                $handleNum = 0;
                while (self::MAX_HANDLE > $handleNum) {
                    $handleNum++;

$this->handle($app);
                }
            }, false);
        }

$pm->start();

$this->stdout("处理结束\n", Console::FG_GREEN);
    }

private function handle($app)
    {
        $this->stdout("正在处理 {$app['pkg']}" . PHP_EOL);
		
        // Redis 链接
        \yii::$app->redis->get();
	}
}
```

另外，是否可以提供不同进程共用链接导致数据读写异常的示例。

发布于1年前 · 16 次浏览 · 来自提问

zxyfaxcn