本篇內(nèi)容介紹了“如何在spring事務中正確進行遠程調(diào)用”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

冷水灘ssl適用于網(wǎng)站、小程序/APP、API接口等需要進行數(shù)據(jù)傳輸應用場景，ssl證書未來市場廣闊！成為創(chuàng)新互聯(lián)的ssl證書銷售渠道，可以享受市場價格4-6折優(yōu)惠！如果有意向歡迎電話聯(lián)系或者加微信：13518219792（備注：SSL證書合作）期待與您的合作！

前言

最近和朋友聊天，他說他承接的外包項目遇到了分布式事務問題，問我有沒啥解決方案，我本可以直接跟他說，分布式事務方案網(wǎng)上一大堆，什么tcc、可靠消息一致性、最大努力通知之類的，直接網(wǎng)上找個試下，比如直接用阿里的seata。但我并沒有這么做，因為分布式事務，本來就是一個很復雜的課題，真正落地的時候，會發(fā)現(xiàn)有時候是多種分布式方案一起混用，而非一種方案走到黑。

因此我就跟他說，能不用分布式事務，就盡量不用，后來我就問了一下他的業(yè)務場景，場景也不是很復雜，就是邀請好友注冊，然后可以增加積分，朋友實現(xiàn)邏輯的偽代碼大概如下

    @Transactional(rollbackFor = Exception.class)
    public Boolean inviteUser(..){
        userService.add(..);
        integralService.addIntegration(..,20)
    }

其中integralService是一個遠程積分服務，20為增加的積分值。這代碼乍一看是沒問題，我想可能很多朋友都會這么寫。后邊我就問朋友說你們這個業(yè)務場景是否允許如下場景

• 允不允許邀請的用戶入庫成功，而積分入庫失??？

• 允不允許邀請的用戶入庫失敗，而積分入庫成功？

朋友思考了一下，說第二種不允許，第一種方式可以通過補償?shù)姆绞皆黾臃e分。

現(xiàn)在我們回過頭來看這段代碼，我拋出以下兩個問題，看文章的朋友可以思考下

• 如果添加積分請求耗時特別長，這段代碼有沒有問題？

• 如果添加積分因為網(wǎng)絡抖動原因出了異常，這段代碼有沒有問題？

這邊說下我的想法

• 耗時過長，會導致長事務的發(fā)生，在并發(fā)場景下，可能會導致數(shù)據(jù)庫連接得不到釋放

• 網(wǎng)絡抖動出了異常，可能會導致用戶服務的添加邏輯進行回滾

解決耗時過長，有些朋友可能想到可以采用異步的方式，積分抖動異常，可以通過添加熔斷機制，比如積分超時沒響應，就直接進行熔斷

今天我再說一種方案，就是在事務提交后再進行調(diào)用，羅里吧嗦一大堆，才剛要進入正題，哈哈

如何在spring的事務中正確的進行遠程調(diào)用

通過spring的事務同步管理器

這個是個什么鬼，這是我直譯，它的真身是長如下

org.springframework.transaction.support.TransactionSynchronizationManager

這玩意有啥用，可以利用它注冊一個事務同步器，這個事務同步器，可以允許在事務提交后，做一些事情，核心代碼如下

TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
            @Override
            public void afterCommit() {
                //做你想做的業(yè)務
            }
        });

看了代碼，想必大家都知道怎么改造上面邀請用戶，添加積分了吧

 @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的事件驅動實現(xiàn)

通過TransactionalEventListener注解+ApplicationEventPublisher

這是spring的事件驅動實現(xiàn)，或者說是觀察者實現(xiàn)方式，不過TransactionalEventListener注解是spring4.2版本之后才提供的注解

通過這種方式如何改造上面邀請用戶，添加積分的實現(xiàn)？

1、在邀請用戶注冊方法中，進行事件發(fā)布

偽代碼如下

  @Transactional(rollbackFor = Exception.class)
  public Boolean inviteUser(..) {
        userService.add(..);
         applicationEventPublisher.publishEvent(..);
        });

2、編寫一個事務監(jiān)聽器，并在里面觸發(fā)添加積分實現(xiàn)

偽代碼如下

    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
    public void addIntegration(..){
        integralService.addIntegration(..,20)
    }

這邊有個細節(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，只是對他再一次進行封裝

總結

在和朋友交流后，發(fā)現(xiàn)他們那個外包項目開發(fā)人員就只有三個，然后服務拆分了10來個，我就問他說這個外包項目業(yè)務有很復雜嗎，他說其實還好，我就問他說業(yè)務不復雜，開發(fā)人員也不多，為什么不用單體架構，而要用微服務。他給我的答案是甲方爸爸覺得他們項目未來會承載很大的業(yè)務量，所以必須得用微服務，而且現(xiàn)在的主流技術棧是微服務。聽到這個答復，我是該說是過度設計還是高瞻遠矚呢？技術日新月異，鬼知道后面會不會出現(xiàn)更厲害的東西，架構從來都不是一步到位，而是逐步演進

demo鏈接

https://github.com/lyb-geek/springboot-learning/tree/master/springboot-transation-after-commit

“如何在spring事務中正確進行遠程調(diào)用”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關的知識可以關注創(chuàng)新互聯(lián)網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實用文章！

分享名稱：如何在spring事務中正確進行遠程調(diào)用
網(wǎng)站路徑：http://chinadenli.net/article20/gicgco.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供外貿(mào)網(wǎng)站建設、電子商務、品牌網(wǎng)站建設、商城網(wǎng)站、做網(wǎng)站、App開發(fā)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)