activemq消息堆積 ActiveMQ中消費(fèi)者是怎么接收消息的?
ActiveMQ中消費(fèi)者是怎么接收消息的?在ActiveMQ中,消息生產(chǎn)者不能知道消息消費(fèi)者是否收到了消息,因?yàn)橄l(fā)送和接收是兩個(gè)相對(duì)獨(dú)立的過程。生產(chǎn)者將消息發(fā)送給mom,當(dāng)mom響應(yīng)收到的消息時(shí)1
ActiveMQ中消費(fèi)者是怎么接收消息的?
在ActiveMQ中,消息生產(chǎn)者不能知道消息消費(fèi)者是否收到了消息,因?yàn)橄l(fā)送和接收是兩個(gè)相對(duì)獨(dú)立的過程。生產(chǎn)者將消息發(fā)送給mom,當(dāng)mom響應(yīng)收到的消息時(shí)
1。在上圖中定義消息發(fā)送和消耗的過程
2。為消息定義消息協(xié)議,如ActiveMQ、stomp、XMPP等。定義消息協(xié)議,定義消息隊(duì)列需要滿足的場景
是否要保證消息的可靠性,必要時(shí)要保證存儲(chǔ)的高可用性
是否支持同步和異步消息
是否要保證消息的順序
是否需要延遲消息要支持
很多開源的實(shí)現(xiàn)功能可以參考詳細(xì)信息。例如,rocketmq是高度可靠的,Kafka是高吞吐量的,但不是高度可靠的。