如何配置Hibernate中的二级缓存

拧巴人

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

首先，要在hibernate.cfg.xml中设置一个cache Provider，hibernate支持多个cache实现，有EHCache，OSCache等。在非分布式环境中可以选择默认的EHCache。添加ehcahe jar

1. <dependency>
   
2.           <groupId>org.hibernate</groupId>
   6 d9 @5 g; c+ |; }$ m& |
3.           <artifactId>hibernate-ehcache</artifactId>
   
4.           <version>4.3.5.Final</version>
   ' i8 U7 ~" m/ @! Z* D
5.       </dependency>

复制代码

1. <hibernate-configuration>
   : s+ F, P" K# F
2.     <session-factory>
   & P( }& f3 ^3 E1 T
3.         <property name="connection.driver_class">com.mysql.jdbc.Driver</property>
   
4.         <property name="connection.url">jdbc:mysql://localhost/test</property>
   ' i- B% P) z; E! ^9 V; |) X
5.         <property name="connection.username">root</property>
   $ N8 x/ m9 f) O/ w: Q* a: E. R
6.         <property name="connection.password"></property>
   ) T) H8 ^" v2 Y# k7 G
7.         <property name="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</property>
   # `7 p! v; K+ S
8.         <property name="hibernate.show_sql">true</property>
   - k% H3 |7 I* v3 R
9.         <property name="hibernate.hbm2ddl.auto">update</property>
   
10.         <property name="hibernate.generate_statistics">true</property>
    : v+ s& @( u& y" o# p
11.         <property name="hibernate.cache.region.factory_class">
    
12.             org.hibernate.cache.ehcache.EhCacheRegionFactory
    
13.         </property>
    " n4 `5 \; c9 }
14.         <mapping class="com.xinglongjian.entity.hbm.Book2"/>
    
15. </hibernate-configuration>

复制代码

/ j- P2 |' O/ L: U+ L8 v- g 第二，通过ehcache.xml配置EHCache，该文件放置于classpath的根目录下。可以在该配置文件中设置将不同的对象存储在不同的regions。

1. <ehcache>
   
2. <diskStore path="c:/data/ehcache"/>
   
3. <defaultCache
   
4.         maxElementsInMemory="10"
   : x( X: Z' f5 O. Q5 S4 _$ H
5.         eternal="false"
   8 A* i. s  O( U$ \1 Y) M
6.         overflowToDisk="true"
   
7.         timeToIdleSeconds="120"
   
8.         timeToLiveSeconds="120"
   
9.         diskPersistent="false"
   , `/ \: }/ c+ c" w% p
10.         diskExpiryThreadIntervalSeconds="120"/>
    
11. <cache name="com.xinglongjian.entity.hbm.Book" maxElementsInMemory="10"  eternal="false"
    
12.     overflowToDisk="false" timeToIdleSeconds="120" timeToLiveSeconds="120" diskPersistent="false"/>
    , [& ?0 s& M; `/ P9 j  x
13. </ehcache>

复制代码

第三，设置持久化类

1. @Entity
   
2. @Cacheable
   
3. @Cache(usage=CacheConcurrencyStrategy.READ_ONLY,region="com.xinglongjian.entity.hbm.Book")
   - L- U; Y9 r! i; b$ X1 }! K* w: G+ x
4. public class Book2 {
   : e  q# P! k$ H. n& l0 O
5.     @Id
   ; M, U0 q0 x9 m6 h& C! `
6.     @GeneratedValue
   # D1 H% G  e# a  w/ Y9 t  l
7.     private int id;
   
8.     private String title;
   $ p7 }4 O2 ~9 [8 H& k9 n% t
9.     public String getTitle() {
   " g# |/ T- ]8 M6 G) K
10.         return title;
    $ n1 E5 w/ P8 y
11.     }
    5 S2 I* Y' Z, v+ @. V) I2 v4 L
12.     public void setTitle(String title) {
    
13.         this.title = title;
    % c: F$ H2 A3 g& G% ]# Z; r- [& Q
14.     }
    
15.     public int getId() {
    
16.         return id;
    
17.     }
    
18.     public void setId(int id) {
    
19.         this.id = id;
    
20.     }
    / t0 d2 b$ d" d% v$ T: o; e
21.     @Override
    
22.     public int hashCode() {
    
23.         final int prime = 31;
    5 v& ^$ [' U1 c$ W+ _2 N, _
24.         int result = 1;
    % n' I3 {' P7 s, }3 A
25.         result = prime * result + id;
    
26.         result = prime * result + ((title == null) ? 0 : title.hashCode());
    , N+ v+ f8 j2 Z+ p0 w1 L# F
27.         return result;
    # |2 x) W$ {4 t
28.     }
    
29.     @Override
    2 }! J$ V6 X3 m, D
30.     public boolean equals(Object obj) {
    ) P6 b* l/ B. e& v, X5 n  i) o
31.         if (this == obj)
    ' F/ U1 \+ v$ x5 ^5 D
32.             return true;
    
33.         if (obj == null)
    
34.             return false;
    ) G5 d) m5 G3 G9 G% Q
35.         if (getClass() != obj.getClass())
    
36.             return false;
    ( i7 @( Y' p. A5 C6 E6 `; I& K7 z
37.         Book2 other = (Book2) obj;
    
38.         if (id != other.id)
    : `) f* T# A) m7 n3 d7 G: P. _* U
39.             return false;
    " @4 V0 j& H; z
40.         if (title == null) {
    , I, K/ A4 {! Z- Y% v% W
41.             if (other.title != null)
      C) w; Y# k; b2 |. J) _3 X
42.                 return false;
    
43.         } else if (!title.equals(other.title))
    
44.             return false;
    
45.         return true;
    3 l, C) d5 t/ S  r: B4 a) Q6 G/ _3 c
46.     }
    ) ~& Z4 l$ y) a* S8 M3 q
47.    
    
48. }

复制代码

二级缓存的持久化类必须实现equals方法。
  Y: Q% E" @: _/ F6 u5 W5 g: T
3 a% r, R( }* X# q5 c& A( }" q只有在SELECT时才会缓存。

! ^: m  U1 W: W& z, i" o在同一个session里，查询2个不同的对象，会缓存2次，

1. Session sess=sf.openSession();
   # _) K: E+ Z, C5 L
2.         Book2 b=(Book2) sess.get(Book2.class, 17);
   % n: X! v6 I% l$ V0 S6 N
3.         System.out.println(b);
   
4.         assertEquals("spring Recipes", b.getTitle());
   
5.         Book2 b3=(Book2) sess.get(Book2.class, 18);
   : D3 S7 a/ C6 E  e! ^$ d
6.         assertEquals("dfad", b3.getTitle());
   6 w; t( a1 L0 b
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
   
2. ountOnDisk=0,sizeInMemory=3948]

复制代码

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

1. Session sess1=sf.openSession();
   
2.         Book2 b1=(Book2) sess1.get(Book2.class, 17);
   
3.         System.out.println(b);
   
4.         Book2 b2=(Book2) sess1.get(Book2.class, 17);
   5 I* y, }+ S0 p
5.         assertEquals("Spring Recipes", b1.getTitle());
     a  q  f- l) W( _* R7 o* ]$ j
6.         assertEquals("Spring Recipes", b2.getTitle());
   
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
   ' U4 @/ D5 m/ C: F# V* y
2. ountOnDisk=0,sizeInMemory=3948]

复制代码

完整测试逻辑

1. @Test
   ) M4 ?3 d* n/ H8 `" v3 ^
2.     public void test2LCache()
   * Z/ I4 s5 l# E/ z( s. m4 m
3.     {
   / v0 E) w- ]0 P
4.         Statistics stat=sf.getStatistics();//获取stat对象
   # s* C( {& F( A3 Q$ e
5.         Session sess=sf.openSession();
   
6.         Transaction tx=sess.beginTransaction();
   # h5 E# M1 W) t+ }- P
7.         
   
8.         //存储对象，此时不会放到缓存中
   
9.         System.out.println("--------------存储对象---------------------------------");
   
10.         Book2 book=new Book2();
    
11.         book.setTitle("Spring Recipes");
    " q* F* I, d& S$ D" ~$ O
12.         sess.saveOrUpdate(book);
    
13.         tx.commit();
    - |1 ^; j7 v0 J* X6 d3 ?2 @
14.         sess.close();
    8 ^( c% P+ {/ j: b' y
15.         System.out.println(book);
    ! Y7 F* v3 t7 e5 y
16.         SecondLevelCacheStatistics slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
17.         System.out.println(slcs);
    
18.         Cache cache=sf.getCache();
    . e7 O& j$ n) F, e
19.         System.out.println(cache);
    
20.         cache.evictAllRegions();//从所有region中获取数据
    3 f) |9 \, U& }! P% z4 W
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();
    ) F7 d/ N4 m& F: W
26.         Book2 b1=(Book2) sess.byId(Book2.class).load(book.getId());//第一次查询
    
27.         System.out.println(b1);
    + R# g3 W, l# _! O) s  @- {) Q0 y
28.         assertEquals(book, b1);
    
29.         tx.commit();
    
30.         sess.close();
    ; o7 ?5 k1 T  Z/ T6 Z* T, l
31.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
32.         System.out.println(slcs);
    ( ]+ ?7 }" s8 o" t
33.         map=slcs.getEntries();
    2 a5 a+ g" p8 V  S- N
34.         System.out.println(map.size());
    6 D, O& ]* Q9 g) m4 s" v  F
35.         System.out.println("--------------第二次查询后---------------------------------");
    
36.         sess=sf.openSession();
    
37.         tx=sess.beginTransaction();
    ) H1 d7 {, l5 Q. v% |9 K8 \
38.         Book2 b2=(Book2) sess.byId(Book2.class).load(book.getId());//第二次查询
    1 X2 k* j) ]" E9 H2 @& h9 N" Z
39.         System.out.println(b2);
    
40.         assertEquals(book, b2);
    5 S8 T* O! T& z: S; T
41.         tx.commit();
    ' f( v4 R, o. K$ P
42.         sess.close();
    5 ~% L2 x! I1 |" a
43.         
    8 ^7 W  f- x3 U* a, w/ c0 r
44.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    * ~+ D$ m! ]0 I
45.         System.out.println(slcs);
    3 H8 o* H+ u2 v8 {+ G" g# y  Z
46.         // this is the initial select
    % H5 [' y6 r. i
47.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    2 R; H& p% n7 Q% \3 N
48.         // we put one element in the cache from the miss
    % W: W0 E+ l) c" L4 E4 f
49.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    
50.         // we still didn't hit the cache, because of 1L cache
    + c) c6 M, r: J( D( v' Z0 h
51.         assertEquals(stat.getSecondLevelCacheHitCount(), 1);
    ' M, s8 g; E% I2 e5 g8 J* e
52.         System.out.println("--------------第三次查询后---------------------------------");
    
53.         sess=sf.openSession();
    
54.         tx=sess.beginTransaction();
    
55.         b1=(Book2) sess.byId(Book2.class).load(book.getId());//第三次查询
    6 |4 i0 @& r; u7 ?6 S- v1 U5 U
56.         assertEquals(book, b1);
    + u( ]2 F9 q: v. Y9 T! {1 n$ R
57.         tx.commit();
    
58.         sess.close();
    
59.         
    
60.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
61.         System.out.println(slcs);
    & s% s  _; e4 D) [% _9 v
62.         // same miss count (we should hit now)
    8 t$ U# {9 Z! B9 X( u6 E$ O9 k
63.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    7 k; f* z( [1 \! G; g: R* j
64.         // same put count (we didn't put anything new)
    6 E9 K" }; g8 `( E3 i
65.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    3 s5 X/ t6 v/ g1 Z
66.         // now we hit the 2L cache for load
    % x+ r; E, ~/ `
67.         assertEquals(stat.getSecondLevelCacheHitCount(), 2);
    + M$ z& X; Z8 x% D6 ~
68.         
    
69.     }

复制代码

完整测试结果

1. Hibernate: delete from book2
   ) F& a3 h8 B- }4 n
2. --------------存储对象---------------------------------
   
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]
   5 F! @7 |) r+ v+ B: Y- O' E
6. org.hibernate.internal.CacheImpl@4830f6
   
7. Cache entries:0
   5 i- r) T) }$ O! p. D3 p9 q
8. --------------第一次查询后---------------------------------
   : @* u, P# y4 n& R. {' q: z
9. Hibernate: select book2x0_.id as id1_0_0_, book2x0_.title as title2_0_0_ from Book2 book2x0_
   
10. where book2x0_.id=?
    / O8 N+ {: W( a; x
11. com.xinglongjian.entity.hbm.Book2@521e083b
    7 _9 R9 W" E1 k5 M$ b
12. SecondLevelCacheStatistics[hitCount=0,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
13. ountOnDisk=0,sizeInMemory=1979]
    
14. 1
    4 l- d# j+ z& A! B$ T" w
15. --------------第二次查询后---------------------------------
    / b% s: \" U& r$ J, A2 Z
16. com.xinglongjian.entity.hbm.Book2@521e083b
    - ]. v2 z8 Q, ?4 o) A9 P
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
    
21. ountOnDisk=0,sizeInMemory=1979]

复制代码

: [5 E7 T, q) i, t  ^4 S