如何配置Hibernate中的二级缓存

拧巴人

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

- L& R& c) f1 s+ V0 m3 E5 ]7 }首先，要在hibernate.cfg.xml中设置一个cache Provider，hibernate支持多个cache实现，有EHCache，OSCache等。在非分布式环境中可以选择默认的EHCache。添加ehcahe jar

1. <dependency>
   # x! c  c' D! b5 c
2.           <groupId>org.hibernate</groupId>
   
3.           <artifactId>hibernate-ehcache</artifactId>
   
4.           <version>4.3.5.Final</version>
   
5.       </dependency>

复制代码

1. <hibernate-configuration>
   " U4 G1 q( D- g
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>
   ) i- M% N. Q3 E  e$ w; g9 P
6.         <property name="connection.password"></property>
   # G- |; \; K9 j' v0 }* x( M
7.         <property name="hibernate.dialect">org.hibernate.dialect.MySQL5Dialect</property>
   . C2 u. ?' @8 u) _- j
8.         <property name="hibernate.show_sql">true</property>
   : I0 P/ e* ?- q) G
9.         <property name="hibernate.hbm2ddl.auto">update</property>
   % O! O' M4 g% j4 G7 T
10.         <property name="hibernate.generate_statistics">true</property>
    4 F0 i: R+ a) T& m* T
11.         <property name="hibernate.cache.region.factory_class">
    
12.             org.hibernate.cache.ehcache.EhCacheRegionFactory
    
13.         </property>
    
14.         <mapping class="com.xinglongjian.entity.hbm.Book2"/>
    
15. </hibernate-configuration>

复制代码

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

1. <ehcache>
   - A! ^9 \! Y; c* {% d/ w
2. <diskStore path="c:/data/ehcache"/>
   5 h1 b" L. f# ^
3. <defaultCache
   
4.         maxElementsInMemory="10"
   
5.         eternal="false"
   
6.         overflowToDisk="true"
   ' d8 X$ U' F+ B4 a) m. x0 N+ j9 `6 C
7.         timeToIdleSeconds="120"
   2 d4 A6 i& ~8 r, [( z
8.         timeToLiveSeconds="120"
   
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
   ) i, |. h+ L$ \: z
2. @Cacheable
   
3. @Cache(usage=CacheConcurrencyStrategy.READ_ONLY,region="com.xinglongjian.entity.hbm.Book")
   9 Y% s3 H! ^0 z* ^
4. public class Book2 {
   0 i9 A/ d6 }0 u- M9 s$ A
5.     @Id
   
6.     @GeneratedValue
   ( `8 c+ J1 w6 q0 X7 v5 o
7.     private int id;
   
8.     private String title;
   
9.     public String getTitle() {
   
10.         return title;
    " o! ^. f# R9 T: J( D/ \( w
11.     }
    3 L* R. ~% S2 D; R+ m
12.     public void setTitle(String title) {
    
13.         this.title = title;
    
14.     }
    
15.     public int getId() {
    ( d4 N5 O( k2 e
16.         return id;
      \! f; J* G! i0 j" V- J
17.     }
    
18.     public void setId(int id) {
    ; z' i) ~5 s( m/ F4 n, n: P
19.         this.id = id;
    
20.     }
    4 M/ u& m' P, x6 d2 y5 \" p1 _/ t
21.     @Override
    
22.     public int hashCode() {
    
23.         final int prime = 31;
    3 K. Z' e/ U; {9 r
24.         int result = 1;
    & X& B" u' R( D; t! y# z9 S% {
25.         result = prime * result + id;
    
26.         result = prime * result + ((title == null) ? 0 : title.hashCode());
    3 Q" Y& ?- W9 e
27.         return result;
    
28.     }
    ! o; T" y- w4 t1 R1 r3 ?
29.     @Override
    
30.     public boolean equals(Object obj) {
    
31.         if (this == obj)
    % }- f7 f8 }9 G+ X6 M
32.             return true;
    & V- ]2 ?3 X) s- E$ Q* R0 q
33.         if (obj == null)
    
34.             return false;
    ' R  u' Z5 x& b& I; W- V% z+ |
35.         if (getClass() != obj.getClass())
    
36.             return false;
    
37.         Book2 other = (Book2) obj;
    
38.         if (id != other.id)
    
39.             return false;
    : Z- z. ~: ^) c3 M7 C
40.         if (title == null) {
    
41.             if (other.title != null)
    ( J& ?6 j. H+ q3 t4 w
42.                 return false;
    " Y% Q$ ?' r* z, `3 i2 ]& c
43.         } else if (!title.equals(other.title))
    ' h* k+ O2 w, s/ q2 `* h6 V2 S/ D5 T
44.             return false;
    
45.         return true;
    ) O; S" m$ |! w+ M  u
46.     }
    & C5 }( V$ n' W; l0 p5 A5 d$ h
47.    
    * u3 }2 k% o/ R- a. N; a$ e
48. }

复制代码

二级缓存的持久化类必须实现equals方法。
2 i3 Z( Z' r: X7 I) I2 m8 r
只有在SELECT时才会缓存。
9 z& S! H- N- [
在同一个session里，查询2个不同的对象，会缓存2次，

1. Session sess=sf.openSession();
   7 K2 e9 C# P* C- b: Z
2.         Book2 b=(Book2) sess.get(Book2.class, 17);
   - R& c* d6 P  E6 C' F. C# n) B# @- \
3.         System.out.println(b);
   
4.         assertEquals("spring Recipes", b.getTitle());
   
5.         Book2 b3=(Book2) sess.get(Book2.class, 18);
   : p! S' M& ?9 M: m
6.         assertEquals("dfad", b3.getTitle());
   ) c4 e% k7 }' r, M0 K
7.         sess.close();
   
8.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
   . |7 I1 P! K; Z( U
9.         System.out.println(slcs);

复制代码

结果

1. SecondLevelCacheStatistics[hitCount=0,missCount=2,putCount=2,elementCountInMemory=2,elementC
   4 c  V  X6 t, G8 I; V7 o8 F
2. ountOnDisk=0,sizeInMemory=3948]

复制代码

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

1. Session sess1=sf.openSession();
     u5 E" s0 s/ }- }; @1 Z, t
2.         Book2 b1=(Book2) sess1.get(Book2.class, 17);
   
3.         System.out.println(b);
   * n3 `! Y, K3 ~1 T0 N5 E! K
4.         Book2 b2=(Book2) sess1.get(Book2.class, 17);
   
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()
   2 w# X! k6 ^+ h
3.     {
   * k7 ?% y4 r3 @( T8 C+ f7 m
4.         Statistics stat=sf.getStatistics();//获取stat对象
   
5.         Session sess=sf.openSession();
   ; k8 Z" X% I/ f4 E* y, \
6.         Transaction tx=sess.beginTransaction();
   : \1 ^' j; d. ]0 S
7.         
   
8.         //存储对象，此时不会放到缓存中
   
9.         System.out.println("--------------存储对象---------------------------------");
   % ?# q) F$ F1 y! b# S4 z  P  t9 `
10.         Book2 book=new Book2();
    
11.         book.setTitle("Spring Recipes");
    
12.         sess.saveOrUpdate(book);
    , j$ I: R4 X4 n8 p
13.         tx.commit();
    
14.         sess.close();
    
15.         System.out.println(book);
    
16.         SecondLevelCacheStatistics slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    # `9 d7 j; S  ~, [) H( j
17.         System.out.println(slcs);
    
18.         Cache cache=sf.getCache();
    8 _( p9 X! x3 E. b3 W, G
19.         System.out.println(cache);
    
20.         cache.evictAllRegions();//从所有region中获取数据
    
21.         Map map=slcs.getEntries();
    5 e4 a4 e. d% m7 s3 R* M
22.         System.out.println("Cache entries:"+map.size());
    
23.         System.out.println("--------------第一次查询后---------------------------------");
    
24.         sess=sf.openSession();
    % S4 G; l4 k3 [$ j7 S
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();
    / y* i. O/ i) S
30.         sess.close();
    * e8 A/ |4 x* _4 }) G
31.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
32.         System.out.println(slcs);
    # [+ o) j3 i  f1 Q' c' Z
33.         map=slcs.getEntries();
    
34.         System.out.println(map.size());
    9 f. z  `! _( Y# c, q9 ~
35.         System.out.println("--------------第二次查询后---------------------------------");
    
36.         sess=sf.openSession();
    
37.         tx=sess.beginTransaction();
    
38.         Book2 b2=(Book2) sess.byId(Book2.class).load(book.getId());//第二次查询
    2 ~1 ~( ], R* q. h% H9 I1 O
39.         System.out.println(b2);
    1 M3 R/ j9 ~8 H4 r( |
40.         assertEquals(book, b2);
    
41.         tx.commit();
    + A4 [1 X# K) @- h' _& t( y4 E
42.         sess.close();
    
43.         
    
44.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    $ k9 F* {9 q8 |# W+ ]
45.         System.out.println(slcs);
    
46.         // this is the initial select
    
47.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    
48.         // we put one element in the cache from the miss
    
49.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    
50.         // we still didn't hit the cache, because of 1L cache
    4 m$ K; H4 Z; M: @+ i: K
51.         assertEquals(stat.getSecondLevelCacheHitCount(), 1);
    1 i5 e" E! l1 d5 y
52.         System.out.println("--------------第三次查询后---------------------------------");
    ! P7 d* O8 r. r( {) t% `
53.         sess=sf.openSession();
    
54.         tx=sess.beginTransaction();
    + S6 Q$ T0 o. Y* g0 M5 W
55.         b1=(Book2) sess.byId(Book2.class).load(book.getId());//第三次查询
    % P/ n: u. K/ i  t  q
56.         assertEquals(book, b1);
    
57.         tx.commit();
    " t6 d: c. g: W2 }; @9 s  h6 X
58.         sess.close();
    
59.         
    
60.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    . ]$ M5 `1 N4 r0 D9 Q+ L. C1 F3 m& T
61.         System.out.println(slcs);
    ) A# x0 B( P( [
62.         // same miss count (we should hit now)
    3 ?, Q8 a7 \) N5 t8 Y% D" D" t
63.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    4 @9 t1 L: w5 v2 \0 ^) [. x
64.         // same put count (we didn't put anything new)
    
65.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    + g- R+ x. k) U# ]
66.         // now we hit the 2L cache for load
    * y5 o) M& g& U7 b  D+ S
67.         assertEquals(stat.getSecondLevelCacheHitCount(), 2);
    : j  _/ |6 [4 W
68.         
    
69.     }

复制代码

完整测试结果

1. Hibernate: delete from book2
   # P; L! `6 H% ~8 q) o) {; Y5 Q
2. --------------存储对象---------------------------------
   , r. d7 j& U; A5 n$ R) f
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]
   3 X0 s: Z( n% l
6. org.hibernate.internal.CacheImpl@4830f6
   
7. Cache entries:0
   . a& L% m8 E" y. k5 h2 n' \# Q+ ^
8. --------------第一次查询后---------------------------------
   + \) X3 k# I  U
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
    * P2 c& |2 n! L0 K3 u' Y( L! z1 ~
12. SecondLevelCacheStatistics[hitCount=0,missCount=1,putCount=1,elementCountInMemory=1,elementC
    6 |  n8 X1 Y5 r: k
13. ountOnDisk=0,sizeInMemory=1979]
    ' k: b5 [; r$ x0 l0 ^. T- t
14. 1
    * i4 p& S$ J! Q' R: B  Q: Z
15. --------------第二次查询后---------------------------------
    - n* T3 g  j: u9 Y9 E5 O
16. com.xinglongjian.entity.hbm.Book2@521e083b
    ( F, z5 j6 Z/ D4 I6 j. R4 K
17. SecondLevelCacheStatistics[hitCount=1,missCount=1,putCount=1,elementCountInMemory=1,elementC
    * g6 Z: k! a* k
18. ountOnDisk=0,sizeInMemory=1979]
    3 a1 l4 f% H5 @: l! n5 M
19. --------------第三次查询后---------------------------------
    
20. SecondLevelCacheStatistics[hitCount=2,missCount=1,putCount=1,elementCountInMemory=1,elementC
    6 \" B( E8 x* j  c* T" V
21. ountOnDisk=0,sizeInMemory=1979]

复制代码