<?php
return [
...這里省略了其它配置...
'redis_consumer' => [
'handler' => Webman\RedisQueue\Process\Consumer::class,
'count' => 8, // 可以設(shè)置多進(jìn)程
'constructor' => [
// 消費(fèi)者類目錄
'consumer_dir' => app_path() . '/queue/redis'
]
]
];
您好 請(qǐng)問(wèn)這個(gè)進(jìn)程是全局設(shè)定嗎?
比如 我有一個(gè) 郵件發(fā)送隊(duì)列 還有其他隊(duì)列 這個(gè)多進(jìn)程 所有隊(duì)列都8進(jìn)程嗎?能單獨(dú)分開(kāi)嗎
這個(gè)配置的意思是全局啟動(dòng)8個(gè)消費(fèi)進(jìn)程,這8個(gè)進(jìn)程共同使用 app_path() . '/queue/redis'
下的消費(fèi)者消費(fèi)數(shù)據(jù),并不是每個(gè)隊(duì)列設(shè)置8個(gè)進(jìn)程。如果你想分開(kāi),比如發(fā)送郵件放到一組單獨(dú)的進(jìn)程需消費(fèi),就把郵件消費(fèi)者單獨(dú)放一個(gè)目錄,比如放app_path() . '/queue/redis_email'
下(注意消費(fèi)者類的命名空間要相應(yīng)改動(dòng)), 然后加一個(gè)配置,例如
return [
...這里省略了其它配置...
'redis_consumer' => [
'handler' => Webman\RedisQueue\Process\Consumer::class,
'count' => 8, // 可以設(shè)置多進(jìn)程
'constructor' => [
// 消費(fèi)者類目錄
'consumer_dir' => app_path() . '/queue/redis'
]
],
// =====新加的email消費(fèi)者進(jìn)程====
'redis_consumer_email' => [
'handler' => Webman\RedisQueue\Process\Consumer::class,
'count' => 8, // 可以設(shè)置多進(jìn)程
'constructor' => [
// 消費(fèi)者類目錄
'consumer_dir' => app_path() . '/queue/redis_email'
]
]
];
這樣就單獨(dú)啟動(dòng)8個(gè)郵件消費(fèi)進(jìn)程了
超贊
最近就是想把有些可能會(huì)堆積的消息,用單獨(dú)的進(jìn)程來(lái)消費(fèi)
這樣就不會(huì)影響其他快速消費(fèi)的消息
太棒了!!!!!!!!!!!!!!