activemq面試題(ActiveMQ面試題及答案有哪些)

　1、什么是 ActiveMQ?

　　activeMQ是一種開源的,實現了JMS1.1規范的,面向消息(MOM)的中間件,為應用程序提供高效的、可擴展的、穩定的和安全的企業級消息通信。

　　2、Activemq的瓶頸值

　　根據網上一般評測文檔上來看,每秒的消息吞吐在2000以上, acticemq也可以集群化部署,也是使用zookeeper來搭建。

　　3、ActiveMQ服務器宕機怎么辦?

　　這得從ActiveMQ的儲存機制說起。在通常的情況下,非持久化消息是存儲在內存中的,持久化消息是存儲在文件中的,它們的最大限制在配置文件的節點中配置。

　　但是,在非持久化消息堆積到一定程度,內存告急的時候,ActiveMQ會將內存中的非持久化消息寫入臨時文件中,以騰出內存。雖然都保存到了文件里,但它和持久化消息的區別是,重啟后持久化消息會從文件中恢復,非持久化的臨時文件會直接刪除。

　　那如果文件增大到達了配置中的最大限制的時候會發生什么?我做了以下實驗:

　　設置2G左右的持久化文件限制,大量生產持久化消息直到文件達到最大限制,此時生產者阻塞,但消費者可正常連接并消費消息,等消息消費掉一部分,文件刪除又騰出空間之后,生產者又可繼續發送消息,服務自動恢復正常。

　　設置2G左右的臨時文件限制,大量生產非持久化消息并寫入臨時文件,在達到最大限制時,生產者阻塞,消費者可正常連接但不能消費消息,或者原本慢速消費的消費者,消費突然停止。整個系統可連接,但是無法提供服務,就這樣掛了。

　　具體原因不詳,解決方案:盡量不要用非持久化消息,非要用的話,將臨時文件限制盡可能的調大。

　　4、AcitveMQ的作用、原理?(生產者、消費者。p2p、訂閱實現流程)

　　Activemq的作用就是系統之間進行通信。當然可以使用其他方式進行系統間通信,如果使用Activemq的話可以對系統之間的調用進行解耦,實現系統間的異步通信。原理就是生產者生產消息,把消息發送給activemq。Activemq接收到消息,然后查看有多少個消費者,然后把消息轉發給消費者,此過程中生產者無需參與。消費者接收到消息后做相應的處理和生產者沒有任何關系

　　5、activemq在項目中如何應用的

　　Activemq在項目中主要是完成系統之間通信,并且將系統之間的調用進行解耦。例如在添加、修改商品信息后,需要將商品信息同步到索引庫、同步緩存中的數據以及生成靜態頁面一系列操作。

　　在此場景下就可以使用activemq。一旦后臺對商品信息進行修改后,就向activemq發送一條消息,然后通過activemq將消息發送給消息的消費端,消費端接收到消息可以進行相應的業務處理

　　7、rabbitmq如何實現集群高可用?

　　集群是保證服務可靠性的一種方式,同時可以通過水平擴展以提升消息吞吐能力。RabbitMQ是用分布式程序設計語言erlang開發的,所以天生就支持集群。接下來,將介紹RabbitMQ分布式消息處理方式、集群模式、節點類型,并動手搭建一個高可用集群環境,最后通過java程序來驗證集群的高可用性。

　　RabbitMQ分布式的消息處理方式有以下三種:

　　(1)Clustering:不支持跨網段,各節點需運行同版本的Erlang和RabbitMQ,應用于同網段局域網。

　　(2)Federation:允許單臺服務器上的Exchange或Queue接收發布到另一臺服務器上Exchange或Queue的消息,應用于廣域網。

　　(3)Shovel:與Federation類似,但工作在更低層次。

　　RabbitMQ對網絡延遲很敏感,在LAN環境建議使用clustering方式;在WAN環境中,則使用Federation或Shovel。我們平時說的RabbitMQ集群,說的就是clustering方式,它是RabbitMQ內嵌的一種消息處理方式,而Federation或Shovel則是以plugin形式存在。

　　8、丟消息怎么辦?

　　這得從java的java.net.SocketException異常說起。簡單點說就是當網絡發送方發送一堆數據,然后調用close關閉連接之后。這些發送的數據都在接收者的緩存里,接收者如果調用read方法仍舊能從緩存中讀取這些數據,盡管對方已經關閉了連接。

　　但是當接收者嘗試發送數據時,由于此時連接已關閉,所以會發生異常,這個很好理解。不過需要注意的是,當發生SocketException后,原本緩存區中數據也作廢了,此時接收者再次調用read方法去讀取緩存中的數據,就會報Software caused connection abort: recv failed錯誤。

　　通過抓包得知,ActiveMQ會每隔10秒發送一個心跳包,這個心跳包是服務器發送給客戶端的,用來判斷客戶端死沒死。如果你看過上面第一條,就會知道非持久化消息堆積到一定程度會寫到文件里,這個寫的過程會阻塞所有動作,而且會持續20到30秒,并且隨著內存的增大而增大。

　　當客戶端發完消息調用connection.close()時,會期待服務器對于關閉連接的回答,如果超過15秒沒回答就直接調用socket層的close關閉tcp連接了。這時客戶端發出的消息其實還在服務器的緩存里等待處理,不過由于服務器心跳包的設置,導致發生了java.net.SocketException異常,把緩存里的數據作廢了,沒處理的消息全部丟失。

　　解決方案:用持久化消息,或者非持久化消息及時處理不要堆積,或者啟動事務,啟動事務后,commit()方法會負責任的等待服務器的返回,也就不會關閉連接導致消息丟失了。