channel.queueDeclare("delayed-queue",true,false,false, args); channel.queueBind("delayed-queue","delayed-exchange","delayed-queue"); 在上述代碼中,將隊列綁定到延時交換機(jī)上,并設(shè)置了隊列的 TTL 參數(shù)為 5000 毫秒,即消息在發(fā)送到隊列后,如果在 5000 毫秒內(nèi)沒有被消費(fèi)者消費(fèi),則會被轉(zhuǎn)發(fā)到delayed-exchang...
www.dbjr.com.cn/program/288961m...htm 2025-6-10