我想非抽象地了解下redis-queue工作情況,設(shè)置了多進(jìn)程同時消費(fèi),請問如何獲取進(jìn)程ID以證明確實是多個進(jìn)程在消費(fèi)?
for($i = 1; $i <= 200; $i++){
$redis = new \redis();
$redis->connect('127.0.0.1', 6379);
$redis->auth('123456');
$redis->select(1);
$this->redis_queue_send($redis, 'test', [
'i' => $i
]);
print_r($i).'<br>';
}
die;
'redis_consumer_fast' => [
'handler' => Webman\RedisQueue\Process\Consumer::class,
'count' => 8, // 可以設(shè)置多進(jìn)程同時消費(fèi)
'constructor' => [
// 消費(fèi)者類目錄
'consumer_dir' => app_path() . '/queue/redis/fast'
]
],
消費(fèi)類:
public function test($data)
{
$t = time();
Log::channel('plugin.webman.redis-queue.default')->info('測試'.$t, $data);
}