SpringBoot集成消息隊(duì)列的項(xiàng)目實(shí)踐
更新時間：2024年02月21日 10:42:02 作者：清醒的人最荒唐
本文主要介紹了SpringBoot集成消息隊(duì)列的項(xiàng)目實(shí)踐,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
背景
最近在對公司開發(fā)框架進(jìn)行優(yōu)化，框架內(nèi)涉及到多處入庫的日志記錄，例如登錄日志/操作日志/訪問日志/業(yè)務(wù)執(zhí)行日志，集成在業(yè)務(wù)代碼中耦合度較高且占用業(yè)務(wù)操作執(zhí)行時間，所以準(zhǔn)備集成相關(guān)消息隊(duì)列進(jìn)行代碼解耦
方案規(guī)劃
現(xiàn)有的成熟消息隊(duì)列組件非常多，例如RabbitMQ，ActiveMQ，Kafka等，考慮到業(yè)務(wù)并發(fā)量不高且框架已經(jīng)應(yīng)用于多個項(xiàng)目平穩(wěn)運(yùn)行，準(zhǔn)備提供基于Redis的消息隊(duì)列和集成ActiveMQ兩種方案，Redis消息隊(duì)列的好處是無需額外安裝部署存量項(xiàng)目可平穩(wěn)過度但消息無法持久化可能丟失，ActiveMQ解決方案成熟可以保證消息持久化但是需要實(shí)施人員額外掌握操作部署
統(tǒng)一設(shè)計
增加自定義配置指定消息隊(duì)列方式
system: #消息隊(duì)列方式 redis/activemq messageChannel: redis
定義消息傳輸統(tǒng)一模型
public class MessageModel {
private Class<? extends IMessageReceiver> handleClazz;
private String bodyContent;
private Class bodyClass;
private HashMap extraParam;
public MessageModel(){
extraParam = new HashMap();
}
public Class<? extends IMessageReceiver> getHandleClazz() {
return handleClazz;
}
public void setHandleClazz(Class<? extends IMessageReceiver> handleClazz) {
this.handleClazz = handleClazz;
}
public HashMap getExtraParam() {
return extraParam;
}
public void setExtraParam(HashMap extraParam) {
this.extraParam = extraParam;
}
public String getBodyContent() {
return bodyContent;
}
public void setBodyContent(String bodyContent) {
this.bodyContent = bodyContent;
}
public Class getBodyClass() {
return bodyClass;
}
public void setBodyClass(Class bodyClass) {
this.bodyClass = bodyClass;
}
}定義標(biāo)準(zhǔn)消息處理接口
public interface IMessageReceiver {
void handleMessage(Object bodyObject, HashMap extraParam);
}
定義統(tǒng)一對外發(fā)送消息工具類
@Component
public class MessageUtil {
@Autowired
private SystemConfig systemConfig;
@Autowired
private RedisUtil redisUtil;
@Autowired
private JmsMessagingTemplate jmsMessagingTemplate;
public void sendMessage(Object messageBody, Class<? extends IMessageReceiver> handleClass, HashMap<String,Object> extraParam) {
MessageModel messageModel = new MessageModel();
messageModel.setHandleClazz(handleClass);
messageModel.setBodyClass(messageBody.getClass());
messageModel.setBodyContent(JSON.toJSONString(messageBody));
if (extraParam != null) {
for (String key:extraParam.keySet()) {
messageModel.getExtraParam().put(key,extraParam.get(key));
}
}
if(systemConfig.getMessageChannel().equals("redis")){
redisUtil.sendMessage("message", JSON.toJSON(messageModel));
}else{
jmsMessagingTemplate.convertAndSend("message",JSON.toJSONString(messageModel));
}
}
}集成Redis消息隊(duì)列
pom配置
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
<version>2.0.1.RELEASE</version>
</dependency>
連接配置
spring:
redis:
host: localhost
port: 6379
password:
操作工具類
@Autowired
private RedisTemplate redisTemplate;
public void sendMessage(String channel, Object message) {
redisTemplate.convertAndSend(channel, message);
}
消息處理
@Component
@ConditionalOnProperty(name = "system.messageChannel", havingValue = "redis", matchIfMissing = true)
public class RedisMessageReceiver {
public void receiveMessage(String message) {
MessageModel messageModel = JSON.parseObject(message, MessageModel.class);
IMessageReceiver receiver = SpringBootBeanUtil.getBean(messageModel.getHandleClazz());
receiver.handleMessage(JSON.parseObject(messageModel.getBodyContent(), messageModel.getBodyClass()), messageModel.getExtraParam());
}
}
配置注冊
@Configuration
public class MessageCenter {
@Bean
@ConditionalOnProperty(name = "system.messageChannel", havingValue = "redis", matchIfMissing = true)
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
RedisMessageListenerContainer container = new RedisMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
// 可以添加多個 messageListener，配置不同的交換機(jī)
container.addMessageListener(listenerAdapter, new PatternTopic("message"));
return container;
}
/**
* 消息監(jiān)聽器適配器，綁定消息處理器，利用反射技術(shù)調(diào)用消息處理器的業(yè)務(wù)方法
*
* @param receiver
* @return
*/
@Bean
@ConditionalOnProperty(name = "system.messageChannel", havingValue = "redis", matchIfMissing = true)
MessageListenerAdapter listenerAdapter(RedisMessageReceiver receiver) {
return new MessageListenerAdapter(receiver, "receiveMessage");
}
}集成ActiveMQ消息隊(duì)列
pom配置
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-pool</artifactId>
<version>5.15.0</version>
</dependency>
注意：jdk1.8對應(yīng)版本5.15.0
連接配置
spring:
activemq:
broker-url: tcp://127.0.0.1:61616 #MQ服務(wù)器地址
user: admin
password: admin
pool:
enabled: true
消息處理
@Component
@ConditionalOnProperty(name = "system.messageChannel", havingValue = "activemq", matchIfMissing = false)
public class ActiveMQMessageReceiver {
@JmsListener(destination = "message", containerFactory = "customQueueListener")
public void handleMessage(String message) {
MessageModel messageModel = JSON.parseObject(message, MessageModel.class);
IMessageReceiver receiver = SpringBootBeanUtil.getBean(messageModel.getHandleClazz());
receiver.handleMessage(JSON.parseObject(messageModel.getBodyContent(), messageModel.getBodyClass()), messageModel.getExtraParam());
}
}
配置注冊
@Configuration
@EnableJms
public class MessageCenter {
@Bean(name = "customQueueListener")
@ConditionalOnProperty(name = "system.messageChannel", havingValue = "activemq", matchIfMissing = false)
public JmsListenerContainerFactory<?> customQueueListener(ConnectionFactory connectionFactory) {
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
factory.setPubSubDomain(false);
factory.setConnectionFactory(connectionFactory);
//重連間隔時間
factory.setRecoveryInterval(1000L);
factory.setSessionAcknowledgeMode(Session.AUTO_ACKNOWLEDGE);
//連接數(shù)
factory.setConcurrency("5-10");
//指定任務(wù)線程池
factory.setTaskExecutor(new ThreadPoolExecutor(5, 10, 1, TimeUnit.MINUTES,
new LinkedBlockingQueue<>(100), new ThreadPoolExecutor.CallerRunsPolicy()));
return factory;
}
}
使用示例
消息處理
@Service
public class RequestLogMessageReceiver implements IMessageReceiver{
@Autowired
private F_RequestLogService requestLogService;
@Override
public void handleMessage(Object bodyObject, HashMap extraParam) {
F_RequestLogDO requestLogDO = (F_RequestLogDO)bodyObject;
requestLogService.insert(requestLogDO);
}
}發(fā)送消息
@AutoWired private MessageUtil messageUtil; messageUtil.sendMessage(requestLogDO,RequestLogMessageReceiver.class,null);
到此這篇關(guān)于SpringBoot集成消息隊(duì)列的項(xiàng)目實(shí)踐的文章就介紹到這了,更多相關(guān)SpringBoot集成消息隊(duì)列內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:
- SpringBoot整合RabbitMQ消息隊(duì)列的完整步驟
- 詳解SpringBoot集成消息隊(duì)列的案例應(yīng)用
- Springboot?整合?RabbitMQ?消息隊(duì)列?詳情
- springboot整合消息隊(duì)列RabbitMQ
- SpringBoot整合消息隊(duì)列RabbitMQ
- SpringBoot基于RabbitMQ實(shí)現(xiàn)消息延時隊(duì)列的方案
- SpringBoot基于RabbitMQ實(shí)現(xiàn)消息延遲隊(duì)列方案及使用場景
- Springboot RabbitMQ 消息隊(duì)列使用示例詳解
- SpringBoot集成Redisson實(shí)現(xiàn)消息隊(duì)列的示例代碼
相關(guān)文章
Mybatis generator自動生成代碼插件實(shí)例解析
這篇文章主要介紹了Mybatis generator自動生成代碼插件實(shí)例解析,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-09-09
字符串拼接問題應(yīng)該是每個Java程序員都熟知的事情了，幾乎每個Java程序員都讀過關(guān)于StringBuffer/StringBuilder來拼接字符串。下面這篇文章主要給大家介紹了關(guān)于JDK8中的字符串拼接的相關(guān)資料，需要的朋友可以參考下。2018-04-04
這篇文章主要為大家詳細(xì)介紹了java動態(tài)代理模式，總結(jié)一下代理模式，以及jdk,cglib代理模式用法，來理解代理模式，感興趣的小伙伴們可以參考一下2016-02-02
本文主要介紹了IntelliJ IDEA快速查看某個類/接口的子類或父類，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-07-07
關(guān)于java四舍五入方法的基礎(chǔ)學(xué)習(xí)
這篇文章主要給大家介紹了關(guān)于java四舍五入方法的基礎(chǔ)學(xué)習(xí),這是最近做算法題的時候碰到的這個問題,文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2023-07-07
這篇文章主要給大家介紹了關(guān)于Java8中如何通過方法引用獲取屬性名的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-09-09
java正則匹配HTML中a標(biāo)簽里的中文字符示例
這篇文章主要介紹了java正則匹配HTML中a標(biāo)簽里的中文字符,涉及java中文正則及HTML元素操作技巧,具有一定參考借鑒價值,需要的朋友可以參考下2017-01-01
一文帶你學(xué)會規(guī)則引擎Drools的應(yīng)用
Drools?就是一個開源的業(yè)務(wù)規(guī)則引擎，可以很容易地與?spring?boot?應(yīng)用程序集成，這篇文章就來和大家詳細(xì)聊聊Drools的具體應(yīng)用，需要的可以參考一下2023-03-03
Java如何實(shí)現(xiàn)圖片裁剪預(yù)覽功能
通常注冊賬戶上傳用戶圖像時需要進(jìn)行預(yù)覽，這篇文章就是教我們?nèi)绾斡?Java 實(shí)現(xiàn)圖片裁剪預(yù)覽功能，需要的朋友可以參考下2015-07-07
java通過模擬post方式提交表單實(shí)現(xiàn)圖片上傳功能實(shí)例
這篇文章主要介紹了java通過模擬post方式提交表單實(shí)現(xiàn)圖片上傳功能實(shí)例,涉及Java針對表單的提交操作響應(yīng)及文件傳輸?shù)南嚓P(guān)技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-11-11