SpringBoot整合多個Mq服務做法詳解
更新時間：2023年02月14日 15:25:44 作者：chenxianchong
SpringBoot整合rabbitmq很容易，但是整合的目的是為了使用，那要使用rabbitmq就要對其有一定的了解，不然容易整成一團漿糊。因為說到底，SpringBoot只是在封裝rabbitmq的API，讓其更容易使用而已，廢話不多說，讓我們一起整它
以rabbitmq為例
springboot項目想要整合rabbitmq非常簡單，只需要在maven中引入對應的starter即可
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>然后只需要在配置文件中配置spring.rabbitmq.***即可使用。
如果我們項目中需要配置多個mq服務的時候，springboot便不能幫我們自動加載了，我們需要手動加載對應RabbitTemplate。
具體做法如下：
1、自定義一個MqTemplate
@Data
@Component
public class MqTemplate {
private RabbitTemplate rabbitTemplate;
private String exchange;
private String queue;
private String routing_key;
}在這里面我們定義了RabbitTemplate、交換機、路由，隊列，如果需要其他的數(shù)據(jù)，也可以往上加
2、定義一個mq配置項相對應的類
@Data
@Component
class MqConfiguration {
private String host;
private Integer port;
private String user;
private String password;
private String exchange;
private String queue;
private String routing_key;
}這個類的作用是將我們配置文件中的信息轉(zhuǎn)成實體類
3、將我們自定義的mq配置定義成MqTemplate類型的bean
@Configuration
public class MqConfig {
@Bean
@ConfigurationProperties(prefix = "mq.task-update-mq")
public MqConfiguration taskUpdateMqConfiguration(){
return new MqConfiguration();
}
@Bean
public MqTemplate taskUpdateMq(MqConfiguration taskUpdateMqConfiguration) {
CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
connectionFactory.setHost(taskUpdateMqConfiguration.getHost());
connectionFactory.setPort(taskUpdateMqConfiguration.getPort());
connectionFactory.setUsername(taskUpdateMqConfiguration.getUser());
connectionFactory.setPassword(taskUpdateMqConfiguration.getPassword());
connectionFactory.setVirtualHost("/");
connectionFactory.setPublisherConfirms(true); //必須要設置
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
MqTemplate mqTemplate = new MqTemplate();
mqTemplate.setRabbitTemplate(rabbitTemplate);
mqTemplate.setExchange(taskUpdateMqConfiguration.getExchange());
mqTemplate.setQueue(taskUpdateMqConfiguration.getQueue());
mqTemplate.setRouting_key(taskUpdateMqConfiguration.getRouting_key());
return mqTemplate;
}
}這里我們就將該mq配置加載成一個名為taskUpdateMq的bean。當需要添加其他的mq服務的時候，我們只需要在這個配置類里面定義bean即可
4、使用對應的Template發(fā)送消息
首先我們把taskUpdateMq注入到業(yè)務代碼中
@Autowired MqTemplate taskUpdateMq;
然后我們定義 一個發(fā)送延遲消息的接口方法
public interface MessageService {
void sendDelayMessage(MqTemplate mqTemplate, String msg, Integer delay);
}@Service
public class MessageServiceImpl implements MessageService {
@Override
public void sendDelayMessage(MqTemplate mqTemplate, String msg, Integer delay) {
mqTemplate.getRabbitTemplate().convertAndSend(mqTemplate.getExchange(), mqTemplate.getRouting_key(), msg, message -> {
message.getMessageProperties().setDeliveryMode(MessageDeliveryMode.PERSISTENT);
message.getMessageProperties().setDelay(delay);
message.getMessageProperties().setContentType("application/json");
return message;
});
}
}調(diào)用方法的時候?qū)qTemplate對象傳入就好了。
到此這篇關于SpringBoot整合多個Mq服務做法詳解的文章就介紹到這了,更多相關SpringBoot整合Mq服務內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:
相關文章
本篇文章主要介紹了深度剖析java中JDK動態(tài)代理機制 ，動態(tài)代理避免了開發(fā)人員編寫各個繁鎖的靜態(tài)代理類，只需簡單地指定一組接口及目標類對象就能動態(tài)的獲得代理對象。2017-04-04
Java如何將任意類型的Object對象轉(zhuǎn)換為相應的實體對象
這篇文章主要介紹了Java如何將任意類型的Object對象轉(zhuǎn)換為相應的實體對象問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-01-01
這篇文章主要介紹了Spring@Value屬性注入使用方法解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-01-01
這篇文章主要介紹了Spring實戰(zhàn)之容器后處理器操作,結(jié)合實例形式分析了spring容器后處理器配置、使用操作技巧與相關注意事項,需要的朋友可以參考下2019-12-12
這篇文章主要介紹了Intellij IDEA 關閉和開啟自動更新的提示操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-04-04
Java多線程高并發(fā)中解決ArrayList與HashSet和HashMap不安全的方案
ArrayList實現(xiàn)了可變大小的數(shù)組。它允許所有元素，包括null。ArrayList沒有同步，HashMap和Hashtable類似，不同之處在于HashMap是非同步的，并且允許null，關于HashSet有一件事應該牢記，即就條目數(shù)和容量之和來講，迭代是線性的，接下來讓我們詳細來了解吧2021-11-11
這篇文章主要介紹了CGLIB代理的使用與原理解析,靜態(tài)代理和JDK 代理模式都要求目標對象是實現(xiàn)一個接口,但是有時候目標對象只是一個單獨的對象,并沒有實現(xiàn)任何的接口,這個時候可使用目標對象子類來實現(xiàn)代理,這就是Cglib代理,需要的朋友可以參考下2023-09-09
教你使用eclipse?搭建Swt?環(huán)境的全過程
本文給大家分享使用eclipse?搭建Swt?環(huán)境的全過程，本文通過圖文并茂的形式給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2021-12-12
Springboot整合Netty實現(xiàn)RPC服務器的示例代碼
這篇文章主要介紹了Springboot整合Netty實現(xiàn)RPC服務器的示例代碼，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2021-01-01
Java接口返回省市區(qū)樹形結(jié)構(gòu)的實現(xiàn)
本文主要介紹了Java接口返回省市區(qū)樹形結(jié)構(gòu)的實現(xiàn)，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-01-01