国产+高潮+在线,国产 av 仑乱内谢,www国产亚洲精品久久,51国产偷自视频区视频,成人午夜精品网站在线观看

workman使用rabbitmq消費(fèi)隊(duì)列時(shí)遇到問題

ani

一個(gè)worker是否可以消費(fèi)多個(gè)隊(duì)列
截圖
目前這樣寫好像有問題，遇到了死鎖問題。
demo里邊只有監(jiān)聽一個(gè)隊(duì)列，consume是否是阻塞進(jìn)程。
請教監(jiān)聽多個(gè)隊(duì)列應(yīng)該怎么處理，是需要開啟多個(gè)worker，然后不同worker監(jiān)聽不同隊(duì)列嗎？
使用的是這個(gè)庫 https://github.com/walkor/rabbitmq

3021 1 0
1個(gè)回答
six

目測這個(gè)客戶端是非阻塞的客戶端，不會(huì)阻塞進(jìn)程。是否阻塞運(yùn)行 php start.php status 看下就知道了，如果消費(fèi)者是busy就是阻塞的。

感覺應(yīng)該可以一個(gè)客戶端訂閱多個(gè)消息，如果不行就建立多個(gè)客戶端唄，沒必要一個(gè)隊(duì)列開一個(gè)worker。

foreach ($subjects as $subject) {
    (new Client())->connect()->then(function (Client $client) {
        return $client->channel();
    })->then(function (Channel $channel) {
        $channel->consume(.....);
    });
}
  • ani 2021-11-15

    好的，謝謝，我看狀態(tài)是busy
年代過于久遠(yuǎn)，無法發(fā)表回答
??