.jpg)
spring boot整合activemq artemis的核心在于利用其自動化配置和依賴管理簡化jms集成。1. 添加spring-boot-starter-activemq依賴實現(xiàn)快速接入；2. 在application.properties或yml中配置broker-url、用戶信息等；3. 使用jmstemplate發(fā)送消息，支持字符串和對象的序列化；4. 通過@jmslistener注解監(jiān)聽隊列或主題，可區(qū)分隊列與主題的監(jiān)聽器；5. 可自定義jmslistenercontainerfactory以支持不同消息域和轉(zhuǎn)換器；6. 配置連接池提升性能，如使用jmspoolconnectionfactory；7. 自定義消息轉(zhuǎn)換器如mappingjackson2messageconverter處理json；8. 啟用事務(wù)管理確保消息與業(yè)務(wù)操作的一致性；9. 設(shè)置errorhandler實現(xiàn)錯誤處理與死信隊列機(jī)制；10. 生產(chǎn)環(huán)境需考慮持久化、高可用部署（如shared store或replication ha）、安全認(rèn)證授權(quán)、監(jiān)控告警及資源調(diào)優(yōu)等關(guān)鍵點，以保障系統(tǒng)的穩(wěn)定性和可靠性。
spring boot整合ActiveMQ Artemis，在我看來，核心就是利用Spring Boot的自動化配置和依賴管理能力，高效、便捷地將Artemis這個強(qiáng)大而靈活的消息中間件融入到你的應(yīng)用中。它極大地簡化了JMS（Java Message Service）的配置和使用，讓開發(fā)者能更專注于業(yè)務(wù)邏輯，而非繁瑣的底層集成細(xì)節(jié)。
Spring Boot與ActiveMQ Artemis的整合，其實遠(yuǎn)比你想象的要直接。它就像Spring Boot一貫的風(fēng)格，提供了開箱即用的解決方案。
首先，你需要確保你的項目依賴中包含了ActiveMQ的Starter。通常，spring-boot-starter-activemq就足夠了，因為它內(nèi)部已經(jīng)包含了Artemis的客戶端庫。如果你用maven，那就像這樣：
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency>
接著，配置ActiveMQ Artemis的連接信息。這部分通常在application.properties或application.yml里搞定。如果你是在本地跑一個Artemis實例，或者連接遠(yuǎn)程Broker，無非就是指定地址、端口、用戶名和密碼。
# application.properties spring.activemq.broker-url=tcp://localhost:61616 spring.activemq.user=admin spring.activemq.password=admin # 開啟JMS消息池，這是個好習(xí)慣，能提升性能 spring.jms.cache.connection-factory=true
發(fā)送消息，Spring Boot會自動配置一個JmsTemplate bean，你直接注入使用就行。這簡直是福利，省去了手動創(chuàng)建ConnectionFactory、JmsTemplate的麻煩。
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jms.core.JmsTemplate; import org.springframework.stereotype.Service; @Service public class MessageProducer { private final JmsTemplate jmsTemplate; @Autowired public MessageProducer(JmsTemplate jmsTemplate) { this.jmsTemplate = jmsTemplate; } public void sendMessage(String destination, String message) { System.out.println("Sending message to " + destination + ": " + message); jmsTemplate.convertAndSend(destination, message); } public void sendObjectMessage(String destination, MyCustomObject obj) { System.out.println("Sending object message to " + destination + ": " + obj); // Spring Boot默認(rèn)支持序列化Java對象，但更推薦使用JSON等格式 jmsTemplate.convertAndSend(destination, obj); } }
接收消息，Spring Boot提供了@JmsListener注解，這真是太方便了。你只需要在一個方法上加上這個注解，指定監(jiān)聽的隊列或主題，Spring Boot就會自動幫你處理消息的消費(fèi)。
import org.springframework.jms.annotation.JmsListener; import org.springframework.stereotype.Component; @Component public class MessageConsumer { @JmsListener(destination = "my.queue") public void receiveQueueMessage(String message) { System.out.println("Received queue message: " + message); } @JmsListener(destination = "my.topic", containerFactory = "jmsTopicListenerContainerFactory") public void receiveTopicMessage(String message) { System.out.println("Received topic message: " + message); } // 如果要接收對象消息，并且想用JSON轉(zhuǎn)換器 @JmsListener(destination = "my.object.queue", containerFactory = "jmsQueueListenerContainerFactory") public void receiveObjectMessage(MyCustomObject obj) { System.out.println("Received object message: " + obj); } }
注意，如果你需要區(qū)分隊列和主題的監(jiān)聽器，可能需要額外配置一個JmsListenerContainerFactory，比如用于主題的：
import org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.jms.config.DefaultJmsListenerContainerFactory; import org.springframework.jms.config.JmsListenerContainerFactory; import javax.jms.ConnectionFactory; @Configuration public class JmsConfig { @Bean public JmsListenerContainerFactory<?> jmsTopicListenerContainerFactory( ConnectionFactory connectionFactory, DefaultJmsListenerContainerFactoryConfigurer configurer) { DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); configurer.configure(factory, connectionFactory); factory.setPubSubDomain(true); // 開啟主題模式 return factory; } @Bean public JmsListenerContainerFactory<?> jmsQueueListenerContainerFactory( ConnectionFactory connectionFactory, DefaultJmsListenerContainerFactoryConfigurer configurer) { DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory(); configurer.configure(factory, connectionFactory); factory.setPubSubDomain(false); // 隊列模式是默認(rèn)的，但明確設(shè)置也無妨 // factory.setMessageConverter(jacksonJmsMessageConverter()); // 如果需要自定義消息轉(zhuǎn)換器 return factory; } // 如果需要發(fā)送和接收J(rèn)SON對象，可以配置一個消息轉(zhuǎn)換器 // @Bean // public MessageConverter jacksonJmsMessageConverter() { // MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter(); // converter.setTargetType(MessageType.TEXT); // converter.setTypeIdPropertyName("_type"); // return converter; // } }
ActiveMQ Artemis為何在Spring Boot生態(tài)中如此受歡迎？
在我看來，ActiveMQ Artemis在Spring Boot生態(tài)中受歡迎并非偶然，它有著幾個非常實際的優(yōu)勢，讓其在眾多消息隊列中脫穎而出。
首先，性能與資源消耗。Artemis是基于Netty構(gòu)建的，它的異步I/O模型使得其在處理高并發(fā)消息時表現(xiàn)出色，延遲低、吞吐量高。相比起一些“老牌”消息隊列，Artemis在資源占用上更為輕量，這對于微服務(wù)架構(gòu)下資源敏感的應(yīng)用來說，無疑是個巨大的加分項。我個人在實際項目中對比過，Artemis在同等負(fù)載下的表現(xiàn)確實令人滿意。
其次，多協(xié)議支持。Artemis不僅僅支持JMS，它還原生支持AMQP、MQTT、STOMP、OpenWire等多種協(xié)議。這意味著你的系統(tǒng)可以非常靈活地與不同技術(shù)棧、不同客戶端進(jìn)行集成，這在復(fù)雜的企業(yè)環(huán)境中尤其重要。比如，你可能有一個iot設(shè)備通過MQTT發(fā)送數(shù)據(jù)，同時后端服務(wù)通過JMS消費(fèi)，Artemis能完美地充當(dāng)這個橋梁。這種靈活性，讓它不僅僅是一個JMS Broker。
再者，嵌入式部署能力。Artemis可以非常方便地作為嵌入式Broker運(yùn)行在你的Spring Boot應(yīng)用內(nèi)部。這對于開發(fā)測試環(huán)境、或者一些對消息可靠性要求沒那么高、但又需要消息隊列功能的輕量級應(yīng)用來說，簡直是福音。省去了獨(dú)立部署的麻煩，開發(fā)體驗也流暢很多。雖然生產(chǎn)環(huán)境通常還是獨(dú)立部署，但這個特性在某些場景下確實很有用。
最后，社區(qū)活躍度與演進(jìn)。Artemis是apache ActiveMQ的下一代產(chǎn)品，它繼承了ActiveMQ的優(yōu)點，同時進(jìn)行了大量的優(yōu)化和改進(jìn)。社區(qū)活躍，文檔豐富，遇到問題也比較容易找到解決方案。它一直在積極演進(jìn)，不斷引入新的特性和優(yōu)化，這給了開發(fā)者信心。
如何在Spring Boot中精細(xì)化配置ActiveMQ Artemis的連接與消息處理？
當(dāng)你的應(yīng)用走向生產(chǎn)環(huán)境，或者對消息的可靠性、性能有更高要求時，僅僅依靠默認(rèn)配置是遠(yuǎn)遠(yuǎn)不夠的。Spring Boot雖然提供了極大的便利，但它也保留了讓你深入定制的能力。
一個常見的需求是連接池的優(yōu)化。Spring Boot默認(rèn)會使用CachingConnectionFactory，它會緩存Connection、Session和MessageProducer。但你可以進(jìn)一步配置其緩存大小、會話模式等。
# application.properties # 連接工廠緩存設(shè)置 spring.jms.cache.connection-factory=true spring.jms.cache.session-cache-size=10 # 每個連接緩存的會話數(shù)量
如果你需要更細(xì)粒度的控制，比如使用PooledConnectionFactory，你可能需要手動配置JmsConnectionFactory和JmsTemplate：
import org.apache.activemq.artemis.jms.client.ActiveMQJMSConnectionFactory; import org.apache.activemq.artemis.jms.client.ActiveMQXAConnectionFactory; // 如果需要XA事務(wù) import org.messaginghub.pooled.jms.JmsPoolConnectionFactory; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.jms.core.JmsTemplate; @Configuration public class CustomJmsConfig { @Bean public ActiveMQJMSConnectionFactory artemisConnectionFactory() { // 直接創(chuàng)建Artemis的ConnectionFactory return new ActiveMQJMSConnectionFactory("tcp://localhost:61616", "admin", "admin"); } @Bean(destroyMethod = "stop") public JmsPoolConnectionFactory pooledConnectionFactory(ActiveMQJMSConnectionFactory artemisConnectionFactory) { JmsPoolConnectionFactory pool = new JmsPoolConnectionFactory(); pool.setConnectionFactory(artemisConnectionFactory); pool.setMaxConnections(10); // 最大連接數(shù) pool.setBlockIfSessionPoolIsFull(true); pool.setBlockIfSessionPoolIsFullTimeout(5000); // 阻塞超時時間 return pool; } @Bean public JmsTemplate jmsTemplate(JmsPoolConnectionFactory pooledConnectionFactory) { JmsTemplate template = new JmsTemplate(); template.setConnectionFactory(pooledConnectionFactory); // template.setMessageConverter(jacksonJmsMessageConverter()); // 如果需要自定義消息轉(zhuǎn)換器 return template; } }
消息轉(zhuǎn)換器是另一個需要關(guān)注的地方。默認(rèn)情況下，JMS可以發(fā)送和接收String、Map、Bytes以及可序列化的Java對象。但在微服務(wù)和異構(gòu)系統(tǒng)集成中，JSON或xml是更常見的選擇。你可以配置MappingJackson2MessageConverter來處理JSON：
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.jms.support.converter.MappingJackson2MessageConverter; import org.springframework.jms.support.converter.MessageType; @Configuration public class MessageConverterConfig { @Bean public MappingJackson2MessageConverter jacksonJmsMessageConverter() { MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter(); converter.setTargetType(MessageType.TEXT); // 將Java對象轉(zhuǎn)換為文本消息（JSON字符串） converter.setTypeIdPropertyName("_type"); // 在消息頭中添加類型信息，方便反序列化 return converter; } } // 別忘了在JmsListenerContainerFactory或JmsTemplate中設(shè)置這個Converter
事務(wù)管理也是個核心。JMS支持本地事務(wù)和XA事務(wù)。對于簡單的“發(fā)送即確認(rèn)”或“接收即確認(rèn)”場景，可以不使用事務(wù)。但如果涉及數(shù)據(jù)庫操作和消息發(fā)送的原子性，就需要事務(wù)了。Spring的@Transactional注解可以與JMS很好地配合，但前提是你的JmsListenerContainerFactory配置了事務(wù)管理器。
// 在JmsConfig中，確保JmsListenerContainerFactory支持事務(wù) // factory.setSessionTransacted(true); // 開啟JMS會話事務(wù) // 結(jié)合Spring的PlatformTransactionManager // @Transactional 注解就可以生效了
最后，錯誤處理。消息消費(fèi)過程中難免會遇到異常。Spring Boot的@JmsListener默認(rèn)會重試，但你可能需要更細(xì)致的控制，比如死信隊列（DLQ）或者自定義錯誤處理器。你可以為JmsListenerContainerFactory設(shè)置一個ErrorHandler：
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.jms.listener.DefaultMessageListenerContainer; import org.springframework.util.ErrorHandler; @Configuration public class JmsErrorHandlerConfig { @Bean public ErrorHandler myJmsErrorHandler() { return t -> { System.err.println("JMS message processing error: " + t.getMessage()); // 這里可以記錄日志、發(fā)送告警、或者將消息轉(zhuǎn)發(fā)到死信隊列 // 避免拋出異常導(dǎo)致消息無限重試 }; } // 在JmsListenerContainerFactory中設(shè)置這個ErrorHandler // factory.setErrorHandler(myJmsErrorHandler()); }
這些精細(xì)化配置能讓你更好地掌控消息的生命周期和處理流程，確保系統(tǒng)在復(fù)雜場景下的穩(wěn)定性和可靠性。
ActiveMQ Artemis在生產(chǎn)環(huán)境部署中的關(guān)鍵考量點有哪些？
將ActiveMQ Artemis從開發(fā)測試環(huán)境推向生產(chǎn)，絕不是簡單地把代碼部署上去就完事。生產(chǎn)環(huán)境的穩(wěn)定性和高可用性是重中之重，這要求我們對Artemis的部署策略、持久化、集群、安全和監(jiān)控等方面有深入的理解和規(guī)劃。
首先，持久化。Artemis默認(rèn)會使用日志文件（journal）進(jìn)行消息持久化，這通常非常高效。但你需要考慮日志文件的存儲位置、大小以及如何防止磁盤空間耗盡。對于關(guān)鍵業(yè)務(wù)消息，必須確保它們被正確持久化。你也可以配置Artemis使用數(shù)據(jù)庫（JDBC）進(jìn)行持久化，但這通常會帶來性能開銷，除非你有特殊的集成需求。我的建議是，優(yōu)先考慮Artemis原生的Journal，它的性能表現(xiàn)通常更優(yōu)。
其次，高可用性（HA）和集群。這是生產(chǎn)環(huán)境的標(biāo)配。Artemis提供了幾種HA模式：
- 共享存儲（Shared Store）HA：多個Broker實例共享同一個持久化存儲（比如NFS、SAN）。一個Broker作為主節(jié)點活躍，其他作為備份。當(dāng)主節(jié)點故障時，備份節(jié)點會接管。這種模式實現(xiàn)簡單，但共享存儲可能成為單點故障。
- 復(fù)制（Replication）HA：這是我個人更推薦的模式。Broker之間通過網(wǎng)絡(luò)同步數(shù)據(jù)，沒有共享存儲依賴。一個Broker是主節(jié)點，其他是復(fù)制節(jié)點。主節(jié)點故障時，復(fù)制節(jié)點可以提升為主節(jié)點。這種模式提供了更高的可靠性和數(shù)據(jù)安全性，但網(wǎng)絡(luò)延遲會影響同步性能。
選擇哪種模式取決于你的業(yè)務(wù)對數(shù)據(jù)一致性、恢復(fù)時間目標(biāo)（RTO）和恢復(fù)點目標(biāo)（RPO）的要求。
再者，安全性。生產(chǎn)環(huán)境的Artemis必須配置認(rèn)證和授權(quán)。默認(rèn)的admin/admin賬戶是絕對不能用的。你需要配置用戶、角色，并為隊列和主題設(shè)置訪問權(quán)限。Artemis支持多種認(rèn)證機(jī)制，包括基于文件、LDAP、Kerberos等。對于Spring Boot應(yīng)用，連接Artemis時也需要使用配置好的安全憑證。
<!-- Artemis broker.xml 配置示例，用于安全 --> <security-settings> <security-setting match="#"> <permission type="createNonDurableQueue" roles="admin,dev"/> <permission type="deleteNonDurableQueue" roles="admin,dev"/> <permission type="createDurableQueue" roles="admin"/> <permission type="deleteDurableQueue" roles="admin"/> <permission type="send" roles="admin,producer"/> <permission type="consume" roles="admin,consumer"/> <permission type="manage" roles="admin"/> </security-setting> </security-settings>
還有監(jiān)控與告警。你需要能夠?qū)崟r監(jiān)控Artemis的運(yùn)行狀態(tài)，包括連接數(shù)、消息堆積量、內(nèi)存使用、CPU負(fù)載等。Artemis通過JMX提供了豐富的監(jiān)控指標(biāo)，你可以使用JConsole、VisualVM等工具連接，或者集成到prometheus、grafana等監(jiān)控系統(tǒng)中。設(shè)置合理的告警閾值，確保在問題發(fā)生時能及時收到通知。
最后，資源管理。這包括jvm參數(shù)調(diào)優(yōu)（內(nèi)存、GC）、文件描述符限制、網(wǎng)絡(luò)配置等。對于高吞吐量的Artemis實例，適當(dāng)增加文件描述符限制和調(diào)整JVM堆大小是很有必要的。
生產(chǎn)環(huán)境的部署是一個系統(tǒng)工程，需要綜合考慮性能、可靠性、安全和可維護(hù)性。沒有一勞永逸的方案，但遵循這些關(guān)鍵考量點，能讓你少走很多彎路。
.png)
