如何配置Hibernate中的二级缓存

拧巴人

需要启动二级缓存，二级缓存的scope是sessionFactory。也就是说二级缓存的数据可以在由相同SessionFactory创建的多个Session中重用。
6 c# W+ w  g1 k
首先，要在hibernate.cfg.xml中设置一个cache Provider，hibernate支持多个cache实现，有EHCache，OSCache等。在非分布式环境中可以选择默认的EHCache。添加ehcahe jar
8 J( B5 H# I1 Z9 t. ?5 P* c. F. s

1. <dependency>
   8 v( W% g/ s! f5 K
2.           <groupId>org.hibernate</groupId>
   
3.           <artifactId>hibernate-ehcache</artifactId>
   
4.           <version>4.3.5.Final</version>
   
5.       </dependency>

复制代码

1. <hibernate-configuration>
   % |$ _3 x* L- G7 z( k
2.     <session-factory>
   
3.         <property name="connection.driver_class">com.mysql.jdbc.Driver</property>
   
4.         <property name="connection.url">jdbc:mysql://localhost/test</property>
   ) ?2 T+ s- Z9 D4 k2 j9 N
5.         <property name="connection.username">root</property>
   
6.         <property name="connection.password"></property>
   - }+ a/ A  [1 ]) v$ @* f
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>
    
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>
   0 e% a) p$ _: a4 z; L, P$ h% P# G
2. <diskStore path="c:/data/ehcache"/>
   
3. <defaultCache
   
4.         maxElementsInMemory="10"
   
5.         eternal="false"
   ; f  i# ~. c4 U
6.         overflowToDisk="true"
   / p- j! v$ p/ m) f5 O7 X, q
7.         timeToIdleSeconds="120"
     ]* \: b( c% ?; E, V4 r/ ^; f
8.         timeToLiveSeconds="120"
   * }$ x/ c% k& S# ]6 |* D2 H3 F
9.         diskPersistent="false"
   
10.         diskExpiryThreadIntervalSeconds="120"/>
    
11. <cache name="com.xinglongjian.entity.hbm.Book" maxElementsInMemory="10"  eternal="false"
    1 f1 @& ], G' S* B8 s
12.     overflowToDisk="false" timeToIdleSeconds="120" timeToLiveSeconds="120" diskPersistent="false"/>
    
13. </ehcache>

复制代码

第三，设置持久化类

1. @Entity
   
2. @Cacheable
   4 O; M+ V% n$ A6 a- e$ E: i: R
3. @Cache(usage=CacheConcurrencyStrategy.READ_ONLY,region="com.xinglongjian.entity.hbm.Book")
   
4. public class Book2 {
   
5.     @Id
   # F$ Y1 j' a. d; J- `( M
6.     @GeneratedValue
   
7.     private int id;
   8 c" ~: O# x% a- a& \
8.     private String title;
   
9.     public String getTitle() {
   % a7 I# K3 D& |' Q6 Y
10.         return title;
    " T4 ^8 ^2 ?$ T' k, \. n0 ]
11.     }
    
12.     public void setTitle(String title) {
    
13.         this.title = title;
    - D/ Q- R+ P! I. l1 P
14.     }
    
15.     public int getId() {
    
16.         return id;
    
17.     }
    
18.     public void setId(int id) {
    , j' B( s$ y* h% ^, K
19.         this.id = id;
    
20.     }
    
21.     @Override
    
22.     public int hashCode() {
    
23.         final int prime = 31;
    
24.         int result = 1;
    
25.         result = prime * result + id;
    ! |9 U! G& R1 N& x' p
26.         result = prime * result + ((title == null) ? 0 : title.hashCode());
    / R5 C3 Q8 ^! ~# N1 L5 q4 S, o4 u
27.         return result;
    
28.     }
    % L6 L3 }7 d3 B
29.     @Override
    - T4 Z2 ]; J& M" ~( a
30.     public boolean equals(Object obj) {
    9 K  C2 u* |  T2 @) U2 k, x( h7 k
31.         if (this == obj)
    
32.             return true;
    0 }5 a3 |4 a+ I4 w' e" }3 x6 S
33.         if (obj == null)
    
34.             return false;
    
35.         if (getClass() != obj.getClass())
    + c. f+ a" f+ s
36.             return false;
    
37.         Book2 other = (Book2) obj;
    
38.         if (id != other.id)
    
39.             return false;
    
40.         if (title == null) {
    
41.             if (other.title != null)
    2 u% w7 _) n5 a+ O  H3 K1 K3 o
42.                 return false;
    , c; M0 `+ N: Y' ]. w
43.         } else if (!title.equals(other.title))
    / Q, n4 u0 v/ Y/ g* K5 M2 u4 G
44.             return false;
    . p: [. H$ [1 u
45.         return true;
    
46.     }
    
47.    
    
48. }

复制代码

二级缓存的持久化类必须实现equals方法。
+ L" @. X5 ^* m/ N5 p* L) A& z
只有在SELECT时才会缓存。

) c2 e, d6 f' ^, d" b在同一个session里，查询2个不同的对象，会缓存2次，

1. Session sess=sf.openSession();
   $ v( U; W) ?, x4 h' D7 V% O. L
2.         Book2 b=(Book2) sess.get(Book2.class, 17);
   
3.         System.out.println(b);
   
4.         assertEquals("spring Recipes", b.getTitle());
   " n$ z0 c- a: x
5.         Book2 b3=(Book2) sess.get(Book2.class, 18);
   
6.         assertEquals("dfad", b3.getTitle());
   - E4 K' {  K" P
7.         sess.close();
   4 T5 a( p% c! S1 s' U7 `# y. A
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]

复制代码

" [' ?2 ]  o) b* ` 在同一个session里，查询相同的对象，会先查询一级缓存，一级缓存中有就不会查询二级缓存。

1. Session sess1=sf.openSession();
   ) G7 x* ~/ ]! w. ]  V1 n
2.         Book2 b1=(Book2) sess1.get(Book2.class, 17);
   
3.         System.out.println(b);
   
4.         Book2 b2=(Book2) sess1.get(Book2.class, 17);
   2 a: e% O* `; e  h0 `# U) E
5.         assertEquals("Spring Recipes", b1.getTitle());
   4 t% B# O6 g$ D1 @' l( ?/ p  T
6.         assertEquals("Spring Recipes", b2.getTitle());
   
7.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
   ' |- M& ~; T: A* J5 e6 [
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()
   / z+ B* P2 J  |
3.     {
   
4.         Statistics stat=sf.getStatistics();//获取stat对象
   8 N* Y# o; c5 T* A. k2 U! }6 t
5.         Session sess=sf.openSession();
   
6.         Transaction tx=sess.beginTransaction();
   ) I4 B, n1 R% t) r, q% a) N. x
7.         
   - E" w# M- C/ f5 p- c" ~8 _4 i
8.         //存储对象，此时不会放到缓存中
   
9.         System.out.println("--------------存储对象---------------------------------");
   5 e. D# j( c3 D9 }) k! e1 \
10.         Book2 book=new Book2();
    5 A. c* W# Z* a1 |9 w1 _& ?
11.         book.setTitle("Spring Recipes");
    
12.         sess.saveOrUpdate(book);
    
13.         tx.commit();
    
14.         sess.close();
    
15.         System.out.println(book);
    
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);
    / _7 I6 ]( x- c- _3 x; t
20.         cache.evictAllRegions();//从所有region中获取数据
    + q0 E( X5 W: P2 o+ R9 j
21.         Map map=slcs.getEntries();
    8 d& ?1 s- i7 s' a9 ^
22.         System.out.println("Cache entries:"+map.size());
    ; @9 U! F3 h2 z5 S) D) O" E3 M8 b
23.         System.out.println("--------------第一次查询后---------------------------------");
    
24.         sess=sf.openSession();
    ; A) O+ M; q9 O) k* K- B
25.         tx=sess.beginTransaction();
    1 }0 g, k* Z4 P( q/ c4 ?4 G# f- g
26.         Book2 b1=(Book2) sess.byId(Book2.class).load(book.getId());//第一次查询
    
27.         System.out.println(b1);
    
28.         assertEquals(book, b1);
    4 S7 k) K+ |5 s, |: Y5 m4 e# S
29.         tx.commit();
    
30.         sess.close();
    
31.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
32.         System.out.println(slcs);
    8 P; t- O4 @3 ~8 Y
33.         map=slcs.getEntries();
    + h# q$ M) y4 E$ K* R
34.         System.out.println(map.size());
    
35.         System.out.println("--------------第二次查询后---------------------------------");
    ; h9 u2 t4 I8 |
36.         sess=sf.openSession();
    + l/ a: ?4 G, G' {7 r; ?9 F
37.         tx=sess.beginTransaction();
    + g& X. J) p6 A
38.         Book2 b2=(Book2) sess.byId(Book2.class).load(book.getId());//第二次查询
    % {  E+ o8 ~) \. K
39.         System.out.println(b2);
    ' }. d3 R, m* j1 A
40.         assertEquals(book, b2);
    : {$ s+ p2 w  t/ ]
41.         tx.commit();
    
42.         sess.close();
    
43.         
    
44.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    0 Z5 j. s5 z  D
45.         System.out.println(slcs);
    
46.         // this is the initial select
    % v! I0 e4 u5 C8 T7 N/ r
47.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    
48.         // we put one element in the cache from the miss
    0 s! _& S6 W& X, ^0 |3 K% J* v
49.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    
50.         // we still didn't hit the cache, because of 1L cache
    
51.         assertEquals(stat.getSecondLevelCacheHitCount(), 1);
    
52.         System.out.println("--------------第三次查询后---------------------------------");
    ! z& J, w8 a* }! L$ v0 a
53.         sess=sf.openSession();
    & P4 m3 g# }" ?  R2 O6 f
54.         tx=sess.beginTransaction();
    
55.         b1=(Book2) sess.byId(Book2.class).load(book.getId());//第三次查询
    
56.         assertEquals(book, b1);
    - m$ L+ s( V$ c, ~6 i2 i# A
57.         tx.commit();
    
58.         sess.close();
    
59.         
    2 V# o5 Q' d; |  Z0 T, G! I
60.         slcs=stat.getSecondLevelCacheStatistics("com.xinglongjian.entity.hbm.Book");
    
61.         System.out.println(slcs);
    : B2 X6 L+ V) i$ X  m
62.         // same miss count (we should hit now)
    # x( U" Y  e/ q7 L7 d, Y
63.         assertEquals(stat.getSecondLevelCacheMissCount(), 1);
    . P, W8 R; J! q
64.         // same put count (we didn't put anything new)
    ; y9 [8 C  d9 I$ i5 a1 M3 h
65.         assertEquals(stat.getSecondLevelCachePutCount(), 1);
    " f/ A. Y5 G2 I4 C+ t5 L' A
66.         // now we hit the 2L cache for load
    & R+ n$ ]8 y6 X5 k3 T) E
67.         assertEquals(stat.getSecondLevelCacheHitCount(), 2);
    
68.         
    " s. `* X/ S$ V4 w0 \# M
69.     }

复制代码

完整测试结果

1. Hibernate: delete from book2
   7 U: v  l  E6 g; C
2. --------------存储对象---------------------------------
   
3. Hibernate: insert into Book2 (title) values (?)
   5 z- L$ O" J7 H; w0 d" C  D, F
4. com.xinglongjian.entity.hbm.Book2@521e083b
   
5. SecondLevelCacheStatistics[hitCount=0,missCount=0,putCount=0,elementCountInMemory=0,elementCountOnDisk=0,sizeInMemory=0]
   
6. org.hibernate.internal.CacheImpl@4830f6
   9 f  C, j/ r  h' T. Q: I
7. Cache entries:0
   
8. --------------第一次查询后---------------------------------
   1 K" F4 {0 l% P* ?4 t
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
    
13. ountOnDisk=0,sizeInMemory=1979]
    
14. 1
    
15. --------------第二次查询后---------------------------------
    & B- o! h' F& k- X7 g, t
16. com.xinglongjian.entity.hbm.Book2@521e083b
    " _% w2 f5 W& ^  ]" F2 V! y3 M
17. SecondLevelCacheStatistics[hitCount=1,missCount=1,putCount=1,elementCountInMemory=1,elementC
    
18. ountOnDisk=0,sizeInMemory=1979]
    : N5 C% e& `  w: v3 H, P) z
19. --------------第三次查询后---------------------------------
    
20. SecondLevelCacheStatistics[hitCount=2,missCount=1,putCount=1,elementCountInMemory=1,elementC
    , ^. L4 V6 H3 G  V. X3 K
21. ountOnDisk=0,sizeInMemory=1979]

复制代码

% D- k0 y$ r4 C' @- B, a3 K$ ]5 A