如何在spring事務(wù)中正確進(jìn)行遠(yuǎn)程調(diào)用
本篇內(nèi)容介紹了“如何在spring事務(wù)中正確進(jìn)行遠(yuǎn)程調(diào)用”的有關(guān)知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！
冷水灘ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場景，ssl證書未來市場廣闊！成為創(chuàng)新互聯(lián)的ssl證書銷售渠道，可以享受市場價格4-6折優(yōu)惠！如果有意向歡迎電話聯(lián)系或者加微信：13518219792（備注：SSL證書合作）期待與您的合作！
前言
最近和朋友聊天，他說他承接的外包項目遇到了分布式事務(wù)問題，問我有沒啥解決方案，我本可以直接跟他說，分布式事務(wù)方案網(wǎng)上一大堆，什么tcc、可靠消息一致性、最大努力通知之類的，直接網(wǎng)上找個試下，比如直接用阿里的seata。但我并沒有這么做，因為分布式事務(wù)，本來就是一個很復(fù)雜的課題，真正落地的時候，會發(fā)現(xiàn)有時候是多種分布式方案一起混用，而非一種方案走到黑。
因此我就跟他說，能不用分布式事務(wù)，就盡量不用，后來我就問了一下他的業(yè)務(wù)場景，場景也不是很復(fù)雜，就是邀請好友注冊，然后可以增加積分，朋友實現(xiàn)邏輯的偽代碼大概如下
@Transactional(rollbackFor = Exception.class)
public Boolean inviteUser(..){
userService.add(..);
integralService.addIntegration(..,20)
}其中integralService是一個遠(yuǎn)程積分服務(wù)，20為增加的積分值。這代碼乍一看是沒問題，我想可能很多朋友都會這么寫。后邊我就問朋友說你們這個業(yè)務(wù)場景是否允許如下場景
允不允許邀請的用戶入庫成功，而積分入庫失??？
允不允許邀請的用戶入庫失敗，而積分入庫成功？
朋友思考了一下，說第二種不允許，第一種方式可以通過補償?shù)姆绞皆黾臃e分。
現(xiàn)在我們回過頭來看這段代碼，我拋出以下兩個問題，看文章的朋友可以思考下
如果添加積分請求耗時特別長，這段代碼有沒有問題？
如果添加積分因為網(wǎng)絡(luò)抖動原因出了異常，這段代碼有沒有問題？
這邊說下我的想法
耗時過長，會導(dǎo)致長事務(wù)的發(fā)生，在并發(fā)場景下，可能會導(dǎo)致數(shù)據(jù)庫連接得不到釋放
網(wǎng)絡(luò)抖動出了異常，可能會導(dǎo)致用戶服務(wù)的添加邏輯進(jìn)行回滾
解決耗時過長，有些朋友可能想到可以采用異步的方式，積分抖動異常，可以通過添加熔斷機制，比如積分超時沒響應(yīng)，就直接進(jìn)行熔斷
今天我再說一種方案，就是在事務(wù)提交后再進(jìn)行調(diào)用，羅里吧嗦一大堆，才剛要進(jìn)入正題，哈哈
如何在spring的事務(wù)中正確的進(jìn)行遠(yuǎn)程調(diào)用
通過spring的事務(wù)同步管理器
這個是個什么鬼，這是我直譯，它的真身是長如下
org.springframework.transaction.support.TransactionSynchronizationManager
這玩意有啥用，可以利用它注冊一個事務(wù)同步器，這個事務(wù)同步器，可以允許在事務(wù)提交后，做一些事情，核心代碼如下
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
@Override
public void afterCommit() {
//做你想做的業(yè)務(wù)
}
});看了代碼，想必大家都知道怎么改造上面邀請用戶，添加積分了吧
@Transactional(rollbackFor = Exception.class)
public Boolean inviteUser(..) {
userService.add(..);
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
@Override
public void afterCommit() {
integralService.addIntegration(..,20)
}
});但大家發(fā)現(xiàn)沒有，每次都要寫這么一坨代碼，看著是不是很惡心，有沒有什么改造的方案。 答案有的，通過注解+aop來整合實現(xiàn)，具體實現(xiàn)邏輯，可以查看下面demo鏈接中的
com.github.lybgeek.transactional
我這邊就不貼具體代碼了，為什么不貼，是因為我要介紹另外一種方案，就是基于spring的事件驅(qū)動實現(xiàn)
通過TransactionalEventListener注解+ApplicationEventPublisher
這是spring的事件驅(qū)動實現(xiàn)，或者說是觀察者實現(xiàn)方式，不過TransactionalEventListener注解是spring4.2版本之后才提供的注解
通過這種方式如何改造上面邀請用戶，添加積分的實現(xiàn)？
1、在邀請用戶注冊方法中，進(jìn)行事件發(fā)布
偽代碼如下
@Transactional(rollbackFor = Exception.class)
public Boolean inviteUser(..) {
userService.add(..);
applicationEventPublisher.publishEvent(..);
});2、編寫一個事務(wù)監(jiān)聽器，并在里面觸發(fā)添加積分實現(xiàn)
偽代碼如下
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
public void addIntegration(..){
integralService.addIntegration(..,20)
}這邊有個細(xì)節(jié)點要注意，就是監(jiān)聽事件的參數(shù)要和發(fā)布的參數(shù)一致
3、實現(xiàn)核心源碼
@Override
public void onApplicationEvent(ApplicationEvent event) {
if (TransactionSynchronizationManager.isSynchronizationActive()) {
TransactionSynchronization transactionSynchronization = createTransactionSynchronization(event);
TransactionSynchronizationManager.registerSynchronization(transactionSynchronization);
}
else if (this.annotation.fallbackExecution()) {
if (this.annotation.phase() == TransactionPhase.AFTER_ROLLBACK && logger.isWarnEnabled()) {
logger.warn("Processing " + event + " as a fallback execution on AFTER_ROLLBACK phase");
}
processEvent(event);
}
else {
// No transactional event execution at all
if (logger.isDebugEnabled()) {
logger.debug("No transaction is active - skipping " + event);
}
}
}不知道大家發(fā)現(xiàn)沒有，他本質(zhì)上還是使用了TransactionSynchronizationManager，只是對他再一次進(jìn)行封裝
總結(jié)
在和朋友交流后，發(fā)現(xiàn)他們那個外包項目開發(fā)人員就只有三個，然后服務(wù)拆分了10來個，我就問他說這個外包項目業(yè)務(wù)有很復(fù)雜嗎，他說其實還好，我就問他說業(yè)務(wù)不復(fù)雜，開發(fā)人員也不多，為什么不用單體架構(gòu)，而要用微服務(wù)。他給我的答案是甲方爸爸覺得他們項目未來會承載很大的業(yè)務(wù)量，所以必須得用微服務(wù)，而且現(xiàn)在的主流技術(shù)棧是微服務(wù)。聽到這個答復(fù)，我是該說是過度設(shè)計還是高瞻遠(yuǎn)矚呢？技術(shù)日新月異，鬼知道后面會不會出現(xiàn)更厲害的東西，架構(gòu)從來都不是一步到位，而是逐步演進(jìn)
demo鏈接
https://github.com/lyb-geek/springboot-learning/tree/master/springboot-transation-after-commit
“如何在spring事務(wù)中正確進(jìn)行遠(yuǎn)程調(diào)用”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識可以關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實用文章！
網(wǎng)頁名稱：如何在spring事務(wù)中正確進(jìn)行遠(yuǎn)程調(diào)用
文章來源：http://m.jiaotiyi.com/article/gicgco.html