在利用Hibernate開發DAO模塊時,我們和Session打的交道最多,所以如何合理的管理Session,避免Session的頻繁創建和銷毀,對於提高系統的性能來說是非常重要的,以往是通過eclipse的插件來自動完成這些代碼的,當然效果是不錯的,但是總是覺得不爽(沒有讀懂那些冗長的代碼),所以現在打算自己實現Session管理的代碼。我們知道Session是由SessionFactory負責創建的,而SessionFactory的實現是線程安全的,多個並發的線程可以同時訪問一個SessionFactory並從中獲取Session實例,那麼Session是否是線程安全的呢?很遺憾,答案是否定的。Session中包含了數據庫操作相關的狀態信息,那麼說如果多個線程同時使用一個Session實例進行CRUD,就很有可能導致數據存取的混亂,你能夠想像那些你根本不能預測執行順序的線程對你的一條記錄進行操作的情形嗎?
在Session的眾多管理方案中,我們今天來認識一種名為ThreadLocal模式的解決方案。
早在Java1.2推出之時,Java平台中就引入了一個新的支持:java.lang.ThreadLocal,給我們在編寫多線程程序時提供了一種新的選擇。ThreadLocal是什麼呢?其實ThreadLocal並非是一個線程的本地實現版本,它並不是一個Thread,而是thread local variable(線程局部變量)。也許把它命名為ThreadLocalVar更加合適。線程局部變量(ThreadLocal)其實的功用非常簡單,就是為每一個使用該變量的線程都提供一個變量值的副本,是每一個線程都可以獨立地改變自己的副本,而不會和其它線程的副本沖突。從線程的角度看,就好像每一個線程都完全擁有一個該變量。
ThreadLocal是如何做到為每一個線程維護變量的副本的呢?其實實現的思路很簡單,在ThreadLocal類中有一個Map,用於存儲每一個線程的變量的副本。比如下面的示例實現(為了簡單,沒有考慮集合的泛型):
1. public class ThreadLocal {
2. private Map values = Collections.synchronizedMap(new HashMap());
3. public Object get() {
4. Thread currentThread = Thread.currentThread();
5. Object result = values.get(currentThread);
6. if(result == null&&!values.containsKey(currentThread)) {
7. result = initialValue();
8. values.put(currentThread, result);
9. }
10. return result;
11. }
12. public void set(Object newValue) {
13. values.put(Thread.currentThread(), newValue);
14. }
15. public Object initialValue() {
16. return null;
17. }
18. }
那麽具體如何利用ThreadLocal來管理Session呢?Hibernate官方文檔手冊的示例之中,提供了一個通過ThreadLocal維護Session的好榜樣:
1. public class HibernateUtil {
2. public static final SessionFactory sessionFactory;
3. static {
4. try {
5. sessionFactory = new Configuration().configure()
6. .buildSessionFactory();
7. } catch (Throwable ex) {
8. throw new ExceptionInInitializerError(ex);
9. }
10. }
11. public static final ThreadLocal session =
12. new ThreadLocal();
13. public static Session currentSession() throws HibernateException {
14. Session s = session.get();
15. if(s == null) {
16. s = sessionFactory.openSession();
17. session.set(s);
18. }
19. return s;
20. }
21. public static void closeSession() throws HibernateException {
22. Session s = session.get();
23. if(s != null) {
24. s.close();
25. }
26. session.set(null);
27. }
28. }