馬老師前端技術(shù)之CSS
定時(shí)消息會(huì)暫存在名為 SCHEDULE_TOPIC_XXXX 的 Topic 中,并根據(jù) delayTimeLevel 存入特定的 queue,queueId = delayTimeLevel – 1,即一個(gè)queue只存相同延遲的消息,保證具有相同發(fā)送延遲的消息能夠順序消費(fèi)。Broker會(huì)調(diào)度地消費(fèi) SCHEDULE_TOPIC_XXXX ,將消息寫入真實(shí)的 Topic。
需要注意的是,定時(shí)消息會(huì)在第一次寫入和調(diào)度寫入真實(shí)topic時(shí)都會(huì)計(jì)數(shù),因此發(fā)送數(shù)量、tps都會(huì)變高。
標(biāo)簽: