如何配置Hibernate中的二级缓存

拧巴人

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

  M$ V/ |# }, t' c( N首先，要在hibernate.cfg.xml中设置一个cache Provider，hibernate支持多个cache实现，有EHCache，OSCache等。在非分布式环境中可以选择默认的EHCache。添加ehcahe jar

1. <dependency>
   
2.           <groupId>org.hibernate</groupId>
   + w( b% h' E: M5 |! ?: b
3.           <artifactId>hibernate-ehcache</artifactId>
   0 D2 P3 e$ u; l6 U& K
4.           <version>4.3.5.Final</version>
   % w' w' q. j0 j: e7 S3 e2 p
5.       </dependency>

复制代码

1. <hibernate-configuration>
   7 j' H0 L( P! _2 @  R
2.     <session-factory>
   ! A7 Q# k2 x, ?7 r1 w' i
3.         <property name="connection.driver_class">com.mysql.jdbc.Driver</property>
   
4.         <property name="connection.url">jdbc:mysql://localhost/test</property>
   3 M1 z0 g, r7 e& G( O
5.         <property name="connection.username">root</property>
   
6.         <property name="connection.password"></property>
   9 z1 h5 j7 l* i  A
7.         <property name="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</property>
   * @2 H% K- T. L8 N! }
8.         <property name="hibernate.show_sql">true</property>
   $ }& m  \) Y! ]& `6 x. y0 C( ?) T
9.         <property name="hibernate.hbm2ddl.auto">update</property>
   
10.         <property name="hibernate.generate_statistics">true</property>
    
11.         <property name="hibernate.cache.region.factory_class">
    
12.             org.hibernate.cache.ehcache.EhCacheRegionFactory
    6 ?, A7 H) A# ?! e
13.         </property>
    6 p8 E5 P6 A4 A7 q* r
14.         <mapping class="com.xinglongjian.entity.hbm.Book2"/>
    
15. </hibernate-configuration>

复制代码

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

1. <ehcache>
   7 w4 H% {( {6 [, l' j* P
2. <diskStore path="c:/data/ehcache"/>
   ) y' U" U9 r6 o5 m
3. <defaultCache
   
4.         maxElementsInMemory="10"
   7 c3 \. H  S' w$ q
5.         eternal="false"
   
6.         overflowToDisk="true"
   
7.         timeToIdleSeconds="120"
   3 [( T" ]7 q6 P( o: V
8.         timeToLiveSeconds="120"
   
9.         diskPersistent="false"
   
10.         diskExpiryThreadIntervalSeconds="120"/>
    
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. @Cacheable
   
3. @Cache(usage=CacheConcurrencyStrategy.READ_ONLY,region="com.xinglongjian.entity.hbm.Book")
   2 m( \6 M; m6 y  d# E( y9 \
4. public class Book2 {
     }2 u1 o$ N0 n. F( X
5.     @Id
   : u( y) D! G- F. I0 m; g# f
6.     @GeneratedValue
   " l3 p# S' i6 _9 `6 _# U6 c& y3 R
7.     private int id;
   
8.     private String title;
   ' V  u7 C. g( Y" {# b7 S
9.     public String getTitle() {
   ) G& L. w3 U4 z, J
10.         return title;
    4 s( z$ \: [6 G) {. ]$ S+ s& W8 d
11.     }
    5 x" e' X& n# H4 F
12.     public void setTitle(String title) {
    , C0 d2 C' Q4 Z* e9 i/ `; U
13.         this.title = title;
    + [3 M/ Z( c6 C
14.     }
    
15.     public int getId() {
    ) m) e# p  _, y& t' c# R* {
16.         return id;
    + q0 u) Z4 ^" _1 ]5 v- \+ k
17.     }
    5 t) E; x4 D9 a+ `
18.     public void setId(int id) {
    - |" z+ U9 l$ a- R$ k& }$ ^
19.         this.id = id;
    
20.     }
    * c% c1 ]2 l& C, ~
21.     @Override
    
22.     public int hashCode() {
    : ~* B: P% i- m+ A
23.         final int prime = 31;
    
24.         int result = 1;
    
25.         result = prime * result + id;
      m6 P) v: O7 C# w
26.         result = prime * result + ((title == null) ? 0 : title.hashCode());
    
27.         return result;
    " U' N! k+ l9 n. a( p
28.     }
    " ?- [- E4 v, |* ]5 K
29.     @Override
    6 ^/ b/ o0 v7 D) D4 T- L) B% F
30.     public boolean equals(Object obj) {
    & A- d+ _+ i& Q) V# C
31.         if (this == obj)
    9 b) {+ }" f1 H! m6 x8 P* M
32.             return true;
    3 E7 s; W$ B' i
33.         if (obj == null)
    7 x4 F7 F& R7 \1 n. j8 f# O6 m
34.             return false;
    , d; u( L/ E8 `. a/ P
35.         if (getClass() != obj.getClass())
    9 X% x' L2 K! g* x: L" ]2 G
36.             return false;
    : _  k1 v. h) i
37.         Book2 other = (Book2) obj;
    
38.         if (id != other.id)
    
39.             return false;
    
40.         if (title == null) {
    ( I: `/ J$ v5 g( J
41.             if (other.title != null)
    5 w& D( x5 K% ^6 T1 V2 ~
42.                 return false;
    
43.         } else if (!title.equals(other.title))
    
44.             return false;
    
45.         return true;
    2 {1 z2 H5 p8 A- K# V3 U
46.     }
    2 }) r3 r# `+ r0 d+ }
47.    
    + ?% j! \- k; ^. g0 [
48. }

复制代码

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

只有在SELECT时才会缓存。

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

1. Session sess=sf.openSession();
   ' V# D; x; \# L2 P; q
2.         Book2 b=(Book2) sess.get(Book2.class, 17);
   * B2 E) \+ H/ @0 F& q1 P
3.         System.out.println(b);
   
4.         assertEquals("spring Recipes", b.getTitle());
   
5.         Book2 b3=(Book2) sess.get(Book2.class, 18);
   8 R' n! W0 Q) V
6.         assertEquals("dfad", b3.getTitle());
   
7.         sess.close();
   
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
   5 l; o( O1 W# N) i" [6 R
2. ountOnDisk=0,sizeInMemory=3948]

复制代码

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

1. Session sess1=sf.openSession();
   $ z" b0 t+ V0 O) E% W* D/ `3 ^6 D
2.         Book2 b1=(Book2) sess1.get(Book2.class, 17);
   
3.         System.out.println(b);
   
4.         Book2 b2=(Book2) sess1.get(Book2.class, 17);
   
5.         assertEquals("Spring Recipes", b1.getTitle());
   
6.         assertEquals("Spring Recipes", b2.getTitle());
   2 k: Z' L0 }2 v  N" W" N2 M$ [
7.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
   ' B1 ?7 [; r8 a/ l
8.         System.out.println(slcs);

复制代码

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

1. SecondLevelCacheStatistics[hitCount=1,missCount=2,putCount=2,elementCountInMemory=2,elementC
   ! K6 l+ u/ H; `1 j
2. ountOnDisk=0,sizeInMemory=3948]

复制代码

完整测试逻辑

1. @Test
   
2.     public void test2LCache()
     p$ h$ K+ h; |, I
3.     {
   
4.         Statistics stat=sf.getStatistics();//获取stat对象
   
5.         Session sess=sf.openSession();
   4 X  V% e( \: T" }
6.         Transaction tx=sess.beginTransaction();
   
7.         
   
8.         //存储对象，此时不会放到缓存中
   " o7 t7 {9 g& k  p: i6 Z
9.         System.out.println("--------------存储对象---------------------------------");
   
10.         Book2 book=new Book2();
    ' ~( t# I: j3 `* g) X# f8 @9 F
11.         book.setTitle("Spring Recipes");
    
12.         sess.saveOrUpdate(book);
    , u& c, l* c+ C3 @/ P+ ]" V. Y
13.         tx.commit();
    
14.         sess.close();
    
15.         System.out.println(book);
    
16.         SecondLevelCacheStatistics slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
17.         System.out.println(slcs);
    & A1 d; h# Z# C# A4 {& R5 U& d
18.         Cache cache=sf.getCache();
    
19.         System.out.println(cache);
    ! d; H7 W9 Y: P5 k
20.         cache.evictAllRegions();//从所有region中获取数据
    " E: d' {7 j; ~8 i
21.         Map map=slcs.getEntries();
    
22.         System.out.println("Cache entries:"+map.size());
    
23.         System.out.println("--------------第一次查询后---------------------------------");
    
24.         sess=sf.openSession();
    
25.         tx=sess.beginTransaction();
    # S! H# F& r2 [! k7 S6 v" ^4 F( Y
26.         Book2 b1=(Book2) sess.byId(Book2.class).load(book.getId());//第一次查询
    # ~. ]" R& k  [7 e7 S  `$ B
27.         System.out.println(b1);
    % k! W2 E/ t; r  ^5 L
28.         assertEquals(book, b1);
    
29.         tx.commit();
    * t# C* s. W( o
30.         sess.close();
    
31.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    7 M" e+ C, G; u( u& r
32.         System.out.println(slcs);
    
33.         map=slcs.getEntries();
    / [3 g' H$ Y8 B2 F! l8 x
34.         System.out.println(map.size());
    3 V  Q* V. j1 u1 g  @
35.         System.out.println("--------------第二次查询后---------------------------------");
      Q, H5 A1 \2 k( s  `
36.         sess=sf.openSession();
    * C1 A0 p( K) k9 q% r3 Q/ w9 X
37.         tx=sess.beginTransaction();
    ( f6 v! b$ \1 ~9 g9 R1 _: K
38.         Book2 b2=(Book2) sess.byId(Book2.class).load(book.getId());//第二次查询
    - {  P5 e' E& h. ~
39.         System.out.println(b2);
    * o, w0 U' S6 @9 P' B) j
40.         assertEquals(book, b2);
    ' J* S) ]2 u+ a$ q
41.         tx.commit();
    
42.         sess.close();
    8 k0 t+ R: G  z* S' V0 |% A
43.         
    : |% I  m" T9 ~. @
44.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    4 L* c3 L/ t- D1 Q, }! T% T# Q
45.         System.out.println(slcs);
    : M) o, y# W6 t
46.         // this is the initial select
    + B" _$ a9 m# G% I; I, x
47.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    
48.         // we put one element in the cache from the miss
    
49.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    ) Q( i) N1 d  U0 O' C# j
50.         // we still didn't hit the cache, because of 1L cache
    ( J) L3 L! M1 e5 R7 [
51.         assertEquals(stat.getSecondLevelCacheHitCount(), 1);
    - y5 i1 u8 G. U# d7 t+ ^9 u
52.         System.out.println("--------------第三次查询后---------------------------------");
    
53.         sess=sf.openSession();
    / C' h* Y, W. T: S
54.         tx=sess.beginTransaction();
    5 z5 C/ H) `' O% }$ \9 }! n+ f% V
55.         b1=(Book2) sess.byId(Book2.class).load(book.getId());//第三次查询
    % }( [9 E( v" H
56.         assertEquals(book, b1);
    * B9 b/ [0 d) K9 ?6 Q7 S! M1 S
57.         tx.commit();
    
58.         sess.close();
    , e( R3 D; F, @
59.         
    
60.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    * n. Y1 L( Q" K& t% f9 c/ d1 s
61.         System.out.println(slcs);
    # i; B. H. G: A" [) o( `' u
62.         // same miss count (we should hit now)
    9 ~& g4 T# \9 Z" }3 O
63.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    $ O  m# e7 q& S9 T, K: e
64.         // same put count (we didn't put anything new)
    
65.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    : M% s6 e) H0 z- p2 J
66.         // now we hit the 2L cache for load
    
67.         assertEquals(stat.getSecondLevelCacheHitCount(), 2);
    
68.         
    
69.     }

复制代码

完整测试结果

1. Hibernate: delete from book2
   
2. --------------存储对象---------------------------------
     X, Q: \/ L7 O- y$ I6 T9 A
3. Hibernate: insert into Book2 (title) values (?)
   
4. com.xinglongjian.entity.hbm.Book2@521e083b
   
5. SecondLevelCacheStatistics[hitCount=0,missCount=0,putCount=0,elementCountInMemory=0,elementCountOnDisk=0,sizeInMemory=0]
   % c" _% G8 d/ i; m/ `0 q. r0 G4 |6 [
6. org.hibernate.internal.CacheImpl@4830f6
   $ E! F7 ?! g' v# X
7. Cache entries:0
   ! p- y% F4 e/ w! Q4 W1 a
8. --------------第一次查询后---------------------------------
   
9. Hibernate: select book2x0_.id as id1_0_0_, book2x0_.title as title2_0_0_ from Book2 book2x0_
   
10. where book2x0_.id=?
    % G6 q) x/ f+ {
11. com.xinglongjian.entity.hbm.Book2@521e083b
    1 N) H$ j! M. I% L$ e* l
12. SecondLevelCacheStatistics[hitCount=0,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
13. ountOnDisk=0,sizeInMemory=1979]
    # ]. d) \9 Z, g( a# {
14. 1
    , x1 v9 O" S$ _' a& O
15. --------------第二次查询后---------------------------------
    
16. com.xinglongjian.entity.hbm.Book2@521e083b
    
17. SecondLevelCacheStatistics[hitCount=1,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
18. ountOnDisk=0,sizeInMemory=1979]
    $ U7 a8 D, Z- H7 h7 }, p, F
19. --------------第三次查询后---------------------------------
    ) l0 C4 P; `* k9 u! q
20. SecondLevelCacheStatistics[hitCount=2,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
21. ountOnDisk=0,sizeInMemory=1979]

复制代码