溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章給大家介紹使用springboot如何實現對activemq進行集成，內容非常詳細，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助。
ActiveMQ
ActiveMQ 是Apache出品，最流行的，能力強勁的開源消息總線。ActiveMQ 是一個完全支持JMS1.1和J2EE 1.4規范的 JMS Provider實現，盡管JMS規范出臺已經是很久的事情了，但是JMS在當今的J2EE應用中間仍然扮演著特殊的地位。
特性
更多關于 ActiveMQ 的內容可以點擊這里。
Spring-Boot 集成 ActiveMQ
添加maven依賴
<!--
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-client</artifactId>
</dependency> 沒有直接使用注釋的依賴，是因為其含有如下依賴
<dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-broker</artifactId> </dependency>
而它的作用是什么呢，會在程序中直接內嵌 ActivityMQ，也就是說不需要安裝 ActiveMQ，但是這個如果服務宕機了，內嵌的 ActiveMQ 也就沒了。關鍵，這個內嵌的 ActiveMQ 而無法看到圖形化界面，所以這里沒有直接使用注釋里的依賴。
在application.properties中增加如下配置
# activemq spring.activemq.broker-url=tcp://localhost:61616 spring.activemq.user=admin spring.activemq.password=admin spring.activemq.in-memory=true spring.activemq.pool.enabled=false
這里對 ActiveMQ 的端口做一個簡短說明，61616為消息代理接口 ，8161 為管理界面
JAVA代碼實現
定義QUEUE
package com.activemq.queue;
import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.jms.Queue;
@Configuration
public class QueueConfig {
@Bean
public Queue logQueue() {
return new ActiveMQQueue(QueueName.LOG_QUEUE);
}
}
消息生產者
package com.activemq.producer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;
import javax.jms.Queue;
@Component
public class LogProducer implements CommandLineRunner {
private static final Logger LOGGER = LoggerFactory.getLogger(LogProducer.class);
@Autowired
private JmsMessagingTemplate jmsMessagingTemplate;
@Autowired
private Queue logQueue;
@Override
public void run(String... strings) throws Exception {
send("This is a log message.");
LOGGER.info("Log Message was sent to the Queue named sample.log");
}
public void send(String msg) {
this.jmsMessagingTemplate.convertAndSend(this.logQueue, msg);
}
}
消息消費者
package com.activemq.consumer;
import com.activemq.queue.QueueName;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;
@Component
public class LogConsumer {
private static final Logger LOGGER = LoggerFactory.getLogger(LogConsumer.class);
@JmsListener(destination = QueueName.LOG_QUEUE)
public void receivedQueue(String msg) {
LOGGER.info("Has received from " + QueueName.LOG_QUEUE + ", msg: " + msg);
}
}
測試接口
@Autowired
private LogProducer logProducer;
@GetMapping("/activemq/send")
public String activemq(HttpServletRequest request, String msg) {
msg = StringUtils.isEmpty(msg) ? "This is Empty Msg." : msg;
try {
logProducer.send(msg);
} catch (Exception e) {
e.printStackTrace();
}
return "Activemq has sent OK.";
}
啟動類
增加如下注解@EnableJms
@Configuration//配置控制
@EnableAutoConfiguration//啟用自動配置
@ComponentScan//組件掃描
@EnableConfigurationProperties({EmailProp.class})
@EnableJms
public class Bootstrap {
private static final Logger LOGGER = LoggerFactory
.getLogger(Bootstrap.class);
public static void main(String[] args) throws Exception {
SpringApplication.run(Bootstrap.class, args);
LOGGER.info("Server running...");
}
}
測試
運行服務，在瀏覽器輸入 http://127.0.0.1:8080/activemq/send?msg=test%20log，會在控制臺看到如下輸出
INFO 1498 --- [enerContainer-1] c.j.a.activemq.consumer.LogConsumer : Has received from sample.log, msg: test log [DefaultMessageListenerContainer-1] INFO c.j.a.activemq.consumer.LogConsumer - Has received from sample.log, msg: test log
打開 ActiveMQ 的管理頁面，用戶名密碼都是admin，可以看到如下信息
關于使用springboot如何實現對activemq進行集成就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
