如何配置Hibernate中的二级缓存

拧巴人

需要启动二级缓存，二级缓存的scope是sessionFactory。也就是说二级缓存的数据可以在由相同SessionFactory创建的多个Session中重用。
5 L2 |/ V0 V8 n$ E; W
首先，要在hibernate.cfg.xml中设置一个cache Provider，hibernate支持多个cache实现，有EHCache，OSCache等。在非分布式环境中可以选择默认的EHCache。添加ehcahe jar

1. <dependency>
   2 O/ n: N( O9 F) ?" T! w6 N
2.           <groupId>org.hibernate</groupId>
   
3.           <artifactId>hibernate-ehcache</artifactId>
   0 i; o" I& I: V- ~# d8 q
4.           <version>4.3.5.Final</version>
   
5.       </dependency>

复制代码

1. <hibernate-configuration>
   
2.     <session-factory>
   0 g! N2 ?, ]* d; ^8 U- ?3 _
3.         <property name="connection.driver_class">com.mysql.jdbc.Driver</property>
   " ?9 S/ k& W0 F* Y+ Z
4.         <property name="connection.url">jdbc:mysql://localhost/test</property>
   9 W1 ]; P/ h. V% j: i6 G/ B
5.         <property name="connection.username">root</property>
   
6.         <property name="connection.password"></property>
   2 V0 Z# p0 w) \  G3 K) t5 p" K
7.         <property name="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</property>
   
8.         <property name="hibernate.show_sql">true</property>
   0 X- {  x: D! u4 j- w
9.         <property name="hibernate.hbm2ddl.auto">update</property>
   & [3 B" e0 v5 H
10.         <property name="hibernate.generate_statistics">true</property>
    
11.         <property name="hibernate.cache.region.factory_class">
    + s  s* X6 `/ a
12.             org.hibernate.cache.ehcache.EhCacheRegionFactory
    
13.         </property>
    
14.         <mapping class="com.xinglongjian.entity.hbm.Book2"/>
    6 c1 P0 G3 y+ n1 ~/ n- X0 x
15. </hibernate-configuration>

复制代码

第二，通过ehcache.xml配置EHCache，该文件放置于classpath的根目录下。可以在该配置文件中设置将不同的对象存储在不同的regions。

1. <ehcache>
   0 y! W) [4 d/ z
2. <diskStore path="c:/data/ehcache"/>
   5 D* ^' p$ X/ W+ C6 o1 H
3. <defaultCache
   4 E6 J2 t# M! @) ~& |- \6 n2 r* ?
4.         maxElementsInMemory="10"
   
5.         eternal="false"
   
6.         overflowToDisk="true"
   
7.         timeToIdleSeconds="120"
   
8.         timeToLiveSeconds="120"
   
9.         diskPersistent="false"
   
10.         diskExpiryThreadIntervalSeconds="120"/>
    $ G' _& c0 M  J) I* D, w
11. <cache name="com.xinglongjian.entity.hbm.Book" maxElementsInMemory="10"  eternal="false"
    
12.     overflowToDisk="false" timeToIdleSeconds="120" timeToLiveSeconds="120" diskPersistent="false"/>
    
13. </ehcache>

复制代码

第三，设置持久化类

1. @Entity
   . \2 \. L% M% m% c& b  ]
2. @Cacheable
   
3. @Cache(usage=CacheConcurrencyStrategy.READ_ONLY,region="com.xinglongjian.entity.hbm.Book")
   
4. public class Book2 {
   
5.     @Id
   % X6 S6 ?# o* F* D" ^3 F
6.     @GeneratedValue
   
7.     private int id;
   ; k, J+ `1 S' A& @1 t# L
8.     private String title;
   
9.     public String getTitle() {
   ' E3 l$ r, s) w. G  c
10.         return title;
    5 a* U+ M4 b9 f+ y! N
11.     }
    
12.     public void setTitle(String title) {
    
13.         this.title = title;
    
14.     }
    
15.     public int getId() {
    / g" r7 \( [# M; l! ~
16.         return id;
    " F& Z( \) \4 l$ n- K
17.     }
    
18.     public void setId(int id) {
    7 m, d, G# E# C
19.         this.id = id;
    
20.     }
    ) t9 H; E. v1 W
21.     @Override
    
22.     public int hashCode() {
    , B' s! q$ u3 P( B1 T+ @+ Q
23.         final int prime = 31;
    ; V$ e1 H1 ]: X- {
24.         int result = 1;
    
25.         result = prime * result + id;
    
26.         result = prime * result + ((title == null) ? 0 : title.hashCode());
    
27.         return result;
    8 k: N/ D2 C7 ]9 n' c' V. @
28.     }
    
29.     @Override
    ) z" o8 Q) W% @4 P0 A8 t) c
30.     public boolean equals(Object obj) {
    
31.         if (this == obj)
    
32.             return true;
    
33.         if (obj == null)
    9 k$ X- n' J, f$ p3 W! o5 f/ V
34.             return false;
    ! ~$ q- M9 g- ~, D! J
35.         if (getClass() != obj.getClass())
    
36.             return false;
    : J- `9 @$ S: a, S" p' r
37.         Book2 other = (Book2) obj;
    , R4 H$ e+ T$ j" ^1 c( Q) d! A/ B: i
38.         if (id != other.id)
    * x5 }! q; L) h1 b$ N% F# U
39.             return false;
    
40.         if (title == null) {
    
41.             if (other.title != null)
    
42.                 return false;
    6 k9 M3 s- e5 m3 y
43.         } else if (!title.equals(other.title))
    
44.             return false;
    " a& ~3 U; _- F; l, c
45.         return true;
    
46.     }
    / r8 G% e( z6 z8 z- P
47.    
    $ a2 `1 V4 A$ z* V
48. }

复制代码

二级缓存的持久化类必须实现equals方法。

只有在SELECT时才会缓存。

在同一个session里，查询2个不同的对象，会缓存2次，

1. Session sess=sf.openSession();
   
2.         Book2 b=(Book2) sess.get(Book2.class, 17);
   
3.         System.out.println(b);
   , t4 s6 O' ~+ _  X
4.         assertEquals("spring Recipes", b.getTitle());
   1 M8 g; k: U" o3 Z) i
5.         Book2 b3=(Book2) sess.get(Book2.class, 18);
   
6.         assertEquals("dfad", b3.getTitle());
   / C8 S& m7 D' D) m( b3 E
7.         sess.close();
   ' R& Z# i  |/ y" H8 q' B
8.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
   % H. p# B1 |6 h$ Q- I' W/ \3 ]- }  e
9.         System.out.println(slcs);

复制代码

结果

1. SecondLevelCacheStatistics[hitCount=0,missCount=2,putCount=2,elementCountInMemory=2,elementC
   
2. ountOnDisk=0,sizeInMemory=3948]

复制代码

在同一个session里，查询相同的对象，会先查询一级缓存，一级缓存中有就不会查询二级缓存。

1. Session sess1=sf.openSession();
   
2.         Book2 b1=(Book2) sess1.get(Book2.class, 17);
   ! R( Q! e; ]9 c! T! y/ V5 v  A' @8 L
3.         System.out.println(b);
   * t% F* B. {1 |# k* ]1 D
4.         Book2 b2=(Book2) sess1.get(Book2.class, 17);
   
5.         assertEquals("Spring Recipes", b1.getTitle());
   
6.         assertEquals("Spring Recipes", b2.getTitle());
   
7.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
   ! e; m  b1 u% A6 W3 i9 b& r
8.         System.out.println(slcs);

复制代码

结果，在新的session中，一级缓存不可用，就会使用二级缓存。

1. SecondLevelCacheStatistics[hitCount=1,missCount=2,putCount=2,elementCountInMemory=2,elementC
   8 V  l$ q" B# Q0 d
2. ountOnDisk=0,sizeInMemory=3948]

复制代码

完整测试逻辑

1. @Test
   
2.     public void test2LCache()
   8 F6 w9 P0 j1 `- U& H' k" d
3.     {
   
4.         Statistics stat=sf.getStatistics();//获取stat对象
   
5.         Session sess=sf.openSession();
   
6.         Transaction tx=sess.beginTransaction();
   
7.         
   
8.         //存储对象，此时不会放到缓存中
   
9.         System.out.println("--------------存储对象---------------------------------");
   - f% k$ ^' |+ r: M# m2 V* |
10.         Book2 book=new Book2();
    - d/ Y. }+ T1 Q* m9 B* D
11.         book.setTitle("Spring Recipes");
    
12.         sess.saveOrUpdate(book);
    4 ?/ O* l, s" A) w* `
13.         tx.commit();
    
14.         sess.close();
    
15.         System.out.println(book);
    $ D# {3 y) W( [9 Z
16.         SecondLevelCacheStatistics slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    1 K" h* f2 n. d: ?7 E
17.         System.out.println(slcs);
    - v" e- S6 [: k" ^, S  E/ k
18.         Cache cache=sf.getCache();
    
19.         System.out.println(cache);
    2 P) H' w' t. f4 R% d1 d
20.         cache.evictAllRegions();//从所有region中获取数据
    " a! e% p  c4 b+ s
21.         Map map=slcs.getEntries();
      u9 K7 a. P$ o7 n
22.         System.out.println("Cache entries:"+map.size());
    
23.         System.out.println("--------------第一次查询后---------------------------------");
    
24.         sess=sf.openSession();
    $ J, v7 ^8 D+ i# Q/ I2 c
25.         tx=sess.beginTransaction();
    ( Z( y# K2 Q9 L) k! `
26.         Book2 b1=(Book2) sess.byId(Book2.class).load(book.getId());//第一次查询
    
27.         System.out.println(b1);
    & j1 P, N& [% h/ C
28.         assertEquals(book, b1);
    4 U, V8 S. n1 U" q5 j  z' c. z8 r
29.         tx.commit();
    2 t9 H( T) S3 q( e' h" ^9 ~/ v
30.         sess.close();
    
31.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
32.         System.out.println(slcs);
    
33.         map=slcs.getEntries();
    , F, F- D0 A& a. @( T
34.         System.out.println(map.size());
    
35.         System.out.println("--------------第二次查询后---------------------------------");
    
36.         sess=sf.openSession();
    $ U4 a" }- r+ e( _4 _8 k
37.         tx=sess.beginTransaction();
    
38.         Book2 b2=(Book2) sess.byId(Book2.class).load(book.getId());//第二次查询
    
39.         System.out.println(b2);
    # }& t% Y( a. l! h1 s$ `4 Y. }
40.         assertEquals(book, b2);
    5 ^- j1 G, o6 _* H3 z. }( |  x, g
41.         tx.commit();
    
42.         sess.close();
    
43.         
    
44.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
45.         System.out.println(slcs);
    
46.         // this is the initial select
    
47.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    
48.         // we put one element in the cache from the miss
    3 p( P" C3 u) \( U; h
49.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    
50.         // we still didn't hit the cache, because of 1L cache
    $ ?6 V4 V. M) z; X- H
51.         assertEquals(stat.getSecondLevelCacheHitCount(), 1);
    8 Z: s+ a8 e! w& G5 T7 O: D1 u9 K
52.         System.out.println("--------------第三次查询后---------------------------------");
    
53.         sess=sf.openSession();
    
54.         tx=sess.beginTransaction();
    
55.         b1=(Book2) sess.byId(Book2.class).load(book.getId());//第三次查询
    : c0 _# m& h9 G+ s& L! y; y
56.         assertEquals(book, b1);
    
57.         tx.commit();
    
58.         sess.close();
    . t" _$ ~: U, [
59.         
    6 l8 H0 F# ^* n- a: I# w
60.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
61.         System.out.println(slcs);
    . g3 v5 Z- C3 c5 a% u2 ^
62.         // same miss count (we should hit now)
    ! C# {) a( \( K" m. W7 G
63.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    
64.         // same put count (we didn't put anything new)
    8 n' _+ k! w. C# D8 K
65.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    
66.         // now we hit the 2L cache for load
    
67.         assertEquals(stat.getSecondLevelCacheHitCount(), 2);
    
68.         
    2 t# Z! R% j7 _$ d* b
69.     }

复制代码

完整测试结果

1. Hibernate: delete from book2
   
2. --------------存储对象---------------------------------
   + @  P2 b7 i" P( [4 T- b, w6 m
3. Hibernate: insert into Book2 (title) values (?)
   
4. com.xinglongjian.entity.hbm.Book2@521e083b
   3 |- v0 J3 Y. ]  @; b* }
5. SecondLevelCacheStatistics[hitCount=0,missCount=0,putCount=0,elementCountInMemory=0,elementCountOnDisk=0,sizeInMemory=0]
   ! p, G: b  Y+ J2 P9 r# M  D7 K
6. org.hibernate.internal.CacheImpl@4830f6
   
7. Cache entries:0
   
8. --------------第一次查询后---------------------------------
   
9. Hibernate: select book2x0_.id as id1_0_0_, book2x0_.title as title2_0_0_ from Book2 book2x0_
   5 b) F" ~8 C0 _) G1 R
10. where book2x0_.id=?
    
11. com.xinglongjian.entity.hbm.Book2@521e083b
    7 o* f# Q8 t" c/ t; {. D
12. SecondLevelCacheStatistics[hitCount=0,missCount=1,putCount=1,elementCountInMemory=1,elementC
    2 V  A7 d, X1 e3 n2 N4 O
13. ountOnDisk=0,sizeInMemory=1979]
    0 L% A( Y- v- _  h6 [
14. 1
    - d) T8 X. x0 A- d+ t5 P
15. --------------第二次查询后---------------------------------
    1 e8 r" A7 T4 b5 z
16. com.xinglongjian.entity.hbm.Book2@521e083b
    8 a" F4 f# N+ `4 b) k# l
17. SecondLevelCacheStatistics[hitCount=1,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
18. ountOnDisk=0,sizeInMemory=1979]
    ; M/ D9 b# t  ^, S3 e
19. --------------第三次查询后---------------------------------
    
20. SecondLevelCacheStatistics[hitCount=2,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
21. ountOnDisk=0,sizeInMemory=1979]

复制代码

6 z( s: `& E( s( _7 {3 H