ActiveMQ中消費(fèi)者是怎么接收消息的？在ActiveMQ中，消息生產(chǎn)者不能知道消息消費(fèi)者是否收到了消息，因?yàn)橄l(fā)送和接收是兩個(gè)相對(duì)獨(dú)立的過(guò)程。生產(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ú)立的過(guò)程。生產(chǎn)者將消息發(fā)送給mom，當(dāng)mom響應(yīng)收到的消息時(shí)

1。在上圖中定義消息發(fā)送和消耗的過(guò)程

2。為消息定義消息協(xié)議，如ActiveMQ、stomp、XMPP等。定義消息協(xié)議，定義消息隊(duì)列需要滿足的場(chǎng)景

是否要保證消息的可靠性，必要時(shí)要保證存儲(chǔ)的高可用性

是否支持同步和異步消息

是否要保證消息的順序

是否需要延遲消息要支持

很多開(kāi)源的實(shí)現(xiàn)功能可以參考詳細(xì)信息。例如，rocketmq是高度可靠的，Kafka是高吞吐量的，但不是高度可靠的。