快捷導(dǎo)航

ShardingJdbc讀寫分離的BUG踩坑解決

更新時(shí)間：2022年08月29日 10:02:01 作者：女友在高考

這篇文章主要為大家介紹了ShardingJdbc讀寫分離的BUG踩坑解決，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

前言

最近公司準(zhǔn)備接入ShardingJdbc做讀寫分離了，老大讓我們理一理有沒有寫完數(shù)據(jù)立馬讀的場(chǎng)景，因?yàn)橹鲝耐绞怯醒舆t的，如果寫完讀取數(shù)據(jù)走到從庫(kù)，而從庫(kù)正好有延遲，沒讀取到數(shù)據(jù)，豈不是造成了生產(chǎn)事故。

今天我們來看看，ShardingJdbc作為一個(gè)成熟的框架是怎么處理寫完數(shù)據(jù)立即讀取的場(chǎng)景的。

數(shù)據(jù)庫(kù)介紹

我本地使用了兩個(gè)庫(kù)來做實(shí)驗(yàn)，寫庫(kù)（ds_0_master）和讀庫(kù)(ds_0_salve)，兩個(gè)庫(kù)并沒有配置主從，但也不影響實(shí)驗(yàn)操作。

庫(kù)里有一個(gè)city 表。主庫(kù)的 city 表沒有數(shù)據(jù)，而從庫(kù)的 city 表就一條數(shù)據(jù)。數(shù)據(jù)內(nèi)容如下：

我們討論 4 種業(yè)務(wù)場(chǎng)景：

常規(guī)寫完讀
在一個(gè) service 里面調(diào)用另一個(gè) service2 進(jìn)行讀
在一個(gè) service 里面新開一個(gè)線程去調(diào)用 service2
在一個(gè) service 里面調(diào)用 service2，但 service2 是新開的事務(wù)

先直接上實(shí)驗(yàn)結(jié)果：

1. 常規(guī)寫完讀

@Service
public class CityService {
    @Autowired
    private CityRepository cityRepository;
    @Autowired
    private CityService2 cityService2;
    @Transactional(rollbackFor = Exception.class)
    public void test(){
        City city=new City();
        city.setName("眉山");
        city.setProvince("四川");
        cityRepository.save(city);
        List&lt;City&gt; all = cityRepository.findAll();
        all.forEach(x-&gt;{
            System.out.println("cityService:"+((x.getProvince().equals("四川"))?"主庫(kù)":"從庫(kù)")+":"+x);
        });
    }
}

打印結(jié)果：

實(shí)驗(yàn)分析：我們對(duì) city 表進(jìn)行插入后，緊接著對(duì) city 表進(jìn)行了查詢，查出的內(nèi)容是我們剛剛插入的內(nèi)容。說明查詢操作沒有走讀庫(kù)，而是走了主庫(kù)。

2. 在一個(gè) service 里面調(diào)用另一個(gè) service

代碼如下：

 @Transactional(rollbackFor = Exception.class)
    public void test(){
        City city=new City();
        city.setName("眉山");
        city.setProvince("四川");
        cityRepository.save(city);
        //調(diào)用其他service
        cityService2.test();
        List&lt;City&gt; all = cityRepository.findAll();
        all.forEach(x-&gt;{
            System.out.println("cityService:"+((x.getProvince().equals("四川"))?"主庫(kù)":"從庫(kù)")+":"+x);
        });
    }
}

service2 的代碼：

public void test(){
    List&lt;City&gt; all = cityRepository.findAll();
    all.forEach(x-&gt;{
        System.err.println("cityService2:"+((x.getProvince().equals("四川"))?"主庫(kù)":"從庫(kù)")+":"+x);
    });
}

打印結(jié)果：

實(shí)驗(yàn)分析：在 service 方法里調(diào)用了其他 service，其他 service 也會(huì)受到影響。service2 也是走的主庫(kù)。

3. 新開一個(gè)線程去調(diào)用 service2

代碼如下：

@Service
public class CityService {
    @Autowired
    private CityRepository cityRepository;
    @Autowired
    private CityService2 cityService2;
    @Transactional(rollbackFor = Exception.class)
    public void test(){
        City city=new City();
        city.setName("眉山");
        city.setProvince("四川");
        cityRepository.save(city);
        new Thread(()-&gt;{cityService2.test();}).start();
        List&lt;City&gt; all = cityRepository.findAll();
        all.forEach(x-&gt;{
            System.out.println("cityService:"+((x.getProvince().equals("四川"))?"主庫(kù)":"從庫(kù)")+":"+x);
        });
    }
}

@Service
public class CityService2 {
    @Autowired
    private CityRepository cityRepository;
    public void test(){
        List&lt;City&gt; all = cityRepository.findAll();
        all.forEach(x-&gt;{
            System.err.println("cityService2:"+((x.getProvince().equals("四川"))?"主庫(kù)":"從庫(kù)")+":"+x);
        });
    }
}

打印結(jié)果：

實(shí)驗(yàn)分析：我們新開了線程對(duì) city 表進(jìn)行查詢，此次查詢讀的是從庫(kù)。新開的線程會(huì)走從庫(kù)，我猜想是新開的線程它認(rèn)為是沒有寫入/修改操作，所以走了從庫(kù)。

我又改動(dòng)了 service2，加了一段寫入操作。代碼如下：

    public void test(){
        City city=new City();
        city.setName("成都");
        city.setProvince("四川");
        cityRepository.save(city);
        List&lt;City&gt; all = cityRepository.findAll();
        all.forEach(x-&gt;{
            System.err.println("cityService2:"+((x.getProvince().equals("四川"))?"主庫(kù)":"從庫(kù)")+":"+x);
        });
    }

再次執(zhí)行，結(jié)果如下：

和預(yù)想的不一樣，依舊是走的從庫(kù)。

4. service2 新開一個(gè)事務(wù)執(zhí)行

我們調(diào)整 service2 的事務(wù)傳播行為級(jí)別。代碼如下：

@Transactional(propagation = Propagation.REQUIRES_NEW)
    public void test(){
        List&lt;City&gt; all = cityRepository.findAll();
        all.forEach(x-&gt;{
            System.err.println("cityService2:"+((x.getProvince().equals("四川"))?"主庫(kù)":"從庫(kù)")+":"+x);
        });
    }

REQUIRES_NEW 的含義是：

強(qiáng)制自己開啟一個(gè)新的事務(wù),如果一個(gè)事務(wù)已經(jīng)存在,那么將這個(gè)事務(wù)掛起.如 ServiceA.methodA()調(diào)用 ServiceB.methodB(),methodB()上的傳播級(jí)別是 PROPAGATION_REQUIRES_NEW 的話,那么如果 methodA 報(bào)錯(cuò),不影響 methodB 的事務(wù),如果 methodB 報(bào)錯(cuò),那么 methodA 是可以選擇是回滾或者提交的,就看你是否將 methodB 報(bào)的錯(cuò)誤拋出還是 try catch 了.

打印結(jié)果：

實(shí)驗(yàn)分析：這個(gè)結(jié)果確實(shí)是沒想到，service2 新開了個(gè)事務(wù)走的是主庫(kù)，而 service 里面的同一個(gè)事務(wù)里的寫后讀，反而走了從庫(kù)。

實(shí)驗(yàn)總結(jié)：

場(chǎng)景	service	service2
同一個(gè) service 里寫完讀	主庫(kù)	主庫(kù)
service 里寫完調(diào)用另一個(gè) servcie 進(jìn)行讀操作	主庫(kù)	主庫(kù)
service 里寫完新開線程調(diào)用另一個(gè) servcie 進(jìn)行讀操作	主庫(kù)	從庫(kù)
service 里寫完新開一個(gè)事務(wù)調(diào)用另一個(gè) servcie 進(jìn)行讀操作	從庫(kù)	主庫(kù)

常規(guī)的寫完讀操作和寫完在另一個(gè) service 里進(jìn)行讀操作，都能夠走到主庫(kù)，保證了常規(guī)業(yè)務(wù)的正確性，也滿足了我們一般的使用場(chǎng)景了。而新開線程進(jìn)行讀操作的情況其實(shí)比較少，如果非要使用，我們可以用強(qiáng)制指定主庫(kù)的方式進(jìn)行處理。

最后一種情況，service中調(diào)用另一個(gè)service2（新開事務(wù)），原本 service 里同一個(gè)事務(wù)的寫完讀操作走到了從庫(kù)，一不注意容易引起實(shí)際業(yè)務(wù)bug，需要使用者謹(jǐn)慎使用。大家覺得這是不是ShardingJdbc的一個(gè)BUG呢？

以上就是ShardingJdbc讀寫分離的BUG踩坑解決的詳細(xì)內(nèi)容，更多關(guān)于ShardingJdbc讀寫分離BUG的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: