jetcache下載 - jetcache原始碼下載

jetcache

JAVA源碼

v2.7.7

下載

介紹

JetCache 是一種 Java 快取抽象，它為不同的快取解決方案提供統一的使用方式。它提供了比 Spring Cache 中更強大的註解。 JetCache中的註解支援原生TTL，二級緩存，並在分散式環境中自動刷新，您也可以透過程式碼操作Cache實例。目前有四種實作： RedisCache 、 TairCache （未在 github 上開源）、 CaffeineCache （在記憶體中）和一個簡單的LinkedHashMapCache （在記憶體中）。 JetCache 的完整功能：

透過統一的快取 API 操作快取。
使用帶有 TTL（生存時間）註釋的聲明式方法快取和二級快取支持
使用快取管理器建立和配置Cache實例
自動收集Cache實例和方法級快取的存取統計信息
金鑰產生和值序列化策略可自訂
支援的快取密鑰轉換器： fastjson / fastjson2 / jackson ；支援的值轉換器： java / kryo / kryo5
分散式快取自動刷新和分散式鎖定。 (2.2+)
使用Cache API進行非同步存取（2.2+，附redis lettuce客戶端）
更新後使本機快取（在所有 JVM 進程中）失效（2.7+）
Spring Boot 支持

要求：

JDK1.8
Spring Framework4.0.8+（可選，附註解支援），jetcache 2.7需要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 );
}

使用 SpEL 腳本使用key屬性指定快取鍵。

 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

使用CacheManager建立一個Cache實例：

 @ 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 配置

pom：

< 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}