如何配置Hibernate中的二级缓存

拧巴人

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

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

1. <dependency>
   
2.           <groupId>org.hibernate</groupId>
   2 f$ k6 w9 B9 }
3.           <artifactId>hibernate-ehcache</artifactId>
   ' k- L% n. @2 M. X: @
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>
   3 w- f3 G" C- ~3 Q/ b5 h
5.         <property name="connection.username">root</property>
   * M9 Q5 G* n' {7 Q# O& F* y
6.         <property name="connection.password"></property>
   " c( t: q1 J& ~6 a# f( S2 q
7.         <property name="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</property>
   7 ^- F( h; C7 o: V2 ^% G8 }
8.         <property name="hibernate.show_sql">true</property>
   
9.         <property name="hibernate.hbm2ddl.auto">update</property>
   
10.         <property name="hibernate.generate_statistics">true</property>
    6 S5 k$ ~- b: n1 S" h
11.         <property name="hibernate.cache.region.factory_class">
    8 t- w& u8 L. H# S  U$ @
12.             org.hibernate.cache.ehcache.EhCacheRegionFactory
    " S' H3 z) i6 W6 ~# C' _
13.         </property>
    0 A; N5 o+ X: R! ?$ E, _
14.         <mapping class="com.xinglongjian.entity.hbm.Book2"/>
    2 u' ]/ E) \3 z# c0 G/ f7 s4 Z
15. </hibernate-configuration>

复制代码

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

1. <ehcache>
   ) O$ W5 ]( w& b+ }, V7 H
2. <diskStore path="c:/data/ehcache"/>
   % ?) X3 U, w6 y
3. <defaultCache
   
4.         maxElementsInMemory="10"
   
5.         eternal="false"
   ( i; ?9 a; B- w$ V: T, V1 x
6.         overflowToDisk="true"
   ' P0 ^; ?% u: {2 ?2 u, S
7.         timeToIdleSeconds="120"
   
8.         timeToLiveSeconds="120"
   ( u8 X: D# i: Z* T9 N
9.         diskPersistent="false"
   
10.         diskExpiryThreadIntervalSeconds="120"/>
    : c7 Y' u4 h) i: _: ?# t, a
11. <cache name="com.xinglongjian.entity.hbm.Book" maxElementsInMemory="10"  eternal="false"
    4 _0 S! y3 M0 ~/ T( Z5 S
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")
   
4. public class Book2 {
   ) d8 i8 N" ~. n" Q8 k
5.     @Id
   * _8 {2 N* E; V) k: e# A
6.     @GeneratedValue
   2 z3 b* `3 ]* Z$ [
7.     private int id;
   
8.     private String title;
   1 ^4 S% _) [* `
9.     public String getTitle() {
   * c3 k  {/ l+ f& K: O8 t& Z# p
10.         return title;
    
11.     }
    
12.     public void setTitle(String title) {
    3 o, d; s7 B! w" G5 @! K  x
13.         this.title = title;
    $ @4 D1 i9 r3 o
14.     }
    3 D! n# t1 G6 ]* H! i0 e9 R2 L  Z
15.     public int getId() {
    
16.         return id;
    
17.     }
    
18.     public void setId(int id) {
    ) N# m5 z! t" a! g
19.         this.id = id;
    / a" V1 o1 Z* C( Y( u* H1 q
20.     }
    : y: _( d" |# X5 ~5 Z0 k, ]& U
21.     @Override
    
22.     public int hashCode() {
    * m3 {1 W+ [: q, c+ m9 G) g
23.         final int prime = 31;
    
24.         int result = 1;
    
25.         result = prime * result + id;
    $ v# L7 E8 y; l8 c
26.         result = prime * result + ((title == null) ? 0 : title.hashCode());
    
27.         return result;
    
28.     }
    ' Q, |; ?" r2 ]) {
29.     @Override
    
30.     public boolean equals(Object obj) {
    
31.         if (this == obj)
    
32.             return true;
    , _. Y8 X  I. E2 L. `
33.         if (obj == null)
    ) V/ B! ]- z0 V$ x. j  x
34.             return false;
    0 L% ?+ E2 u0 P8 w
35.         if (getClass() != obj.getClass())
    
36.             return false;
    " T+ t: N8 j* S, U5 v5 t' W& @
37.         Book2 other = (Book2) obj;
    : O- S! s5 m- d% o
38.         if (id != other.id)
    
39.             return false;
    
40.         if (title == null) {
    
41.             if (other.title != null)
    5 i2 D& i' e$ a2 M3 ^1 B# M8 B; q
42.                 return false;
    
43.         } else if (!title.equals(other.title))
    
44.             return false;
    
45.         return true;
    4 t  S' x0 e& Z4 _4 @
46.     }
    : T7 a  J! [1 D; _0 _3 `
47.    
    
48. }

复制代码

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

只有在SELECT时才会缓存。
% ?( s+ T9 U4 u6 c0 W, U1 P
$ a& v5 K' j+ t! n3 }在同一个session里，查询2个不同的对象，会缓存2次，

1. Session sess=sf.openSession();
   
2.         Book2 b=(Book2) sess.get(Book2.class, 17);
   
3.         System.out.println(b);
   7 b! h+ R1 w5 T
4.         assertEquals("spring Recipes", b.getTitle());
   " t. R0 C3 l: E, u2 V$ O1 S; i
5.         Book2 b3=(Book2) sess.get(Book2.class, 18);
   6 m( L; l! A3 Q7 b
6.         assertEquals("dfad", b3.getTitle());
   
7.         sess.close();
   4 W: M; s# b7 p
8.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
   0 [+ r" |8 _. @
9.         System.out.println(slcs);

复制代码

结果

1. SecondLevelCacheStatistics[hitCount=0,missCount=2,putCount=2,elementCountInMemory=2,elementC
   ( \9 \. I8 j7 h+ L3 \) D" C( ?' _
2. ountOnDisk=0,sizeInMemory=3948]

复制代码

) ~) n3 M# u& F# a* ~% W; z* m 在同一个session里，查询相同的对象，会先查询一级缓存，一级缓存中有就不会查询二级缓存。

1. Session sess1=sf.openSession();
   
2.         Book2 b1=(Book2) sess1.get(Book2.class, 17);
   & e+ b# L. v3 U6 y% h4 S
3.         System.out.println(b);
   " \- I5 v9 L& B" s1 W
4.         Book2 b2=(Book2) sess1.get(Book2.class, 17);
   
5.         assertEquals("Spring Recipes", b1.getTitle());
   
6.         assertEquals("Spring Recipes", b2.getTitle());
     }2 X# o9 b6 h
7.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
   . G( f2 Z1 S- Q$ q
8.         System.out.println(slcs);

复制代码

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

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

复制代码

完整测试逻辑

1. @Test
   
2.     public void test2LCache()
   ( ~$ ?8 T, E9 P& K. ?8 p# p
3.     {
   + j4 ^5 G; H  W) Z. d5 U. j
4.         Statistics stat=sf.getStatistics();//获取stat对象
   
5.         Session sess=sf.openSession();
   
6.         Transaction tx=sess.beginTransaction();
   
7.         
   8 T/ H. ~% d) M" P
8.         //存储对象，此时不会放到缓存中
   ! x! K+ d" L& j7 N* ]6 B# T& l0 g
9.         System.out.println("--------------存储对象---------------------------------");
   
10.         Book2 book=new Book2();
      J3 ]; W1 l1 f' f: b* i, u* d
11.         book.setTitle("Spring Recipes");
    
12.         sess.saveOrUpdate(book);
    ! z) [  _. K5 p! R  l
13.         tx.commit();
    
14.         sess.close();
    
15.         System.out.println(book);
    ) E" C3 t# j6 X+ d. m* s  r. `
16.         SecondLevelCacheStatistics slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
17.         System.out.println(slcs);
    2 R, `0 m( `# K0 J8 U. g
18.         Cache cache=sf.getCache();
    
19.         System.out.println(cache);
    4 H8 l- ]$ ]+ k
20.         cache.evictAllRegions();//从所有region中获取数据
    9 ]7 m- u) n( _* ?
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();
    
26.         Book2 b1=(Book2) sess.byId(Book2.class).load(book.getId());//第一次查询
    2 [4 m* H! v5 W, O$ P
27.         System.out.println(b1);
    , ^. c3 P8 ]$ n3 R+ B
28.         assertEquals(book, b1);
    
29.         tx.commit();
    # ]* d" q" M2 O7 a# x6 T
30.         sess.close();
    9 }, Y3 k; g$ E' I8 N
31.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
32.         System.out.println(slcs);
    
33.         map=slcs.getEntries();
    ( r! h# D" I; l
34.         System.out.println(map.size());
    2 \* A0 h+ S, s+ _7 D0 S$ [" N: {4 I
35.         System.out.println("--------------第二次查询后---------------------------------");
    
36.         sess=sf.openSession();
    + v$ D7 e* W% e
37.         tx=sess.beginTransaction();
    ! n6 h4 M2 Z( z- D( F7 j
38.         Book2 b2=(Book2) sess.byId(Book2.class).load(book.getId());//第二次查询
    " a) n6 K! Z$ x2 h0 ^
39.         System.out.println(b2);
    * E6 d( L* ^: G% |
40.         assertEquals(book, b2);
    # ~+ M$ l: v# f2 u- G
41.         tx.commit();
    1 U* G6 M( e8 f7 V* X) [
42.         sess.close();
    
43.         
    + X& I7 S6 [0 x/ P3 m
44.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
45.         System.out.println(slcs);
    % \- x. ]- I4 R5 G. g: n  v1 ]$ h
46.         // this is the initial select
    
47.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
      [9 t' l6 g- J( O5 {$ ]
48.         // we put one element in the cache from the miss
    6 N5 }3 o7 `- ?% @+ R
49.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    : ?+ L. ~/ \' S4 E3 k5 {& L. _, ?: n
50.         // we still didn't hit the cache, because of 1L cache
    
51.         assertEquals(stat.getSecondLevelCacheHitCount(), 1);
    + e; p3 ~# E0 Q6 d6 H
52.         System.out.println("--------------第三次查询后---------------------------------");
    % [% k. T7 f  D
53.         sess=sf.openSession();
    % i: V' \. F+ ?; O  i! T) j  [# u
54.         tx=sess.beginTransaction();
    1 U1 A/ \: _* f" l1 ]
55.         b1=(Book2) sess.byId(Book2.class).load(book.getId());//第三次查询
    
56.         assertEquals(book, b1);
    
57.         tx.commit();
    $ a; \# z9 L: G
58.         sess.close();
    ' t0 Z# n! h/ G( ?1 o$ p8 y( h# W
59.         
    
60.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    3 k6 F. I8 l, ]# C/ E, {) S
61.         System.out.println(slcs);
    * |! T+ g7 I0 r, P9 V5 O* Y! H
62.         // same miss count (we should hit now)
    
63.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    
64.         // same put count (we didn't put anything new)
    
65.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    
66.         // now we hit the 2L cache for load
    
67.         assertEquals(stat.getSecondLevelCacheHitCount(), 2);
    % X0 z0 e4 C1 A- J/ |" L
68.         
    9 |& S$ u3 B; j6 |( _- ?0 i9 d
69.     }

复制代码

完整测试结果

1. Hibernate: delete from book2
   4 j% }; n4 t' C9 R9 G0 z
2. --------------存储对象---------------------------------
   
3. Hibernate: insert into Book2 (title) values (?)
   
4. com.xinglongjian.entity.hbm.Book2@521e083b
   9 x: H4 O2 Y  D9 B9 y
5. SecondLevelCacheStatistics[hitCount=0,missCount=0,putCount=0,elementCountInMemory=0,elementCountOnDisk=0,sizeInMemory=0]
   
6. org.hibernate.internal.CacheImpl@4830f6
   & Z2 C. f* H/ w
7. Cache entries:0
   
8. --------------第一次查询后---------------------------------
   
9. Hibernate: select book2x0_.id as id1_0_0_, book2x0_.title as title2_0_0_ from Book2 book2x0_
   4 e$ F6 C3 Z0 V
10. where book2x0_.id=?
    * |  }/ k5 V! M& S: b0 I
11. com.xinglongjian.entity.hbm.Book2@521e083b
    $ ^1 n9 ^8 H. ]3 Z( [
12. SecondLevelCacheStatistics[hitCount=0,missCount=1,putCount=1,elementCountInMemory=1,elementC
    % W! T. l( o& _
13. ountOnDisk=0,sizeInMemory=1979]
    
14. 1
    
15. --------------第二次查询后---------------------------------
    : s) e% Z1 U9 p- i
16. com.xinglongjian.entity.hbm.Book2@521e083b
    1 Z2 n8 y: f) s) q  ~# I0 G) j
17. SecondLevelCacheStatistics[hitCount=1,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
18. ountOnDisk=0,sizeInMemory=1979]
      z) m9 g9 E4 g9 {  K; Z
19. --------------第三次查询后---------------------------------
    
20. SecondLevelCacheStatistics[hitCount=2,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
21. ountOnDisk=0,sizeInMemory=1979]

复制代码