如何配置Hibernate中的二级缓存

拧巴人

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

/ a+ I* Y5 B8 g  m) c' a; m6 b首先，要在hibernate.cfg.xml中设置一个cache Provider，hibernate支持多个cache实现，有EHCache，OSCache等。在非分布式环境中可以选择默认的EHCache。添加ehcahe jar

1. <dependency>
   
2.           <groupId>org.hibernate</groupId>
   3 k; n2 ?! U8 R/ s0 X, K! V
3.           <artifactId>hibernate-ehcache</artifactId>
   
4.           <version>4.3.5.Final</version>
   6 J6 x( R9 W: V: o' \9 v; Z
5.       </dependency>

复制代码

1. <hibernate-configuration>
   ; C% Z  t$ S( v, g& z
2.     <session-factory>
   5 H: g2 ]- J0 j; t1 a% A3 r
3.         <property name="connection.driver_class">com.mysql.jdbc.Driver</property>
   - S. e; q% R; b2 a; F
4.         <property name="connection.url">jdbc:mysql://localhost/test</property>
   6 a3 {& ~4 c0 v7 R3 n. J
5.         <property name="connection.username">root</property>
   ; D0 y- z1 b- 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>
   
9.         <property name="hibernate.hbm2ddl.auto">update</property>
   
10.         <property name="hibernate.generate_statistics">true</property>
    4 K, _8 D2 z# t1 z  T: }7 z
11.         <property name="hibernate.cache.region.factory_class">
    & _7 L# j+ I0 S- r/ [
12.             org.hibernate.cache.ehcache.EhCacheRegionFactory
    
13.         </property>
    ! s7 N  W8 O  _. \+ j) t
14.         <mapping class="com.xinglongjian.entity.hbm.Book2"/>
    2 U! z0 L* @% X' C0 W, S* o3 ~! s
15. </hibernate-configuration>

复制代码

# ~3 d' Q! x; }6 f- x4 d 第二，通过ehcache.xml配置EHCache，该文件放置于classpath的根目录下。可以在该配置文件中设置将不同的对象存储在不同的regions。

1. <ehcache>
   
2. <diskStore path="c:/data/ehcache"/>
   3 j/ `! r  H, x6 {+ b/ M
3. <defaultCache
   
4.         maxElementsInMemory="10"
   ! o  N3 X4 V4 A1 F, T: M
5.         eternal="false"
   
6.         overflowToDisk="true"
   
7.         timeToIdleSeconds="120"
   / N, `0 E5 r3 W
8.         timeToLiveSeconds="120"
   8 E& Q  M( C! o* e$ `
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 R1 `4 j- e3 S4 S- Z7 A- h8 [  K
2. @Cacheable
     C1 b' B7 K/ f6 G3 A' j
3. @Cache(usage=CacheConcurrencyStrategy.READ_ONLY,region="com.xinglongjian.entity.hbm.Book")
   
4. public class Book2 {
   
5.     @Id
     D. v) e( v5 {/ n% z2 d! G
6.     @GeneratedValue
   
7.     private int id;
   ) A( x- |' N$ Q  ~
8.     private String title;
   
9.     public String getTitle() {
   
10.         return title;
    $ U+ w. S" M% ~6 Q  k
11.     }
    
12.     public void setTitle(String title) {
    + v( D0 J+ I6 d- l1 l  @
13.         this.title = title;
    0 r( l, B( v; U" h/ t
14.     }
    
15.     public int getId() {
    1 M+ ~# ]% m7 s8 E
16.         return id;
    
17.     }
    * G: u; }0 I5 E, \  D+ q2 L9 E
18.     public void setId(int id) {
    $ R; P; S) q5 Q' U4 {
19.         this.id = id;
    
20.     }
    
21.     @Override
    " g% u' k2 G- ~) F
22.     public int hashCode() {
    
23.         final int prime = 31;
    
24.         int result = 1;
    & `; Q5 l' F* z
25.         result = prime * result + id;
    
26.         result = prime * result + ((title == null) ? 0 : title.hashCode());
    
27.         return result;
    2 q) R$ f1 C& ^
28.     }
    
29.     @Override
    
30.     public boolean equals(Object obj) {
    - l+ Z+ @* c1 U: L7 O3 L3 e
31.         if (this == obj)
    
32.             return true;
    8 w- e/ n& v% N
33.         if (obj == null)
    
34.             return false;
    
35.         if (getClass() != obj.getClass())
    
36.             return false;
    . g9 w/ S0 V% o% j8 g7 h
37.         Book2 other = (Book2) obj;
    
38.         if (id != other.id)
    
39.             return false;
    & R0 g! G0 Q, i1 @
40.         if (title == null) {
    
41.             if (other.title != null)
    
42.                 return false;
    
43.         } else if (!title.equals(other.title))
    
44.             return false;
    
45.         return true;
    
46.     }
    / P+ F+ M  K2 z  y
47.    
    
48. }

复制代码

二级缓存的持久化类必须实现equals方法。
& K  O  q4 \" n+ L2 _* w' ~$ j1 Y
& w" {$ ^/ L- r9 }只有在SELECT时才会缓存。

) e' C* d- ^7 u2 H6 Y' A: D3 _在同一个session里，查询2个不同的对象，会缓存2次，

1. Session sess=sf.openSession();
   
2.         Book2 b=(Book2) sess.get(Book2.class, 17);
   9 y  E! n1 B# @  s2 W
3.         System.out.println(b);
   9 I4 R* |, x+ \% }: T- D
4.         assertEquals("spring Recipes", b.getTitle());
     ~; i& l' E- K3 O$ ~7 p
5.         Book2 b3=(Book2) sess.get(Book2.class, 18);
   , k' T1 l' `3 V- Q& D! t4 L
6.         assertEquals("dfad", b3.getTitle());
   - _, W# U/ M' r4 R0 D9 l$ A$ T4 h
7.         sess.close();
   / Z. Z6 i; P. r# L. c. N/ i, Z
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]

复制代码

  h7 n9 [1 y1 X$ y/ E9 w 在同一个session里，查询相同的对象，会先查询一级缓存，一级缓存中有就不会查询二级缓存。

1. Session sess1=sf.openSession();
   
2.         Book2 b1=(Book2) sess1.get(Book2.class, 17);
   & `- c& ~' d4 A2 p
3.         System.out.println(b);
   
4.         Book2 b2=(Book2) sess1.get(Book2.class, 17);
   " [1 ?. [3 L2 q2 u% o
5.         assertEquals("Spring Recipes", b1.getTitle());
   
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
   
2. ountOnDisk=0,sizeInMemory=3948]

复制代码

完整测试逻辑

1. @Test
   
2.     public void test2LCache()
   3 P) u& @1 r/ P
3.     {
   
4.         Statistics stat=sf.getStatistics();//获取stat对象
   ' D' ]/ D# s- D+ G% ]. ?3 S
5.         Session sess=sf.openSession();
   
6.         Transaction tx=sess.beginTransaction();
   - O+ s; A! W) @7 H
7.         
   
8.         //存储对象，此时不会放到缓存中
   ; {) u7 [3 A3 R; q6 n  B! {( b
9.         System.out.println("--------------存储对象---------------------------------");
   
10.         Book2 book=new Book2();
    
11.         book.setTitle("Spring Recipes");
    $ e6 c; M. w  {
12.         sess.saveOrUpdate(book);
    
13.         tx.commit();
    ! Y5 X* `2 T8 R7 h$ [. @; q
14.         sess.close();
    
15.         System.out.println(book);
    ) C8 C! Q& R) T2 \" i
16.         SecondLevelCacheStatistics slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    / Y6 b1 g5 S. L
17.         System.out.println(slcs);
    
18.         Cache cache=sf.getCache();
    * F3 W4 H: }1 F0 t% z8 U0 d
19.         System.out.println(cache);
      |) D9 H% Q( @7 P+ E
20.         cache.evictAllRegions();//从所有region中获取数据
    
21.         Map map=slcs.getEntries();
    
22.         System.out.println("Cache entries:"+map.size());
      v7 q6 `1 y+ G+ h
23.         System.out.println("--------------第一次查询后---------------------------------");
    " p. W0 o( I0 N0 y8 A4 ^7 J
24.         sess=sf.openSession();
    
25.         tx=sess.beginTransaction();
    9 x1 g/ w' v2 x5 h% k4 P
26.         Book2 b1=(Book2) sess.byId(Book2.class).load(book.getId());//第一次查询
    
27.         System.out.println(b1);
    
28.         assertEquals(book, b1);
    ( H6 o. @* g* ~4 E5 [
29.         tx.commit();
    # K8 k+ B" o9 V2 U+ m
30.         sess.close();
    
31.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    # o) p8 Y# x" A  v, G: Y. [/ s9 d
32.         System.out.println(slcs);
    
33.         map=slcs.getEntries();
    
34.         System.out.println(map.size());
    ; F' k+ i  R0 i4 J6 J1 \
35.         System.out.println("--------------第二次查询后---------------------------------");
    
36.         sess=sf.openSession();
    
37.         tx=sess.beginTransaction();
    0 |7 [3 c9 R7 y$ h6 u! @5 C
38.         Book2 b2=(Book2) sess.byId(Book2.class).load(book.getId());//第二次查询
    
39.         System.out.println(b2);
    * M- X: h' J8 s6 V$ b3 D! v
40.         assertEquals(book, b2);
      z1 G$ o# R8 [: R) W7 ]
41.         tx.commit();
    
42.         sess.close();
    : l" V4 o: S* u! ?& u( L+ b
43.         
    , Q8 A; @$ [. V2 Q
44.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    ' D- c. ?" K# ]2 |( W
45.         System.out.println(slcs);
    
46.         // this is the initial select
    ! O% W* T' _. `
47.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    ' j1 U4 v6 [2 l# N2 d& E3 W2 Z
48.         // we put one element in the cache from the miss
    5 K7 `. ?8 [6 T* ^! k4 u
49.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    + j. I  ^* R/ e& F5 c# q
50.         // we still didn't hit the cache, because of 1L cache
    
51.         assertEquals(stat.getSecondLevelCacheHitCount(), 1);
    " O: b; m; D; o6 n
52.         System.out.println("--------------第三次查询后---------------------------------");
    
53.         sess=sf.openSession();
    : U8 W* w& X$ r- |. q, T# m) O. @
54.         tx=sess.beginTransaction();
    . B5 T/ V( @5 @7 k) y6 e5 Z
55.         b1=(Book2) sess.byId(Book2.class).load(book.getId());//第三次查询
    
56.         assertEquals(book, b1);
    % e: i$ h- D+ R# ^: `: f6 V: H) @
57.         tx.commit();
    - H, C  }* k1 v. r- I; C
58.         sess.close();
    
59.         
    
60.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
61.         System.out.println(slcs);
    8 U; @: C! ^2 p& L$ M: L
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
    4 o+ ?( g- j( }: x4 D8 D  v
67.         assertEquals(stat.getSecondLevelCacheHitCount(), 2);
    , d5 ]2 h/ P2 k. ^, B
68.         
    
69.     }

复制代码

完整测试结果

1. Hibernate: delete from book2
   * F" W  O# O8 m: E& C. S% e0 b# W
2. --------------存储对象---------------------------------
   + s* A: p2 i& W2 E$ b( b% |" P7 ?
3. Hibernate: insert into Book2 (title) values (?)
   + x  u/ j  D; ~7 l7 u. L" C$ E
4. com.xinglongjian.entity.hbm.Book2@521e083b
   ! w0 H0 l5 ~2 l% f& }/ G
5. SecondLevelCacheStatistics[hitCount=0,missCount=0,putCount=0,elementCountInMemory=0,elementCountOnDisk=0,sizeInMemory=0]
   " |$ k0 P! P1 h. [9 r) }# G8 x
6. org.hibernate.internal.CacheImpl@4830f6
   
7. Cache entries:0
   
8. --------------第一次查询后---------------------------------
   : v4 Y6 }/ |4 M* m* ~) g. k
9. Hibernate: select book2x0_.id as id1_0_0_, book2x0_.title as title2_0_0_ from Book2 book2x0_
   2 t5 j, S5 P) @% j
10. where book2x0_.id=?
    ) V) t8 f1 J1 F& L' |9 D4 g
11. com.xinglongjian.entity.hbm.Book2@521e083b
    
12. SecondLevelCacheStatistics[hitCount=0,missCount=1,putCount=1,elementCountInMemory=1,elementC
    6 s$ H! m0 j- s* Y
13. ountOnDisk=0,sizeInMemory=1979]
    
14. 1
    
15. --------------第二次查询后---------------------------------
    
16. com.xinglongjian.entity.hbm.Book2@521e083b
    
17. SecondLevelCacheStatistics[hitCount=1,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
18. ountOnDisk=0,sizeInMemory=1979]
    
19. --------------第三次查询后---------------------------------
    7 V  h9 X% }, q. L
20. SecondLevelCacheStatistics[hitCount=2,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
21. ountOnDisk=0,sizeInMemory=1979]

复制代码

% ]9 E& C2 d5 b