如何配置Hibernate中的二级缓存

拧巴人

需要启动二级缓存，二级缓存的scope是sessionFactory。也就是说二级缓存的数据可以在由相同SessionFactory创建的多个Session中重用。

6 F8 [& J+ w! \. b8 V2 i6 X首先，要在hibernate.cfg.xml中设置一个cache Provider，hibernate支持多个cache实现，有EHCache，OSCache等。在非分布式环境中可以选择默认的EHCache。添加ehcahe jar

1. <dependency>
   
2.           <groupId>org.hibernate</groupId>
   
3.           <artifactId>hibernate-ehcache</artifactId>
   
4.           <version>4.3.5.Final</version>
   
5.       </dependency>

复制代码

1. <hibernate-configuration>
   
2.     <session-factory>
   
3.         <property name="connection.driver_class">com.mysql.jdbc.Driver</property>
   
4.         <property name="connection.url">jdbc:mysql://localhost/test</property>
   5 C# o, Y: X% W2 m: A7 r
5.         <property name="connection.username">root</property>
   
6.         <property name="connection.password"></property>
   ; Z) b7 l% ]2 Q, b
7.         <property name="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</property>
   ; q& |) R3 f; N7 ~
8.         <property name="hibernate.show_sql">true</property>
   
9.         <property name="hibernate.hbm2ddl.auto">update</property>
   
10.         <property name="hibernate.generate_statistics">true</property>
    & F- ?$ `+ @3 O0 p# D
11.         <property name="hibernate.cache.region.factory_class">
    ! R: y  \% t: Z, v# U5 G7 U! P' Z1 ]2 D
12.             org.hibernate.cache.ehcache.EhCacheRegionFactory
    
13.         </property>
    
14.         <mapping class="com.xinglongjian.entity.hbm.Book2"/>
    
15. </hibernate-configuration>

复制代码

" T# C( w% S* X  s2 u! w 第二，通过ehcache.xml配置EHCache，该文件放置于classpath的根目录下。可以在该配置文件中设置将不同的对象存储在不同的regions。

1. <ehcache>
   
2. <diskStore path="c:/data/ehcache"/>
   
3. <defaultCache
   
4.         maxElementsInMemory="10"
   
5.         eternal="false"
   
6.         overflowToDisk="true"
   
7.         timeToIdleSeconds="120"
   % f2 i' ^. a: `. d" ]7 X
8.         timeToLiveSeconds="120"
   
9.         diskPersistent="false"
   9 z9 X7 r( F8 ^* A% v6 h
10.         diskExpiryThreadIntervalSeconds="120"/>
    
11. <cache name="com.xinglongjian.entity.hbm.Book" maxElementsInMemory="10"  eternal="false"
    3 d! h1 U0 l( O& ]* J- b$ B
12.     overflowToDisk="false" timeToIdleSeconds="120" timeToLiveSeconds="120" diskPersistent="false"/>
    " n. J6 @% X6 Q+ k
13. </ehcache>

复制代码

第三，设置持久化类

1. @Entity
     N9 p5 m" [& ]0 \0 v$ Y: _6 @" t) j
2. @Cacheable
   . w/ G! P6 u. g. a) D
3. @Cache(usage=CacheConcurrencyStrategy.READ_ONLY,region="com.xinglongjian.entity.hbm.Book")
   
4. public class Book2 {
   4 l+ I0 k( F- I( }& L/ }# W& x% I9 Z
5.     @Id
   9 S& z2 k. p8 P: H
6.     @GeneratedValue
   
7.     private int id;
   ) y1 h- V0 C2 {. L- R, l7 r
8.     private String title;
   : o$ Q* x, \6 I# Z! y
9.     public String getTitle() {
   
10.         return title;
    
11.     }
    $ m1 Z9 x" \) Z1 e
12.     public void setTitle(String title) {
    1 Q6 i: C! t3 W; }+ v
13.         this.title = title;
    0 `; L* y. y% ]- Y! O2 e* C  R
14.     }
    1 h0 K- c( q5 D% v6 L# F0 R7 c$ Q
15.     public int getId() {
    
16.         return id;
    
17.     }
    3 L  H. a2 r# T& u1 D" W
18.     public void setId(int id) {
    5 v' N: p7 G4 v8 m$ k2 m
19.         this.id = id;
    
20.     }
    
21.     @Override
    
22.     public int hashCode() {
    
23.         final int prime = 31;
    
24.         int result = 1;
    8 p7 H* t" p/ i1 x0 a! Z
25.         result = prime * result + id;
    $ X0 t  s5 ^0 L$ j
26.         result = prime * result + ((title == null) ? 0 : title.hashCode());
    . [0 M: e2 ?3 m7 I  u
27.         return result;
    
28.     }
    
29.     @Override
    
30.     public boolean equals(Object obj) {
    
31.         if (this == obj)
    " K- }3 W- o. X5 t! L. H
32.             return true;
    % I, t0 l+ s& k- O- }& H
33.         if (obj == null)
    . s  ^7 D; m' o5 F, A: K
34.             return false;
    - S# H# H" `$ p. O! m1 \) f6 k% W7 q0 G
35.         if (getClass() != obj.getClass())
    ' ?* E5 a$ @% n9 z; z
36.             return false;
    2 E8 T7 G) L, |5 ]" y( D; W
37.         Book2 other = (Book2) obj;
    
38.         if (id != other.id)
    
39.             return false;
    
40.         if (title == null) {
    6 }0 _! f& ]& \7 l' L+ Z
41.             if (other.title != null)
    
42.                 return false;
    
43.         } else if (!title.equals(other.title))
    ( k9 N$ _) q3 ~2 y: F1 z) n8 V  i
44.             return false;
    
45.         return true;
    
46.     }
    
47.    
    3 X8 I9 l) E3 n% e( D2 S
48. }

复制代码

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

只有在SELECT时才会缓存。
* V1 J8 M: S1 H# h0 T
在同一个session里，查询2个不同的对象，会缓存2次，

1. Session sess=sf.openSession();
   
2.         Book2 b=(Book2) sess.get(Book2.class, 17);
   4 V: I  d3 P- M, `: J
3.         System.out.println(b);
   ! W7 O( C( _$ ^/ D4 ?4 }
4.         assertEquals("spring Recipes", b.getTitle());
   
5.         Book2 b3=(Book2) sess.get(Book2.class, 18);
   
6.         assertEquals("dfad", b3.getTitle());
   
7.         sess.close();
   3 K$ _5 h6 c. }4 x' P3 Q$ _. v5 E
8.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
   
9.         System.out.println(slcs);

复制代码

结果

1. SecondLevelCacheStatistics[hitCount=0,missCount=2,putCount=2,elementCountInMemory=2,elementC
   4 W- i" p( F2 }" t9 {2 A* e
2. ountOnDisk=0,sizeInMemory=3948]

复制代码

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

1. Session sess1=sf.openSession();
   
2.         Book2 b1=(Book2) sess1.get(Book2.class, 17);
   , j. y7 M. W1 G/ r' U
3.         System.out.println(b);
   . `; q7 A8 k/ y  P% U6 T
4.         Book2 b2=(Book2) sess1.get(Book2.class, 17);
   9 U/ S/ B( n- y6 u7 P9 d1 @: _
5.         assertEquals("Spring Recipes", b1.getTitle());
   
6.         assertEquals("Spring Recipes", b2.getTitle());
   + w, b# ~4 h1 p
7.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
   
8.         System.out.println(slcs);

复制代码

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

1. SecondLevelCacheStatistics[hitCount=1,missCount=2,putCount=2,elementCountInMemory=2,elementC
   # Y( ~" G% E% W6 [
2. ountOnDisk=0,sizeInMemory=3948]

复制代码

完整测试逻辑

1. @Test
   
2.     public void test2LCache()
   ; a: G; G3 W( m2 R7 J8 B
3.     {
   0 a% R& @) x8 ]  o6 |# B2 ?
4.         Statistics stat=sf.getStatistics();//获取stat对象
   % K7 v  F' [  D
5.         Session sess=sf.openSession();
   
6.         Transaction tx=sess.beginTransaction();
   : g, {3 m9 B9 N5 ?( L
7.         
   2 k  B" Z! q  Q9 x" C# A
8.         //存储对象，此时不会放到缓存中
   
9.         System.out.println("--------------存储对象---------------------------------");
   5 R- G6 t/ e) B" m- I& O# |, j/ F
10.         Book2 book=new Book2();
    
11.         book.setTitle("Spring Recipes");
    6 w* H+ i/ e7 b6 w2 p
12.         sess.saveOrUpdate(book);
    + S- z7 a. [5 @. ~* ?4 ?
13.         tx.commit();
    
14.         sess.close();
    % `5 c5 f- m8 m# s& A. K9 d
15.         System.out.println(book);
    . i% A$ U+ ~% G6 p4 O! P# E% G% |6 f
16.         SecondLevelCacheStatistics slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    ! t! g( {% F8 u( L/ ^" A
17.         System.out.println(slcs);
    - u* U% D. {1 ?1 w, e; M' U+ k  c
18.         Cache cache=sf.getCache();
    
19.         System.out.println(cache);
    
20.         cache.evictAllRegions();//从所有region中获取数据
    
21.         Map map=slcs.getEntries();
    
22.         System.out.println("Cache entries:"+map.size());
    
23.         System.out.println("--------------第一次查询后---------------------------------");
    . m% C5 c' `% a* X
24.         sess=sf.openSession();
    
25.         tx=sess.beginTransaction();
    
26.         Book2 b1=(Book2) sess.byId(Book2.class).load(book.getId());//第一次查询
    / L% D3 h  p: w6 q
27.         System.out.println(b1);
    6 e7 w* d) ?/ h# U/ @% W& m
28.         assertEquals(book, b1);
    
29.         tx.commit();
    7 l. o$ d+ T* {' c- J8 ?
30.         sess.close();
    
31.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
32.         System.out.println(slcs);
    8 X, J- T# m3 a" \$ h; b
33.         map=slcs.getEntries();
    
34.         System.out.println(map.size());
    % @1 s7 N$ ~' i  y
35.         System.out.println("--------------第二次查询后---------------------------------");
    
36.         sess=sf.openSession();
    
37.         tx=sess.beginTransaction();
    
38.         Book2 b2=(Book2) sess.byId(Book2.class).load(book.getId());//第二次查询
    
39.         System.out.println(b2);
    9 V% j7 S. C3 B# h
40.         assertEquals(book, b2);
    
41.         tx.commit();
    
42.         sess.close();
    / J: S! d+ }& q5 g0 p$ A
43.         
    : g6 b0 r" a6 u
44.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
45.         System.out.println(slcs);
    
46.         // this is the initial select
    + V* O  k( v1 A5 Q% \. O+ z
47.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    
48.         // we put one element in the cache from the miss
    
49.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    ; A2 v2 z% [0 C6 ]- p
50.         // we still didn't hit the cache, because of 1L cache
    ) e/ }# x4 n: _8 h
51.         assertEquals(stat.getSecondLevelCacheHitCount(), 1);
    ! E- h4 Y  `7 Y8 z/ _3 T
52.         System.out.println("--------------第三次查询后---------------------------------");
    
53.         sess=sf.openSession();
    
54.         tx=sess.beginTransaction();
    1 v2 L) ?, {* N" y' t: o
55.         b1=(Book2) sess.byId(Book2.class).load(book.getId());//第三次查询
    
56.         assertEquals(book, b1);
    : R7 m$ E: t$ i# j2 N1 J
57.         tx.commit();
    ' N+ e" a( F4 C' `! T! U
58.         sess.close();
    
59.         
    4 {( ?2 V+ S- Z9 F4 {# D' }
60.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    3 [0 A* Y0 z) T3 s6 S# m
61.         System.out.println(slcs);
    
62.         // same miss count (we should hit now)
    8 C0 O& o; @3 H) o" M9 I& a. i
63.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    
64.         // same put count (we didn't put anything new)
    
65.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    3 D. h" v! b6 ?: {4 Y2 G
66.         // now we hit the 2L cache for load
    ) ~$ G; B& D" h
67.         assertEquals(stat.getSecondLevelCacheHitCount(), 2);
    8 n" @! ?3 p4 j
68.         
    
69.     }

复制代码

完整测试结果

1. Hibernate: delete from book2
   
2. --------------存储对象---------------------------------
   $ g* e/ n" Q9 n* ~
3. Hibernate: insert into Book2 (title) values (?)
   
4. com.xinglongjian.entity.hbm.Book2@521e083b
   8 o3 I0 e* [3 `: \: f7 \
5. SecondLevelCacheStatistics[hitCount=0,missCount=0,putCount=0,elementCountInMemory=0,elementCountOnDisk=0,sizeInMemory=0]
   
6. org.hibernate.internal.CacheImpl@4830f6
   * A% e# V' R% L4 h
7. Cache entries:0
   + G. e+ e9 ]4 T+ z
8. --------------第一次查询后---------------------------------
   
9. Hibernate: select book2x0_.id as id1_0_0_, book2x0_.title as title2_0_0_ from Book2 book2x0_
   
10. where book2x0_.id=?
    ; m% l( g2 i/ M# `+ [: m; K) @
11. com.xinglongjian.entity.hbm.Book2@521e083b
    " o3 a$ G, S# Y) R% ^
12. SecondLevelCacheStatistics[hitCount=0,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
13. ountOnDisk=0,sizeInMemory=1979]
    " y% U5 D" u, Z- u$ z
14. 1
    ; C+ A! p0 ?  l5 Z+ l4 T
15. --------------第二次查询后---------------------------------
    
16. com.xinglongjian.entity.hbm.Book2@521e083b
    " Y& T( \2 M* Y" C+ T! ~
17. SecondLevelCacheStatistics[hitCount=1,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
18. ountOnDisk=0,sizeInMemory=1979]
    
19. --------------第三次查询后---------------------------------
    
20. SecondLevelCacheStatistics[hitCount=2,missCount=1,putCount=1,elementCountInMemory=1,elementC
    ! {7 {- x: F( ?) ?, c: U0 j5 R
21. ountOnDisk=0,sizeInMemory=1979]

复制代码

7 B# e. L* b' a1 ~; c