如何配置Hibernate中的二级缓存

拧巴人

需要启动二级缓存，二级缓存的scope是sessionFactory。也就是说二级缓存的数据可以在由相同SessionFactory创建的多个Session中重用。
: \( _% S" `0 R4 W/ E2 A
首先，要在hibernate.cfg.xml中设置一个cache Provider，hibernate支持多个cache实现，有EHCache，OSCache等。在非分布式环境中可以选择默认的EHCache。添加ehcahe jar

1. <dependency>
   
2.           <groupId>org.hibernate</groupId>
   ( W1 T) p6 K1 U* f
3.           <artifactId>hibernate-ehcache</artifactId>
   
4.           <version>4.3.5.Final</version>
   " e( `2 T# t$ I5 q  y/ Y# S4 x9 M
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.         <property name="connection.username">root</property>
   # r* z+ W$ \9 K% O
6.         <property name="connection.password"></property>
   
7.         <property name="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</property>
   
8.         <property name="hibernate.show_sql">true</property>
   8 q& U. E# y2 Q; S9 l/ D9 N/ B
9.         <property name="hibernate.hbm2ddl.auto">update</property>
   
10.         <property name="hibernate.generate_statistics">true</property>
    
11.         <property name="hibernate.cache.region.factory_class">
    ; V; c) _& z; t; s) F7 {
12.             org.hibernate.cache.ehcache.EhCacheRegionFactory
    
13.         </property>
    
14.         <mapping class="com.xinglongjian.entity.hbm.Book2"/>
    : }# C0 e0 k7 g# v' |- _+ Z, [
15. </hibernate-configuration>

复制代码

% Z8 G# ?; z; n: _. ^( H8 b6 t' Y 第二，通过ehcache.xml配置EHCache，该文件放置于classpath的根目录下。可以在该配置文件中设置将不同的对象存储在不同的regions。

1. <ehcache>
   
2. <diskStore path="c:/data/ehcache"/>
   
3. <defaultCache
   
4.         maxElementsInMemory="10"
   4 f$ S& @: y- z. L1 V) q, H
5.         eternal="false"
   : S& @, ~. B1 C9 ?% k$ u
6.         overflowToDisk="true"
   ! _$ I& K" u& O+ D
7.         timeToIdleSeconds="120"
   
8.         timeToLiveSeconds="120"
   
9.         diskPersistent="false"
   % o8 \8 E2 F8 o0 B, o
10.         diskExpiryThreadIntervalSeconds="120"/>
    6 T; k- f- {8 x) n
11. <cache name="com.xinglongjian.entity.hbm.Book" maxElementsInMemory="10"  eternal="false"
    0 n# e" J$ L( A
12.     overflowToDisk="false" timeToIdleSeconds="120" timeToLiveSeconds="120" diskPersistent="false"/>
    " i4 |$ `) [2 q3 V5 f/ E( L% _
13. </ehcache>

复制代码

第三，设置持久化类

1. @Entity
   5 v8 D! P3 Z2 w1 }( }! H" U
2. @Cacheable
   ( j5 \/ O2 l- g
3. @Cache(usage=CacheConcurrencyStrategy.READ_ONLY,region="com.xinglongjian.entity.hbm.Book")
   
4. public class Book2 {
   
5.     @Id
   & a5 S' X/ w8 n
6.     @GeneratedValue
   
7.     private int id;
     z3 o" I0 B9 b# {
8.     private String title;
   8 n' h, J7 I4 n& K5 h! s
9.     public String getTitle() {
   8 r9 ?. d- X; U9 n
10.         return title;
    
11.     }
    & O) G2 f9 L5 D5 L2 o% Y
12.     public void setTitle(String title) {
    
13.         this.title = title;
    / s' f; M( r6 |5 s9 E* u  Z6 A
14.     }
    
15.     public int getId() {
    
16.         return id;
    
17.     }
    5 x7 x' ]+ T3 ?) @; s3 F) ~
18.     public void setId(int id) {
    : x* s+ c2 C5 z: N! R' t) S, ]
19.         this.id = id;
    3 Z7 F; O0 H/ K
20.     }
    7 f9 y. p8 `( M! ?
21.     @Override
    ; N( V- n% I7 K
22.     public int hashCode() {
    
23.         final int prime = 31;
    
24.         int result = 1;
    * B" |$ @3 p" o; r/ A( G9 y" F# O
25.         result = prime * result + id;
    2 h' j  U& b2 [; Z# X: Q
26.         result = prime * result + ((title == null) ? 0 : title.hashCode());
    
27.         return result;
    + h( A1 }$ c( p# c9 K" ~9 Z! b
28.     }
    
29.     @Override
    
30.     public boolean equals(Object obj) {
    
31.         if (this == obj)
    % y( f( X5 S* X9 p6 u" o8 V
32.             return true;
    " }' V, Y  ~. J
33.         if (obj == null)
    ( M6 e' i! w9 J$ p
34.             return false;
    5 B  d7 [. e0 N2 g/ H& H" a
35.         if (getClass() != obj.getClass())
    
36.             return false;
    + a4 U. j9 k8 K1 Q. I
37.         Book2 other = (Book2) obj;
    $ [! z% n8 E* j' h1 M& h1 Q0 v5 j' P
38.         if (id != other.id)
    
39.             return false;
    5 l& v* x; \3 h5 t2 e: t/ e  k
40.         if (title == null) {
    
41.             if (other.title != null)
    
42.                 return false;
    
43.         } else if (!title.equals(other.title))
      y0 _, L. N3 y1 H  M
44.             return false;
    8 M# _3 @# h. k
45.         return true;
    
46.     }
    
47.    
    1 p8 ^5 g+ H& _( g4 }& }
48. }

复制代码

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

只有在SELECT时才会缓存。

# G3 d, L; K8 B  X在同一个session里，查询2个不同的对象，会缓存2次，

1. Session sess=sf.openSession();
   . l. G; a7 L, ~% t& }7 Q8 E( h
2.         Book2 b=(Book2) sess.get(Book2.class, 17);
   
3.         System.out.println(b);
   
4.         assertEquals("spring Recipes", b.getTitle());
   
5.         Book2 b3=(Book2) sess.get(Book2.class, 18);
   , k/ {$ v( y3 K, {- s" X
6.         assertEquals("dfad", b3.getTitle());
   ! H: h) y, j7 H# ^
7.         sess.close();
   # H9 Q3 p. q: X1 y* ^0 p' b
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]

复制代码

( }4 \/ S8 u7 o' A" d' U 在同一个session里，查询相同的对象，会先查询一级缓存，一级缓存中有就不会查询二级缓存。

1. Session sess1=sf.openSession();
   
2.         Book2 b1=(Book2) sess1.get(Book2.class, 17);
   ; p" r$ X& e4 |
3.         System.out.println(b);
   9 K# t- C  t# A' ?5 `  s- i: k' C
4.         Book2 b2=(Book2) sess1.get(Book2.class, 17);
   
5.         assertEquals("Spring Recipes", b1.getTitle());
   . R: B! r' r' C+ n" A
6.         assertEquals("Spring Recipes", b2.getTitle());
   8 A" h$ m9 q; d/ w0 L: e' B8 Z- z% l
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
   % B& b, n* b; v' ]' J
2. ountOnDisk=0,sizeInMemory=3948]

复制代码

完整测试逻辑

1. @Test
   ! h- j6 E3 P5 W* J+ L' Q
2.     public void test2LCache()
   3 J! g- y* ?9 f+ ]1 _  i; O
3.     {
   
4.         Statistics stat=sf.getStatistics();//获取stat对象
   
5.         Session sess=sf.openSession();
   
6.         Transaction tx=sess.beginTransaction();
   
7.         
   
8.         //存储对象，此时不会放到缓存中
   
9.         System.out.println("--------------存储对象---------------------------------");
   
10.         Book2 book=new Book2();
    . U0 H9 w3 r* I) g+ H
11.         book.setTitle("Spring Recipes");
    
12.         sess.saveOrUpdate(book);
      \4 @- Q- F% L2 z9 l6 o
13.         tx.commit();
    6 A5 F/ _8 r  e+ I
14.         sess.close();
    7 I2 ^/ d% `% @. Z0 [* R6 d  a( L
15.         System.out.println(book);
    5 S( J- _5 d* L7 j5 Z
16.         SecondLevelCacheStatistics slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    - {* t7 B% ]4 p* [( \* w! x
17.         System.out.println(slcs);
    / j0 W  J$ `  s9 T& ?
18.         Cache cache=sf.getCache();
    
19.         System.out.println(cache);
    
20.         cache.evictAllRegions();//从所有region中获取数据
      g5 v2 g0 ?3 Y; l, \
21.         Map map=slcs.getEntries();
    5 O, J6 ~8 U( I: K
22.         System.out.println("Cache entries:"+map.size());
    4 {" H% b2 E" y9 i& I" }9 U
23.         System.out.println("--------------第一次查询后---------------------------------");
    : ^" V! j1 }0 t, y
24.         sess=sf.openSession();
    
25.         tx=sess.beginTransaction();
    
26.         Book2 b1=(Book2) sess.byId(Book2.class).load(book.getId());//第一次查询
    & d7 l# ~/ Y; A4 M# D! M
27.         System.out.println(b1);
    / W" ]9 C4 A4 h
28.         assertEquals(book, b1);
    
29.         tx.commit();
    : m" e8 _; z8 ^3 ?* l. o
30.         sess.close();
    
31.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
32.         System.out.println(slcs);
    
33.         map=slcs.getEntries();
    2 k/ ^' W0 ~; Z7 {: M
34.         System.out.println(map.size());
    
35.         System.out.println("--------------第二次查询后---------------------------------");
    " i8 x. Q( `% ~- V7 {, R. ?5 a* `
36.         sess=sf.openSession();
    
37.         tx=sess.beginTransaction();
    4 H! g( [8 A% ?/ |# V4 s* \- H
38.         Book2 b2=(Book2) sess.byId(Book2.class).load(book.getId());//第二次查询
    
39.         System.out.println(b2);
    & z7 m+ Z+ V: n
40.         assertEquals(book, b2);
    
41.         tx.commit();
    ) z6 ?6 v4 A1 l4 d1 m
42.         sess.close();
    
43.         
    * W) Q7 K3 B8 s/ _/ g
44.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
      L2 b. ?- ]2 q$ q
45.         System.out.println(slcs);
    
46.         // this is the initial select
    - }' o3 u* A9 I4 N6 k1 w1 |' f
47.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    4 e* y; |7 `& O. p2 q3 d
48.         // we put one element in the cache from the miss
    - G8 ^% K4 L9 E
49.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    
50.         // we still didn't hit the cache, because of 1L cache
    * k0 P3 R6 ]7 G+ q$ ^3 l
51.         assertEquals(stat.getSecondLevelCacheHitCount(), 1);
    8 E$ {7 r0 F& h3 F
52.         System.out.println("--------------第三次查询后---------------------------------");
    
53.         sess=sf.openSession();
    
54.         tx=sess.beginTransaction();
    
55.         b1=(Book2) sess.byId(Book2.class).load(book.getId());//第三次查询
    * U" {5 T0 R6 G: J0 L
56.         assertEquals(book, b1);
    
57.         tx.commit();
    % z6 }' Z/ q8 Y: z1 g" e: [; V. u
58.         sess.close();
    9 x1 k5 n; [3 q1 n. F7 @' T
59.         
    5 u# {9 a% G) D
60.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    * [7 V! d( F9 Z4 k
61.         System.out.println(slcs);
    0 n. T+ f/ [1 _8 a/ V
62.         // same miss count (we should hit now)
    3 m$ k) v  P* [
63.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    
64.         // same put count (we didn't put anything new)
    
65.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    9 j* Z) E; n. d& f# h9 H
66.         // now we hit the 2L cache for load
    
67.         assertEquals(stat.getSecondLevelCacheHitCount(), 2);
    : Q' }5 f8 @$ t2 {$ L; A# E' L6 G% s
68.         
    
69.     }

复制代码

完整测试结果

1. Hibernate: delete from book2
   ; \' ~, h7 t3 K9 ?- T. w: V
2. --------------存储对象---------------------------------
   
3. Hibernate: insert into Book2 (title) values (?)
   
4. com.xinglongjian.entity.hbm.Book2@521e083b
   , _' [* X1 Q$ E9 n/ y. c
5. SecondLevelCacheStatistics[hitCount=0,missCount=0,putCount=0,elementCountInMemory=0,elementCountOnDisk=0,sizeInMemory=0]
   1 E! ~; ?* Z2 x' ^1 J! {0 p1 g
6. org.hibernate.internal.CacheImpl@4830f6
   0 ?$ U- ?( b4 g0 ]
7. Cache entries:0
   & a3 Q) q& h( K* v0 p
8. --------------第一次查询后---------------------------------
   
9. Hibernate: select book2x0_.id as id1_0_0_, book2x0_.title as title2_0_0_ from Book2 book2x0_
   
10. where book2x0_.id=?
    
11. com.xinglongjian.entity.hbm.Book2@521e083b
    
12. SecondLevelCacheStatistics[hitCount=0,missCount=1,putCount=1,elementCountInMemory=1,elementC
    ; I( p8 y9 r0 z* @' H+ T) Y
13. ountOnDisk=0,sizeInMemory=1979]
    ! j( u) X+ j' F$ p. g  [1 d) g
14. 1
    2 y' z3 g8 o2 {: {- U) `3 M. J9 t& b
15. --------------第二次查询后---------------------------------
    
16. com.xinglongjian.entity.hbm.Book2@521e083b
    5 ^! B# k6 [6 A. H- b5 R
17. SecondLevelCacheStatistics[hitCount=1,missCount=1,putCount=1,elementCountInMemory=1,elementC
    + x& s, [' m$ }2 M
18. ountOnDisk=0,sizeInMemory=1979]
    
19. --------------第三次查询后---------------------------------
    # ^% C' Z! p8 O. m/ P
20. SecondLevelCacheStatistics[hitCount=2,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
21. ountOnDisk=0,sizeInMemory=1979]

复制代码

4 i+ W5 G* j- |3 A