jetcache

การแนะนำ

JetCache เป็น Java cache abstraction ซึ่งให้การใช้งานที่เหมือนกันสำหรับโซลูชันการแคชที่แตกต่างกัน มันให้คำอธิบายประกอบที่มีประสิทธิภาพมากกว่าคำอธิบายประกอบใน Spring Cache คำอธิบายประกอบใน JetCache รองรับ TTL ดั้งเดิม การแคชสองระดับ และรีเฟรชโดยอัตโนมัติในสภาพแวดล้อมแบบกระจาย นอกจากนี้ คุณยังสามารถจัดการอินสแตนซ์ Cache ด้วยโค้ดของคุณได้ ปัจจุบันมีการใช้งานสี่แบบ: RedisCache , TairCache (ไม่ใช่โอเพ่นซอร์สบน github), CaffeineCache (ในหน่วยความจำ) และ LinkedHashMapCache แบบธรรมดา (ในหน่วยความจำ) คุณสมบัติทั้งหมดของ JetCache:

• จัดการแคชผ่าน Cache API ที่เหมือนกัน
• การแคชวิธีการประกาศโดยใช้คำอธิบายประกอบด้วย TTL (Time To Live) และการสนับสนุนการแคชสองระดับ
• สร้างและกำหนดค่าอินสแตน Cache ด้วยตัวจัดการแคช
• รวบรวมสถิติการเข้าถึงสำหรับอินสแตนซ์ Cache และแคชระดับวิธีการโดยอัตโนมัติ
• กลยุทธ์การสร้างคีย์และการทำให้เป็นอนุกรมค่าสามารถปรับแต่งได้
• รองรับการแปลงคีย์แคช: fastjson / fastjson2 / jackson ; รองรับการแปลงค่า: java / kryo / kryo5
• แคชแบบกระจายการรีเฟรชอัตโนมัติและการล็อคแบบกระจาย (2.2+)
• การเข้าถึงแบบอะซิงโครนัสโดยใช้ Cache API (2.2+ พร้อมไคลเอ็นต์ผักกาดหอม Redis)
• ทำให้แคชในเครื่องไม่ถูกต้อง (ในกระบวนการ JVM ทั้งหมด) หลังจากอัพเดต (2.7+)
• รองรับ Spring Boot

ความต้องการ:

• เจดีเค1.8
• Spring Framework4.0.8+ (optional, with annotation support)，jetcache 2.7 need 5.2.4+
• Spring Boot1.1.9+ (อุปกรณ์เสริม), jetcache 2.7 ต้องการ 2.2.5+

ไปที่เอกสารเพื่อดูรายละเอียดเพิ่มเติม

เริ่มต้นใช้งาน

แคชวิธีการ

ประกาศวิธีการแคชโดยใช้คำอธิบายประกอบ @Cached
expire = 3600 บ่งชี้ว่าองค์ประกอบจะหมดอายุใน 3600 วินาทีหลังจากตั้งค่า JetCache จะสร้างคีย์แคชพร้อมพารามิเตอร์ทั้งหมดโดยอัตโนมัติ

 public interface UserService {
    @ Cached ( expire = 3600 , cacheType = CacheType . REMOTE )
    User getUserById ( long userId );
}

การใช้ key แอตทริบิวต์เพื่อระบุคีย์แคชโดยใช้สคริปต์ SpEL

 public interface UserService {
    @ Cached ( name = "userCache-" , key = "#userId" , expire = 3600 )
    User getUserById ( long userId );

    @ CacheUpdate ( name = "userCache-" , key = "#user.userId" , value = "#user" )
    void updateUser ( User user );

    @ CacheInvalidate ( name = "userCache-" , key = "#userId" )
    void deleteUser ( long userId );
}

ในการใช้ชื่อพารามิเตอร์ เช่น key="#userId" เป้าหมายคอมไพเลอร์ javac ของคุณต้องเป็น 1.8 ขึ้นไป และควรตั้งค่า -parameters มิฉะนั้น ให้ใช้ดัชนีเพื่อเข้าถึงพารามิเตอร์เช่น key="args[0]"

รีเฟรชอัตโนมัติ:

 public interface SummaryService {
    @ Cached ( expire = 3600 , cacheType = CacheType . REMOTE )
    @ CacheRefresh ( refresh = 1800 , stopRefreshAfterLastAccess = 3600 , timeUnit = TimeUnit . SECONDS )
    @ CachePenetrationProtect
    BigDecimal summaryOfToday ( long categoryId );
}

คำอธิบายประกอบ CachePenetrationProtect บ่งชี้ว่าแคชจะถูกโหลดพร้อมกันในสภาพแวดล้อมแบบมัลติเธรด

API แคช

สร้างอินสแตนซ์ Cache ด้วย CacheManager :

 @ Autowired
private CacheManager cacheManager ;
private Cache < String , UserDO > userCache ;

@ PostConstruct
public void init () {
    QuickConfig qc = QuickConfig . newBuilder ( "userCache" )
        . expire ( Duration . ofSeconds ( 100 ))
        . cacheType ( CacheType . BOTH ) // two level cache
        . localLimit ( 50 )
        . syncLocal ( true ) // invalidate local cache in all jvm process after update
        . build ();
    userCache = cacheManager . getOrCreateCache ( qc );
}

โค้ดด้านบนสร้าง Cache ซ์แคช cacheType = CacheType.BOTH กำหนดแคชสองระดับ (แคชในหน่วยความจำภายในและระบบแคชระยะไกล) โดยมีองค์ประกอบโลคัลจำกัดไว้ที่ 50 (การขับไล่ตาม LRU) คุณสามารถใช้มันเหมือนแผนที่:

 UserDO user = userCache . get ( 12345L );
userCache . put ( 12345L , loadUserFromDataBase ( 12345L ));
userCache . remove ( 12345L );

userCache . computeIfAbsent ( 1234567L , ( key ) -> loadUserFromDataBase ( 1234567L ));

API ขั้นสูง

API แบบอะซิงโครนัส:

 CacheGetResult r = cache . GET ( userId );
CompletionStage < ResultData > future = r . future ();
future . thenRun (() -> {
    if ( r . isSuccess ()){
        System . out . println ( r . getValue ());
    }
});

ล็อคแบบกระจาย:

 cache . tryLockAndRun ( "key" , 60 , TimeUnit . SECONDS , () -> heavyDatabaseOperation ());

อ่านและรีเฟรชอัตโนมัติ:

 @ Autowired
private CacheManager cacheManager ;
private Cache < String , Long > orderSumCache ;

@ PostConstruct
public void init () {
    QuickConfig qc = QuickConfig . newBuilder ( "userCache" )
        . expire ( Duration . ofSeconds ( 3600 ))
        . loader ( this :: loadOrderSumFromDatabase )
        . refreshPolicy ( RefreshPolicy . newPolicy ( 60 , TimeUnit . SECONDS ). stopRefreshAfterLastAccess ( 100 , TimeUnit . SECONDS ))
        . penetrationProtect ( true )
        . build ();
    orderSumCache = cacheManager . getOrCreateCache ( qc );
}

การกำหนดค่าด้วย Spring Boot

ปอม:

< dependency >
    < groupId >com.alicp.jetcache</ groupId >
    < artifactId >jetcache-starter-redis</ artifactId >
    < version >${jetcache.latest.version}</ version >
</ dependency >

คลาสแอพ:

 @ SpringBootApplication
@ EnableMethodCache ( basePackages = "com.company.mypackage" )
@ EnableCreateCacheAnnotation // deprecated in jetcache 2.7, can be removed if @CreateCache is not used
public class MySpringBootApp {
    public static void main ( String [] args ) {
        SpringApplication . run ( MySpringBootApp . class );
    }
}

การกำหนดค่าสปริงบูต application.yml:

 jetcache :
  statIntervalMinutes : 15
  areaInCacheName : false
  local :
    default :
      type : linkedhashmap # other choose：caffeine
      keyConvertor : fastjson2 # other choose：fastjson/jackson
      limit : 100
  remote :
    default :
      type : redis
      keyConvertor : fastjson2 # other choose：fastjson/jackson
      broadcastChannel : projectA
      valueEncoder : java # other choose：kryo/kryo5
      valueDecoder : java # other choose：kryo/kryo5
      poolConfig :
        minIdle : 5
        maxIdle : 20
        maxTotal : 50
      host : ${redis.host}
      port : ${redis.port}

ไปที่การกำหนดค่าโดยละเอียดเพื่อดูคำแนะนำเพิ่มเติม

เอกสารเพิ่มเติม

ไปที่เอกสารเพื่อดูรายละเอียดเพิ่มเติม

สำหรับการอัพเกรด โปรดดูบันทึกการเปลี่ยนแปลงและบันทึกความเข้ากันได้