如何配置Hibernate中的二级缓存

拧巴人

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

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

1. <dependency>
   
2.           <groupId>org.hibernate</groupId>
   / p9 ]' @/ q. d7 ?& h# t
3.           <artifactId>hibernate-ehcache</artifactId>
   1 L% K% U) e$ a
4.           <version>4.3.5.Final</version>
   
5.       </dependency>

复制代码

1. <hibernate-configuration>
   
2.     <session-factory>
   ! ~" N9 P& F: A4 j- j
3.         <property name="connection.driver_class">com.mysql.jdbc.Driver</property>
   - W. s" H0 B- H5 F. u+ A4 q$ Y; P
4.         <property name="connection.url">jdbc:mysql://localhost/test</property>
   - x6 q# S* e9 [% L6 y/ d
5.         <property name="connection.username">root</property>
   & h3 X0 h' _" e5 K; Z# i
6.         <property name="connection.password"></property>
   
7.         <property name="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</property>
   
8.         <property name="hibernate.show_sql">true</property>
   + w9 k+ I" v  o6 G' e
9.         <property name="hibernate.hbm2ddl.auto">update</property>
   
10.         <property name="hibernate.generate_statistics">true</property>
    , r( C! Z1 x+ w4 e% k! |1 }
11.         <property name="hibernate.cache.region.factory_class">
    
12.             org.hibernate.cache.ehcache.EhCacheRegionFactory
    4 |; M/ G6 u* H. K/ i8 {" I  y3 T
13.         </property>
    8 Z. e1 M  S) J4 I; n
14.         <mapping class="com.xinglongjian.entity.hbm.Book2"/>
    0 k( J! @, p" K; g
15. </hibernate-configuration>

复制代码

7 f  K* w! \8 g( i) R$ v. b2 w- G 第二，通过ehcache.xml配置EHCache，该文件放置于classpath的根目录下。可以在该配置文件中设置将不同的对象存储在不同的regions。

1. <ehcache>
   
2. <diskStore path="c:/data/ehcache"/>
   7 a: C0 L5 @, }
3. <defaultCache
   
4.         maxElementsInMemory="10"
   
5.         eternal="false"
   8 G, J8 c; `3 @1 l6 a* r
6.         overflowToDisk="true"
   1 x9 l) m/ M: G- @$ l# Y
7.         timeToIdleSeconds="120"
   
8.         timeToLiveSeconds="120"
   
9.         diskPersistent="false"
   ! Q6 L; X' F8 E; d" \
10.         diskExpiryThreadIntervalSeconds="120"/>
    5 ~9 v& i: T5 O- W* R
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
   , K" R* b1 S5 y: q/ E
3. @Cache(usage=CacheConcurrencyStrategy.READ_ONLY,region="com.xinglongjian.entity.hbm.Book")
   9 Q4 e3 h3 P, Y: B; M1 N
4. public class Book2 {
   
5.     @Id
   ; w7 u, O9 W4 U7 d9 g
6.     @GeneratedValue
   
7.     private int id;
   
8.     private String title;
   
9.     public String getTitle() {
   
10.         return title;
    + o4 L& m5 m" Z5 `
11.     }
    
12.     public void setTitle(String title) {
    
13.         this.title = title;
    ) |2 Y) K& Y5 I, k
14.     }
    3 Y; t- U) v* `4 \3 ?, d
15.     public int getId() {
    + |* e. z4 ?$ ]* J
16.         return id;
    
17.     }
    1 _  v9 Q0 y$ B# B
18.     public void setId(int id) {
    
19.         this.id = id;
    & A+ P) v9 O' g* ]! x2 H7 ^
20.     }
    9 K1 Q4 J' H  u* X
21.     @Override
    
22.     public int hashCode() {
    0 k1 D6 x" ]  q  E/ `6 s
23.         final int prime = 31;
    
24.         int result = 1;
    
25.         result = prime * result + id;
    ! Q! _$ V1 x& U1 p' A$ R5 z
26.         result = prime * result + ((title == null) ? 0 : title.hashCode());
    9 ]' }( h8 d  C6 F0 S! M  w8 {
27.         return result;
    
28.     }
    & T" @7 L2 X4 s9 T$ O0 r
29.     @Override
    ( b2 @, d* T$ ?5 h  n
30.     public boolean equals(Object obj) {
    . E; H" D3 T& k9 W2 ?( D
31.         if (this == obj)
    : @; V# K! k; o
32.             return true;
    
33.         if (obj == null)
    ! ?6 Z8 w1 w" v9 g9 y4 C) |8 G
34.             return false;
    - W  b) t. @+ G& _( n
35.         if (getClass() != obj.getClass())
    
36.             return false;
    6 i- E% {* ^4 X" T
37.         Book2 other = (Book2) obj;
    
38.         if (id != other.id)
    ( Z& N. }. B1 X; K" z
39.             return false;
    
40.         if (title == null) {
    & }8 G4 C+ e: `5 @. B# ~; I% Z
41.             if (other.title != null)
    
42.                 return false;
    9 Z3 z  R! \, `
43.         } else if (!title.equals(other.title))
    
44.             return false;
    ( h8 @( b- a9 i/ U- J1 P0 k& w8 p
45.         return true;
    
46.     }
    . q) `6 b* x2 O1 N2 x4 E% O0 T
47.    
    
48. }

复制代码

二级缓存的持久化类必须实现equals方法。
7 i+ g6 D' E! H
只有在SELECT时才会缓存。

, `: u* _6 ^+ v/ @在同一个session里，查询2个不同的对象，会缓存2次，

1. Session sess=sf.openSession();
   
2.         Book2 b=(Book2) sess.get(Book2.class, 17);
   
3.         System.out.println(b);
   + W" ^* R- I$ U7 t3 Y1 q( w5 H
4.         assertEquals("spring Recipes", b.getTitle());
   
5.         Book2 b3=(Book2) sess.get(Book2.class, 18);
   9 ]5 l1 N, t9 ^
6.         assertEquals("dfad", b3.getTitle());
   $ k/ l" p( Y0 U' E
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);
   + T3 O6 z' M1 Y; X! k! E7 L
3.         System.out.println(b);
   
4.         Book2 b2=(Book2) sess1.get(Book2.class, 17);
   * g- S1 `; j8 C& r! W
5.         assertEquals("Spring Recipes", b1.getTitle());
   5 s6 U' |2 B' P% `- ~) b% I8 M
6.         assertEquals("Spring Recipes", b2.getTitle());
   4 x- V+ ?  V( n
7.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
   % h6 |* B6 J* s0 i+ i
8.         System.out.println(slcs);

复制代码

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

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

复制代码

完整测试逻辑

1. @Test
   & }# n" D0 q) J5 m; q, ~
2.     public void test2LCache()
   7 E3 x7 L7 j! O# W; s
3.     {
   + Q& E0 z4 G; }6 _
4.         Statistics stat=sf.getStatistics();//获取stat对象
   
5.         Session sess=sf.openSession();
   8 Q+ _1 n6 Z# _" q! ?% U
6.         Transaction tx=sess.beginTransaction();
   
7.         
   
8.         //存储对象，此时不会放到缓存中
   ! N8 `7 d. N% ^
9.         System.out.println("--------------存储对象---------------------------------");
   
10.         Book2 book=new Book2();
    # o; Y2 T# h# N$ z
11.         book.setTitle("Spring Recipes");
    
12.         sess.saveOrUpdate(book);
    
13.         tx.commit();
    ! D/ m; X3 K+ i- g
14.         sess.close();
    
15.         System.out.println(book);
    ( Y* H( b; w% k# c- n% \
16.         SecondLevelCacheStatistics slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
17.         System.out.println(slcs);
    
18.         Cache cache=sf.getCache();
    
19.         System.out.println(cache);
    
20.         cache.evictAllRegions();//从所有region中获取数据
    ' D! h5 _, ~: Z) J" W! Z
21.         Map map=slcs.getEntries();
    
22.         System.out.println("Cache entries:"+map.size());
    $ u* |0 y* d! J- J3 x
23.         System.out.println("--------------第一次查询后---------------------------------");
    
24.         sess=sf.openSession();
    ' \  f( L6 @8 {7 j0 f
25.         tx=sess.beginTransaction();
    
26.         Book2 b1=(Book2) sess.byId(Book2.class).load(book.getId());//第一次查询
    
27.         System.out.println(b1);
    
28.         assertEquals(book, b1);
    
29.         tx.commit();
    
30.         sess.close();
    8 ]5 a4 Q/ \# k3 t3 u
31.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
32.         System.out.println(slcs);
    ) y: W1 |8 o- u
33.         map=slcs.getEntries();
    
34.         System.out.println(map.size());
    % P1 o# e/ _; {1 x9 J$ l
35.         System.out.println("--------------第二次查询后---------------------------------");
    : _  q2 D- z( A* n* @- N* b
36.         sess=sf.openSession();
    , X+ H  ?; [8 L
37.         tx=sess.beginTransaction();
    
38.         Book2 b2=(Book2) sess.byId(Book2.class).load(book.getId());//第二次查询
    
39.         System.out.println(b2);
    
40.         assertEquals(book, b2);
    
41.         tx.commit();
    
42.         sess.close();
    
43.         
    , V% o9 B  ~: {3 T2 k3 W& i
44.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    " b% i3 y) v9 a& }' ]2 w1 v( r5 D
45.         System.out.println(slcs);
    2 s* d; `  a/ R3 D
46.         // this is the initial select
    
47.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    1 V& H  ?8 n/ P: g- ~
48.         // we put one element in the cache from the miss
    
49.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    ' P1 k' @5 _1 F6 O# k0 E
50.         // we still didn't hit the cache, because of 1L cache
    % u& ?9 b7 I& j5 c. y$ H* q
51.         assertEquals(stat.getSecondLevelCacheHitCount(), 1);
    - |3 \, g5 W( `. Y. g! G$ u2 X
52.         System.out.println("--------------第三次查询后---------------------------------");
    
53.         sess=sf.openSession();
    
54.         tx=sess.beginTransaction();
    / W$ s! q: h  s* M3 q2 F
55.         b1=(Book2) sess.byId(Book2.class).load(book.getId());//第三次查询
    
56.         assertEquals(book, b1);
    7 ~; Y5 z3 }) H$ k" }
57.         tx.commit();
      n) s7 l5 w( ~9 ^
58.         sess.close();
    
59.         
    9 `' T9 R% M2 s: e4 A  Y
60.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
61.         System.out.println(slcs);
    
62.         // same miss count (we should hit now)
    . T. D8 A' L/ D1 o% d4 {- L
63.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    8 |5 t( G4 z# }! w% D# {: X. @
64.         // same put count (we didn't put anything new)
    5 O- X, W  o3 Z/ J% `: L
65.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    
66.         // now we hit the 2L cache for load
    
67.         assertEquals(stat.getSecondLevelCacheHitCount(), 2);
    
68.         
    
69.     }

复制代码

完整测试结果

1. Hibernate: delete from book2
   
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]
   $ b0 m& S( w0 T' ^3 b
6. org.hibernate.internal.CacheImpl@4830f6
   / o& L* a/ L8 g8 I1 L
7. Cache entries:0
   5 X: o9 N8 A/ A
8. --------------第一次查询后---------------------------------
   $ {; G# z* ~$ U" y3 @% l  F
9. Hibernate: select book2x0_.id as id1_0_0_, book2x0_.title as title2_0_0_ from Book2 book2x0_
     i7 U( n3 x& O& f0 f( O% l
10. where book2x0_.id=?
    & b; k) f8 h4 C
11. com.xinglongjian.entity.hbm.Book2@521e083b
    
12. SecondLevelCacheStatistics[hitCount=0,missCount=1,putCount=1,elementCountInMemory=1,elementC
    5 V: l. L, c& |. T5 q
13. ountOnDisk=0,sizeInMemory=1979]
    
14. 1
    / d# S! y& x1 z& G% [) y6 E
15. --------------第二次查询后---------------------------------
    
16. com.xinglongjian.entity.hbm.Book2@521e083b
    # D( k% u' j$ W
17. SecondLevelCacheStatistics[hitCount=1,missCount=1,putCount=1,elementCountInMemory=1,elementC
    & G  |( z. t% @& U) _: [
18. ountOnDisk=0,sizeInMemory=1979]
    
19. --------------第三次查询后---------------------------------
    
20. SecondLevelCacheStatistics[hitCount=2,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
21. ountOnDisk=0,sizeInMemory=1979]

复制代码

$ i: T5 B9 K- W' D