好程序員Java學習路線分享MyBatis之線程優化

　　好程序員Java學習路線分享MyBatis之線程優化，我們的項目存在大量用戶同時訪問的情況，那么就會出現大量線程并發訪問數據庫，這樣會帶來線程同步問題，本章我們將討論MyBatis的線程同步問題和優化方法。

?

MyBatis的線程同步問題

MyBatis需要通過SqlSession實現數據庫操作，而SQLSession內部的實現需要使用JDBC的Connection連接對象，而Connection對象是非線程安全的，當多個線程同時

訪問時，就可能出現線程同步的問題。

線程同步的解決方法

我們前面學習過解決線程同步的方法是：鎖機制

我們可以給所有數據庫相關方法或代碼添加synchronized關鍵字，本質上是讓所有線程排隊執行這些操作。

這樣解決了線程同步問題，但是會帶來執行效率的降低，如果大量的用戶訪問時會導致長時間的等待，所以今天我們將學習另一種解決方法。

ThreadLocal解決線程同步

ThreadLocal（線程局部變量），可以為每個線程創建對象的副本，這樣就不存在多線程訪問一個對象的情況，以空間換時間，效率高，速度快，但是內存空間消耗更大。

ThreadLocal的用法

創建方法：

ThreadLocal<數據的類型> threadLocal = new ThreadLocal<數據類型>();

數據的類型是每個線程中需要保存數據的類型

數據存取：

void set(Object?數據)?將數據和當前線程綁定起來

Object get()?從當前線程中獲得綁定的數據

?

Session線程安全的優化方法

1）創建ThreadLocal來保存SqlSession

2）編寫獲得SqlSession的方法

1）調用ThreadLocal的get方法來獲得SqlSession

2）如果SqlSession對象為null，調用工廠來創建SqlSession，使用ThreadLocal的set方法保存到線程中，返回SqlSession對象

3）如果SqlSession對象不為null，就直接返回

示例代碼：

/**

?* MyBatis工具類

?*?用于獲得當前線程中的SqlSession

?*?使用ThreadLocal解決線程安全問題

?*/

public class MyBatisUtils {

?

????public static final String CONFIG_FILENAME = "mybatis-config.xml";

????//使用ThreadLocal保存SQLSession對象

????private static ThreadLocal<SqlSession> threadLocal = new ThreadLocal<SqlSession>();

????//SqlSession的工廠，單例

????private static SqlSessionFactory factory = null;

????/**

?????*?創建工廠

?????*/

????public static void buildFactory(){

????????try {

????????????factory = new SqlSessionFactoryBuilder().build(

????????????????????Resources.getResourceAsStream(CONFIG_FILENAME));

????????} catch (IOException e) {

????????????e.printStackTrace();

????????}

????}

????//在靜態代碼塊中執行，保證工廠的創建只執行一次

????static{

????????buildFactory();

????}

????/**

?????*?從當前線程中獲得Session

?????* @return

?????*/

????public static SqlSession getSession(){

????????//從ThreadLocal獲得線程中的SqlSession

????????SqlSession sqlSession = threadLocal.get();

????????if(sqlSession == null){

????????????//如果SqlSession為空，創建SqlSession

????????????if(factory == null){

????????????????buildFactory();

????????????}

????????????sqlSession = factory.openSession();

????????????//把新創建的SqlSession，存入到ThreadLocal,綁定到線程中

????????????threadLocal.set(sqlSession);

????????}

????????return sqlSession;

????}

????/**

?????*?關閉Session

?????*/

????public static void closeSession(){

????????//從ThreadLocal獲得線程中的SqlSession

????????SqlSession sqlSession = threadLocal.get();

????????if(sqlSession != null){

????????????//關閉會話

????????????sqlSession.close();

????????????//設置為null，gc會盡快回收

????????????sqlSession = null;

????????????//刪除掉ThreadLocal中的SqlSession

????????????threadLocal.set(null);

????????}

????}

}

?

總結

線程同步是進行JavaEE開發需要重點考慮的問題，MyBatis的SQLSession有線程同步問題，使用ThreadLocal為每個線程綁定自己的SQLSession副本，可以解決線程同步問題，同時不會降低程序執行效率。

?