ActiveMQ面試題及答案有哪些

這篇文章主要介紹“ActiveMQ面試題及答案有哪些”的相關(guān)知識(shí)，小編通過實(shí)際案例向大家展示操作過程，操作方法簡單快捷，實(shí)用性強(qiáng)，希望這篇“ActiveMQ面試題及答案有哪些”文章能幫助大家解決問題。

   　1、什么是 ActiveMQ?

　　activeMQ是一種開源的，實(shí)現(xiàn)了JMS1.1規(guī)范的，面向消息(MOM)的中間件，為應(yīng)用程序提供高效的、可擴(kuò)展的、穩(wěn)定的和安全的企業(yè)級(jí)消息通信。

　　2、Activemq的瓶頸值

　　根據(jù)網(wǎng)上一般評(píng)測文檔上來看，每秒的消息吞吐在2000以上, acticemq也可以集群化部署，也是使用zookeeper來搭建。

　　3、ActiveMQ服務(wù)器宕機(jī)怎么辦?

　　這得從ActiveMQ的儲(chǔ)存機(jī)制說起。在通常的情況下，非持久化消息是存儲(chǔ)在內(nèi)存中的，持久化消息是存儲(chǔ)在文件中的，它們的最大限制在配置文件的節(jié)點(diǎn)中配置。

　　但是，在非持久化消息堆積到一定程度，內(nèi)存告急的時(shí)候，ActiveMQ會(huì)將內(nèi)存中的非持久化消息寫入臨時(shí)文件中，以騰出內(nèi)存。雖然都保存到了文件里，但它和持久化消息的區(qū)別是，重啟后持久化消息會(huì)從文件中恢復(fù)，非持久化的臨時(shí)文件會(huì)直接刪除。

　　那如果文件增大到達(dá)了配置中的最大限制的時(shí)候會(huì)發(fā)生什么?我做了以下實(shí)驗(yàn)：

　　設(shè)置2G左右的持久化文件限制，大量生產(chǎn)持久化消息直到文件達(dá)到最大限制，此時(shí)生產(chǎn)者阻塞，但消費(fèi)者可正常連接并消費(fèi)消息，等消息消費(fèi)掉一部分，文件刪除又騰出空間之后，生產(chǎn)者又可繼續(xù)發(fā)送消息，服務(wù)自動(dòng)恢復(fù)正常。

　　設(shè)置2G左右的臨時(shí)文件限制，大量生產(chǎn)非持久化消息并寫入臨時(shí)文件，在達(dá)到最大限制時(shí)，生產(chǎn)者阻塞，消費(fèi)者可正常連接但不能消費(fèi)消息，或者原本慢速消費(fèi)的消費(fèi)者，消費(fèi)突然停止。整個(gè)系統(tǒng)可連接，但是無法提供服務(wù)，就這樣掛了。

　　具體原因不詳，解決方案：盡量不要用非持久化消息，非要用的話，將臨時(shí)文件限制盡可能的調(diào)大。

　　4、AcitveMQ的作用、原理?(生產(chǎn)者、消費(fèi)者。p2p、訂閱實(shí)現(xiàn)流程)

　　Activemq的作用就是系統(tǒng)之間進(jìn)行通信。當(dāng)然可以使用其他方式進(jìn)行系統(tǒng)間通信，如果使用Activemq的話可以對(duì)系統(tǒng)之間的調(diào)用進(jìn)行解耦，實(shí)現(xiàn)系統(tǒng)間的異步通信。原理就是生產(chǎn)者生產(chǎn)消息，把消息發(fā)送給activemq。Activemq接收到消息，然后查看有多少個(gè)消費(fèi)者，然后把消息轉(zhuǎn)發(fā)給消費(fèi)者，此過程中生產(chǎn)者無需參與。消費(fèi)者接收到消息后做相應(yīng)的處理和生產(chǎn)者沒有任何關(guān)系

　　5、activemq在項(xiàng)目中如何應(yīng)用的

　　Activemq在項(xiàng)目中主要是完成系統(tǒng)之間通信，并且將系統(tǒng)之間的調(diào)用進(jìn)行解耦。例如在添加、修改商品信息后，需要將商品信息同步到索引庫、同步緩存中的數(shù)據(jù)以及生成靜態(tài)頁面一系列操作。

　　在此場景下就可以使用activemq。一旦后臺(tái)對(duì)商品信息進(jìn)行修改后，就向activemq發(fā)送一條消息，然后通過activemq將消息發(fā)送給消息的消費(fèi)端，消費(fèi)端接收到消息可以進(jìn)行相應(yīng)的業(yè)務(wù)處理

　　7、rabbitmq如何實(shí)現(xiàn)集群高可用?

　　集群是保證服務(wù)可靠性的一種方式，同時(shí)可以通過水平擴(kuò)展以提升消息吞吐能力。RabbitMQ是用分布式程序設(shè)計(jì)語言erlang開發(fā)的，所以天生就支持集群。接下來，將介紹RabbitMQ分布式消息處理方式、集群模式、節(jié)點(diǎn)類型，并動(dòng)手搭建一個(gè)高可用集群環(huán)境，最后通過java程序來驗(yàn)證集群的高可用性。

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

　　(1)Clustering：不支持跨網(wǎng)段，各節(jié)點(diǎn)需運(yùn)行同版本的Erlang和RabbitMQ，應(yīng)用于同網(wǎng)段局域網(wǎng)。

　　(2)Federation：允許單臺(tái)服務(wù)器上的Exchange或Queue接收發(fā)布到另一臺(tái)服務(wù)器上Exchange或Queue的消息,應(yīng)用于廣域網(wǎng)。

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

　　RabbitMQ對(duì)網(wǎng)絡(luò)延遲很敏感，在LAN環(huán)境建議使用clustering方式;在WAN環(huán)境中，則使用Federation或Shovel。我們平時(shí)說的RabbitMQ集群，說的就是clustering方式，它是RabbitMQ內(nèi)嵌的一種消息處理方式，而Federation或Shovel則是以plugin形式存在。

　　8、丟消息怎么辦?

　　這得從java的java.net.SocketException異常說起。簡單點(diǎn)說就是當(dāng)網(wǎng)絡(luò)發(fā)送方發(fā)送一堆數(shù)據(jù)，然后調(diào)用close關(guān)閉連接之后。這些發(fā)送的數(shù)據(jù)都在接收者的緩存里，接收者如果調(diào)用read方法仍舊能從緩存中讀取這些數(shù)據(jù)，盡管對(duì)方已經(jīng)關(guān)閉了連接。

　　但是當(dāng)接收者嘗試發(fā)送數(shù)據(jù)時(shí)，由于此時(shí)連接已關(guān)閉，所以會(huì)發(fā)生異常，這個(gè)很好理解。不過需要注意的是，當(dāng)發(fā)生SocketException后，原本緩存區(qū)中數(shù)據(jù)也作廢了，此時(shí)接收者再次調(diào)用read方法去讀取緩存中的數(shù)據(jù)，就會(huì)報(bào)Software caused connection abort: recv failed錯(cuò)誤。

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

　　當(dāng)客戶端發(fā)完消息調(diào)用connection.close()時(shí)，會(huì)期待服務(wù)器對(duì)于關(guān)閉連接的回答，如果超過15秒沒回答就直接調(diào)用socket層的close關(guān)閉tcp連接了。這時(shí)客戶端發(fā)出的消息其實(shí)還在服務(wù)器的緩存里等待處理，不過由于服務(wù)器心跳包的設(shè)置，導(dǎo)致發(fā)生了java.net.SocketException異常，把緩存里的數(shù)據(jù)作廢了，沒處理的消息全部丟失。

　　解決方案：用持久化消息，或者非持久化消息及時(shí)處理不要堆積，或者啟動(dòng)事務(wù)，啟動(dòng)事務(wù)后，commit()方法會(huì)負(fù)責(zé)任的等待服務(wù)器的返回，也就不會(huì)關(guān)閉連接導(dǎo)致消息丟失了。

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