ShardingJdbc讀寫分離的BUG踩坑解決

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

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

前言

最近公司準備接入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ù)內容如下：

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

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

先直接上實驗結果：

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);
        });
    }
}

打印結果：

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

2. 在一個 service 里面調用另一個 service

代碼如下：

 @Transactional(rollbackFor = Exception.class)
    public void test(){
        City city=new City();
        city.setName("眉山");
        city.setProvince("四川");
        cityRepository.save(city);
        //調用其他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);
    });
}

打印結果：

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

3. 新開一個線程去調用 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);
        });
    }
}

打印結果：

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

我又改動了 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í)行，結果如下：

和預想的不一樣，依舊是走的從庫。

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

我們調整 service2 的事務傳播行為級別。代碼如下：

@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 的含義是：

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

打印結果：

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

實驗總結：

場景	service	service2
同一個 service 里寫完讀	主庫	主庫
service 里寫完調用另一個 servcie 進行讀操作	主庫	主庫
service 里寫完新開線程調用另一個 servcie 進行讀操作	主庫	從庫
service 里寫完新開一個事務調用另一個 servcie 進行讀操作	從庫	主庫