sharding-jdbc
由于生產或者QA環(huán)境下的數(shù)據庫是按主從進行部署，在業(yè)務上默認讀操作會使用從庫查詢來實現(xiàn)與主庫的讀寫分離，提高性能掀宋。但是不可避免的是 主從延遲 的存在扎唾，此時就需要我們切換到主庫進行查詢操作，來保證業(yè)務的正常執(zhí)行械媒。在現(xiàn)有技術棧背景下，是通過使用sharding-jdbc的主庫路由切換到主庫上的评汰。主庫路由在使用上需要注意下面幾個點:
在進行數(shù)據庫路由的時候會使用到HintManager.getInstance() 纷捞，它會將HintManager實例放入ThreadLocal中，該ThreadLocal清除的方式有兩種:
- 調用HintManager.close()手動清除
- 由sharding-jdbc自動支持被去，當數(shù)據庫連接被歸還到連接池后自動清除
自動清除的方式又可以分為兩種:
- 有事務主儡，當前事務執(zhí)行結束之后，會釋放連接编振，同時清除該ThreadLocal
- 沒有事務缀辩，spring-data-jpa的方法 findone等，或者native sql 執(zhí)行完成之后也會釋放連接踪央，同時清除ThreadLocal
如果不清除該ThreadLocal會導致什么后果臀玄？
- 當下次請求到同一線程的時候，調用HintManager.getInstance()發(fā)現(xiàn)ThreadLocal中已經有值了畅蹂，拋出異常
等待GC清除ThreadLocal健无，由于ThreadLocal中在存儲結構實際上是一個weakReference，gc發(fā)生會清除弱引用液斜，但是實際上存儲的實例還在累贤，與此同時這就導致了造成了內存泄漏(實際上不會有這種情況，因為HintManager使用的ThreadLocal是靜態(tài)成員變量)
需要避免下面這種錯誤寫法:
void test() {
HintManager hintManager = HintManager.getInstance();
hintManager.setMasterRouteOnly();
// 1.做了一些其它非數(shù)據庫的操作少漆，可能會出現(xiàn)異常(比如查詢redis, 數(shù)據校驗等)
pupuRedissonHash.getMulti();
// 2.查詢數(shù)據庫
repository.findOne();
}
- 上面這段代碼如果在1中出現(xiàn)了異常臼膏，會導致ThreadLocal沒有被清除，再下次請求用到了同一個線程(比如dubbo線程)就出現(xiàn)異常
- 上面這段代碼如果能正常的執(zhí)行到2的話示损，一旦2執(zhí)行結束后就會清除ThreadLocal渗磅，保證了下次請求使用到相同線程的正常執(zhí)行
在討論過了ThreadLocal清除方式的情況下，可以發(fā)現(xiàn)下述代碼產生的兩種不同情況了:
// 沒有事務先主庫路由检访，再多次查詢
void testNoTransaction() {
HintManger hintManager = HintManger.getInstance();
hintManager.setMasterRouteOnly();
repository.findOne(); // 1. 查詢的是主庫始鱼，同時清除ThreadLocal
repository.findOne(); // 2. 查詢的是從庫，因為ThreadLocal被清除了
}
// 有事務先主庫路由脆贵，再多次查詢
@Transactional
void testHasTransaction() {
HintManger hintManager = HintManger.getInstance();
hintManager.setMasterRouteOnly();
repository.findOne(); // 1. 查詢的是主庫医清，事務還沒結束，不清除ThreadLocal
repository.findOne(); // 2. 查詢的是主庫卖氨，因為ThreadLocal還沒被清除
} // 事務結束会烙，歸還數(shù)據庫連接负懦，清除ThreadLocal
在討論完了自動清除的場景，下述代碼表述了手動清除ThreadLocal:
// 使用try finally進行清除
void testManualClearByTryFinally(DTO dto) {
HintManger hintManager = HintManger.getInstance();
hintManager.setMasterRouteOnly();
try {
checkDTO(dto);
redissonHash.getMulti();
repository.findOne();
} finally {
hintManager.close();
}
}
// 使用try-with-resource進行清除
void testManualClearByTryWithResource(DTO dto) {
try (HintManager ignored = routeToMaster()) {
checkDTO(dto);
redissonHash.getMulti();
repository.findOne();
}
}
HintManager routeToMaster() {
HintManger hintManager = HintManger.getInstance();
hintManager.setMasterRouteOnly();
return hintManager;
}
建議：在使用
HintManager.getInstance()后持搜，不確定在此之后執(zhí)行的代碼是否會出現(xiàn)異常的情況下密似，使用try finally或者try-with-resource手動清除ThreadLocal
