我想非抽象地了解下redis-queue工作情况,设置了多进程同时消费,请问如何获取进程ID以证明确实是多个进程在消费?
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, // 可以设置多进程同时消费
'constructor' => [
// 消费者类目录
'consumer_dir' => app_path() . '/queue/redis/fast'
]
],
消费类:
public function test($data)
{
$t = time();
Log::channel('plugin.webman.redis-queue.default')->info('测试'.$t, $data);
}
找到了 posix_getpid()