rabbitmq有沒(méi)有辦法一個(gè)消費(fèi)者消費(fèi)多個(gè)隊(duì)列啊

2494911084@qq.com 2023-09-04

rabbitmq有沒(méi)有辦法一個(gè)消費(fèi)者消費(fèi)多個(gè)隊(duì)列啊，現(xiàn)在創(chuàng)建了2000多個(gè)消費(fèi)者進(jìn)程，服務(wù)器給我干爆了

之前使用hyperf創(chuàng)建多個(gè)消費(fèi)者進(jìn)程來(lái)綁定隊(duì)列進(jìn)行消費(fèi)的，但是內(nèi)存占的太高了

 1730  2 0

chaz6chez 2023-09-05

有，但沒(méi)必要

白鵠 2023-09-05

無(wú)路由模式

2494911084@qq.com 2023-09-05

rabbitmq服務(wù)端是別人的我這里只負(fù)責(zé)消費(fèi)，可以只創(chuàng)建一個(gè)消費(fèi)者來(lái)消費(fèi)所有生產(chǎn)者投遞的消息嗎
白鵠 2023-09-05

那不行有生產(chǎn)者啟動(dòng)時(shí)的 route類型來(lái)決定
chaz6chez 2023-09-05

其實(shí)可以，用basic get + timer；
一個(gè)進(jìn)程啟動(dòng)多個(gè)client連接，然后在timer中輪詢basic get每個(gè)隊(duì)列的消息，然后消費(fèi)，然后分別ack；
但這樣效率不高，我覺(jué)得沒(méi)有太大意義
2494911084@qq.com 2023-09-05

交換機(jī)使用的topic模式這個(gè)模式可以實(shí)現(xiàn)一個(gè)消費(fèi)者消費(fèi)所有生產(chǎn)者投遞的數(shù)據(jù)嗎
白鵠 2023-09-05

看他的路由規(guī)則如果他的2個(gè)生產(chǎn) 是aaa.bbbb.ccc aaaa.bbbb.ddd 就可以通過(guò) aaaa.bbbb.* 來(lái)