學(xué)習(xí)spring事務(wù)與消息隊列
在開發(fā)過程中，遇到一個bug，產(chǎn)生bug的原因是spring事務(wù)提交晚于消息隊列的生產(chǎn)消息，導(dǎo)致消息隊列消費消息時獲取到的數(shù)據(jù)不正確。這篇文章介紹問題的產(chǎn)生和一步步的解決過程。
一.問題的產(chǎn)生：
場景還原：接口中的一個方法，首先修改訂單狀態(tài)，然后向消息隊列中生產(chǎn)消息，消息隊列的消費者獲取到消息檢測訂單狀態(tài)，發(fā)現(xiàn)訂單狀態(tài)未更改。
代碼：
@Service(orderApi)
public class OrderApiImpl implements OrderApi {
@Resource MqService mqService;
@OrderDao orderDao;
public void push(String orderId) {
// 更新訂單狀態(tài)，之前的狀態(tài)是1
updateStatus(orderId, 3);
// 產(chǎn)生消息
mqService.produce(orderId);
}
public viod updateStatus(String orderId, Integer status) {
orderDao.updateStatus(orderId, status);
}
}
問題產(chǎn)生原因：orderApi中的所有方法都有事務(wù)，事務(wù)類型PROPAGATION_REQUIRED，所以push方法對數(shù)據(jù)的操作會在push代碼全部執(zhí)行之后提交，而在事務(wù)提交之前消息隊列的消息已經(jīng)產(chǎn)生所以消息隊列中消費到的訂單從數(shù)據(jù)庫查詢出的狀態(tài)可能還為1。為了讓bug現(xiàn)象更明顯，可以在push方法最后添加：
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
這樣就會發(fā)現(xiàn)消費消息時，訂單狀態(tài)一定是未修改的。
二.問題的解決：
解決方案：在更新數(shù)據(jù)時，新建一個事物，保證更新代碼執(zhí)行完成后，更新數(shù)據(jù)庫的事務(wù)已被提交。（確保消息產(chǎn)生前數(shù)據(jù)庫操作已提交）
按照上述方案，我首先想到的是直接修改updateStatus方法的事務(wù)類型；我將此方法的事務(wù)類型改為PROPAGATION_REQUIRES_NEW（新建事務(wù)，如果當(dāng)前存在事務(wù)，把當(dāng)前事務(wù)掛起）。
但是這么做有兩點不合適：
1.強制修改了updateStaus的事務(wù)類型，可能影響其他流程。
2.未起到作用，updateStaus方法中沒有新建事務(wù)。
關(guān)于第二點的解釋：spring添加事務(wù)是通過BeanNameAutoProxyCreator實現(xiàn)的動態(tài)代理，只是給bean對象添加了事務(wù)，現(xiàn)在在類內(nèi)部調(diào)用方法，是不會觸發(fā)新事物的創(chuàng)建的。
所以在經(jīng)過以上嘗試后，我創(chuàng)建了一個新的類：
@Service("orderExtApi")
public class OrderExtApiImpl {
@Resource OrderApi orderApi;
public void updateStatusNewPropagation(String orderId) {
orderApi.updateStatus(orderId);
}
}
并為updateStatusNewPropagation方法添加事務(wù)PROPAGATION_REQUIRES_NEW
這個類就只是為了給orderApi中的updateStaus方法新起一個事務(wù)。
ok，到此為止bug已經(jīng)解決了。
但是代碼中還是存在問題：對數(shù)據(jù)庫的操作已經(jīng)提交，如果生產(chǎn)消息出現(xiàn)異常對業(yè)務(wù)邏輯來說還是錯誤的。所以需要檢測消息的產(chǎn)生是否完成。
最終orderApi中的代碼如下：
@Service(orderApi)
public class OrderApiImpl implements OrderApi {
@Resource MqService mqService;
@Resource OrderDao orderDao;
@Resource OrderExtApiImpl orderExtApi;
public void push(String orderId) {
// 更新訂單狀態(tài)，之前的狀態(tài)是1
orderExtApi.updateStatusNewPropagation(orderId, 3);
// 產(chǎn)生消息--produce會檢測是否出現(xiàn)異常 當(dāng)返回1時表示生產(chǎn)消息成功
Response response = mqService.produce(orderId);
if (response.getCode() != 1) {
log.info("消息隊列生產(chǎn)消息異常：" + response.getErrorMsg())
// 生產(chǎn)消息異常，重置狀態(tài) 等待下次重新執(zhí)行
orderExtApi.updateStatusNewPropagation(orderId, 1);
}
}
public viod updateStatus(String orderId, Integer status) {
orderDao.updateStatus(orderId, status);
}
}
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
Spring核心容器之ApplicationContext上下文啟動準(zhǔn)備詳解
這篇文章主要介紹了Spring核心容器之ApplicationContext上下文啟動準(zhǔn)備詳解,ApplicationContext 繼承自 BeanFactory ,其不僅包含 BeanFactory 所有功能,還擴展了容器功能,需要的朋友可以參考下2023-11-11
這篇文章主要介紹了Java中的動態(tài)和靜態(tài)編譯實例詳解的相關(guān)資料,需要的朋友可以參考下2017-04-04
這篇文章主要介紹了SpringBoot開發(fā)之?dāng)r截器實例,Spring?Boot簡介Spring?Boot發(fā)展史SpringBoot的魅力SpringBoot的優(yōu)點總結(jié)Spring?Boot是一個基于Spring框架的快速開發(fā)腳手架,它簡化了Spring應(yīng)用的初始化和搭建過程,需要的朋友可以參考下2023-09-09
springboot中@Async默認線程池導(dǎo)致OOM問題
這篇文章主要介紹了springboot中@Async默認線程池導(dǎo)致OOM問題，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-06-06
本文主要講解了Zookeeper的基礎(chǔ)知識，ZooKeeper提供了一個通用協(xié)調(diào)模式實現(xiàn)方法的開源共享庫，使程序員免于寫這類通用的協(xié)議。關(guān)于Zookeeper更多相關(guān)知識，感興趣的小伙伴參考一下這篇文章2021-09-09
Java畢業(yè)設(shè)計實戰(zhàn)項目之在線服裝銷售商城系統(tǒng)的實現(xiàn)流程
elasticsearch源碼分析index?action實現(xiàn)方式