目錄結(jié)構(gòu)

引入 maven依賴(lài)

?<parent>
????<groupid>org.springframework.boot</groupid>
????<artifactid>spring-boot-starter-parent</artifactid>
????<version>1.5.4.RELEASE</version>
????<relativepath></relativepath>?
??</parent>
??<properties>
????<project.build.sourceencoding>UTF-8</project.build.sourceencoding>
????<project.reporting.outputencoding>UTF-8</project.reporting.outputencoding>
????<java.version>1.8</java.version>
??</properties>
??<dependencies>
????<dependency>
??????<groupid>org.springframework.boot</groupid>
??????<artifactid>spring-boot-starter</artifactid>
????</dependency>
????<dependency>
??????<groupid>org.springframework.boot</groupid>
??????<artifactid>spring-boot-starter-web</artifactid>
????</dependency>
????<dependency>
??????<groupid>org.springframework.boot</groupid>
??????<artifactid>spring-boot-starter-test</artifactid>
??????<scope>test</scope>
????</dependency>
????<dependency>
??????<groupid>org.springframework.boot</groupid>
??????<artifactid>spring-boot-starter-activemq</artifactid>
????</dependency>
??</dependencies>
??<build>
????<plugins>
??????<plugin>
????????<groupid>org.springframework.boot</groupid>
????????<artifactid>spring-boot-maven-plugin</artifactid>
??????</plugin>
????</plugins>
??</build>

引入 application.yml配置

spring:
?activemq:
??broker-url:?tcp://127.0.0.1:61616
??user:?admin
??password:?admin
queue:?springboot-queue
server:
?port:?8080

創(chuàng)建QueueConfig

@Configuration
public?class?QueueConfig?{
??@Value("${queue}")
??private?String?queue;

??@Bean
??public?Queue?logQueue()?{
????return?new?ActiveMQQueue(queue);
??}

??@Bean
??public?JmsTemplate?jmsTemplate(ActiveMQConnectionFactory?activeMQConnectionFactory,?Queue?queue)?{
????JmsTemplate?jmsTemplate?=?new?JmsTemplate();
????jmsTemplate.setDeliveryMode(2);//?進(jìn)行持久化配置?1表示非持久化，2表示持久化
????jmsTemplate.setConnectionFactory(activeMQConnectionFactory);
????jmsTemplate.setDefaultDestination(queue);?//?此處可不設(shè)置默認(rèn)，在發(fā)送消息時(shí)也可設(shè)置隊(duì)列
????jmsTemplate.setSessionAcknowledgeMode(4);//?客戶(hù)端簽收模式
????return?jmsTemplate;
??}

??//?定義一個(gè)消息監(jiān)聽(tīng)器連接工廠(chǎng)，這里定義的是點(diǎn)對(duì)點(diǎn)模式的監(jiān)聽(tīng)器連接工廠(chǎng)
??@Bean(name?=?"jmsQueueListener")
??public?DefaultJmsListenerContainerFactory?jmsQueueListenerContainerFactory(
??????ActiveMQConnectionFactory?activeMQConnectionFactory)?{
????DefaultJmsListenerContainerFactory?factory?=?new?DefaultJmsListenerContainerFactory();
????factory.setConnectionFactory(activeMQConnectionFactory);
????//?設(shè)置連接數(shù)
????factory.setConcurrency("1-10");
????//?重連間隔時(shí)間
????factory.setRecoveryInterval(1000L);
????factory.setSessionAcknowledgeMode(4);
????return?factory;
??}
}

創(chuàng)建生產(chǎn)者：

@SpringBootApplication
@Component
@EnableScheduling
public?class?Producer?{
??
??@Autowired
??private?JmsMessagingTemplate?jmsMessagingTemplate;
??
??@Autowired
??private?Queue?queue;
??
??@Scheduled(fixedDelay=3000)
??public?void?send()?{
????String?result?=?System.currentTimeMillis()+"---測(cè)試";
????System.out.println("result"+result);
????jmsMessagingTemplate.convertAndSend(queue,result);
??}
??public?static?void?main(String[]?args)?{
????SpringApplication.run(Producer.class,?args);
??}
}

創(chuàng)建消費(fèi)者的application.yml

spring:
?activemq:
??broker-url:?tcp://127.0.0.1:61616
??user:?admin
??password:?admin
queue:?springboot-queue
server:
?port:?8081

創(chuàng)建消費(fèi)者：

@Component
@SpringBootApplication
public?class?consumer?{

??private?int?count?=0;
??
??@JmsListener(destination?=?"${queue}")
??public?void?receive(TextMessage?textMessage,Session?session)?throws?JMSException?{
????String?text?=?textMessage.getText();
????
????System.out.println("消費(fèi):"+text+"第幾次獲取消息count："+(++count));
????
????System.out.println();
????String?jmsMessageID?=?textMessage.getJMSMessageID();
??}
?
??public?static?void?main(String[]?args)?{
????SpringApplication.run(consumer.class,args);
??}
}

結(jié)果顯示：

以上是怎么在SpringBoot中整合ActiveMQ的詳細(xì)內(nèi)容。更多信息請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！