您好,登錄后才能下訂單哦!
這篇文章將為大家詳細(xì)講解有關(guān)Spring Boot微服務(wù)怎么集成fescar解決分布式事務(wù)問題,小編覺得挺實用的,因此分享給大家做個參考,希望大家閱讀完這篇文章后可以有所收獲。
什么是fescar?
關(guān)于fescar的詳細(xì)介紹,請參閱fescar wiki。
傳統(tǒng)的2PC提交協(xié)議,會持有一個全局性的鎖,所有局部事務(wù)預(yù)提交成功后一起提交,或有一個局部事務(wù)預(yù)提交失敗后一起回滾,最后釋放全局鎖。鎖持有的時間較長,會對并發(fā)造成較大的影響,死鎖的風(fēng)險也較高。
fescar的創(chuàng)新之處在于,每個局部事務(wù)執(zhí)行完立即提交,釋放本地鎖;它會去解析你代碼中的sql,從數(shù)據(jù)庫中獲得事務(wù)提交前的事務(wù)資源即數(shù)據(jù),存放到undo_log中,全局事務(wù)協(xié)調(diào)器在回滾的時候直接使用undo_log中的數(shù)據(jù)覆蓋你提交的數(shù)據(jù)。
Spring Boot如何集成fescar?
我們可以從官方代碼庫中看到,fescar目前提供的示例是針對使用dubbo的服務(wù),那Spring Boot的項目如何集成fescar呢?
和很多2PC提交協(xié)議(如tx_lcn)的解決方案一樣,fescar也是在數(shù)據(jù)源處做了代理,和事務(wù)協(xié)調(diào)器進(jìn)行通信,來決定本地事務(wù)是否回滾。所以,第一步,在你的spring boot項目中,首先應(yīng)使用fescar提供的代理數(shù)據(jù)源作為你的數(shù)據(jù)源,例如:
DruidDataSource dataSource = initDataSource(dataSourceProps.get("url").toString(), dataSourceProps.get("username").toString(), dataSourceProps.get("password").toString()); DataSourceProxy proxy = new DataSourceProxy(dataSource);
然后,你需要創(chuàng)建一個Feign攔截器,把RootContext中的XID(XID用于標(biāo)識一個局部事務(wù)屬于哪個全局事務(wù),需要在調(diào)用鏈路的上下文中傳遞)傳遞到上層調(diào)用鏈路。
@Component public class RequestHeaderInterceptor implements RequestInterceptor { @Override public void apply(RequestTemplate template) { String xid = RootContext.getXID(); if(StringUtils.isNotBlank(xid)){ template.header("Fescar-Xid",xid); } } }
最后,你需要創(chuàng)建一個Http Rest請求攔截器,用于把當(dāng)前上下文中獲取到的XID放到RootContext。
import com.alibaba.fescar.core.context.RootContext; import org.apache.commons.lang.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.web.filter.OncePerRequestFilter; import javax.servlet.FilterChain; import javax.servlet.ServletException; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException; public class FescarXidFilter extends OncePerRequestFilter { protected Logger logger = LoggerFactory.getLogger(FescarXidFilter.class); @Override protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException { String xid = RootContext.getXID(); String restXid = request.getHeader("Fescar-Xid"); boolean bind = false; if(StringUtils.isBlank(xid)&&StringUtils.isNotBlank(restXid)){ RootContext.bind(restXid); bind = true; if (logger.isDebugEnabled()) { logger.debug("bind[" + restXid + "] to RootContext"); } } try{ filterChain.doFilter(request, response); } finally { if (bind) { String unbindXid = RootContext.unbind(); if (logger.isDebugEnabled()) { logger.debug("unbind[" + unbindXid + "] from RootContext"); } if (!restXid.equalsIgnoreCase(unbindXid)) { logger.warn("xid in change during http rest from " + restXid + " to " + unbindXid); if (unbindXid != null) { RootContext.bind(unbindXid); logger.warn("bind [" + unbindXid + "] back to RootContext"); } } } } } }
這樣就完成了fescar的集成。
開始使用吧!
首先在項目中初始化兩個Bean:
@Bean public FescarXidFilter fescarXidFilter(){ return new FescarXidFilter(); } @Bean public GlobalTransactionScanner scanner(){ GlobalTransactionScanner scanner = new GlobalTransactionScanner("fescar-test","my_test_tx_group"); return scanner; }
然后寫兩個服務(wù),服務(wù)A調(diào)用服務(wù)B,并在A服務(wù)的調(diào)用方法上打上@GlobalTransactional標(biāo)簽:
@GlobalTransactional(timeoutMills = 300000, name = "fescar-test-tx") public void testFescar() throws BusinessException { DictionVO dictionVO = new DictionVO(); dictionVO.setCode("simidatest"); dictionVO.setValue("1"); dictionVO.setDesc("simidatest"); dictionVO.setAppId("sso"); commonService.createDiction(dictionVO);//遠(yuǎn)程調(diào)用服務(wù)B areaMapper.deleteAreaBySysNo(2);//本地事務(wù) throw new BusinessException("主動報錯"); }
最后,兩個項目中添加application.conf文件,用于告訴客戶端如何與分布式協(xié)調(diào)器通信,官方示例中有這個文件,就不在此貼代碼啦,application.conf傳送門
啟動事務(wù)協(xié)調(diào)器,sh fescar-server.sh 8091 ~/dksl/git/fescar/data,啟動你的項目,開始測試吧!
last thing
分布式事務(wù)作為微服務(wù)應(yīng)用中的老大難問題,在現(xiàn)有的解決方案中,個人認(rèn)為fescar是目前最輕量并且代價最小的一種解決方案。目前的版本,事務(wù)協(xié)調(diào)器還不能分布式部署,官方給出的路線圖是在三月底會有第一個生產(chǎn)可用版本。讓我們一起參與到fescar的社區(qū)中,共同推動fescar生態(tài)建設(shè),讓落地微服務(wù)不必再擔(dān)心分布式事務(wù)的問題。
關(guān)于“Spring Boot微服務(wù)怎么集成fescar解決分布式事務(wù)問題”這篇文章就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,使各位可以學(xué)到更多知識,如果覺得文章不錯,請把它分享出去讓更多的人看到。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。