快捷導(dǎo)航

ShardingJdbc讀寫分離的BUG踩坑解決

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

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

前言

最近公司準(zhǔn)備接入ShardingJdbc做讀寫分離了，老大讓我們理一理有沒有寫完數(shù)據(jù)立馬讀的場景，因為主從同步是有延遲的，如果寫完讀取數(shù)據(jù)走到從庫，而從庫正好有延遲，沒讀取到數(shù)據(jù)，豈不是造成了生產(chǎn)事故。

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

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

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

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

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

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

先直接上實驗結(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("四川"))?"主庫":"從庫")+":"+x);
        });
    }
}

打印結(jié)果：

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

2. 在一個 service 里面調(diào)用另一個 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("四川"))?"主庫":"從庫")+":"+x);
        });
    }
}

service2 的代碼：

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

打印結(jié)果：

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

3. 新開一個線程去調(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("四川"))?"主庫":"從庫")+":"+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("四川"))?"主庫":"從庫")+":"+x);
        });
    }
}

打印結(jié)果：

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

我又改動了 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("四川"))?"主庫":"從庫")+":"+x);
        });
    }

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

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

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

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

@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("四川"))?"主庫":"從庫")+":"+x);
        });
    }

REQUIRES_NEW 的含義是：

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

打印結(jié)果：

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

實驗總結(jié)：

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

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

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

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

您可能感興趣的文章: