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