ActiveMQ面試題及答案有哪些

這篇文章主要介紹“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()方法會負責任的等待服務器的返回，也就不會關閉連接導致消息丟失了。

關于“ActiveMQ面試題及答案有哪些”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識，可以關注億速云行業資訊頻道，小編每天都會為大家更新不同的知識點。