Загрузка jetcache - Загрузка исходного кода jetcache

jetcache

Исходный код JAVA

v2.7.7

Скачать

Введение

JetCache — это абстракция кэша Java, которая обеспечивает единообразное использование различных решений кэширования. Он предоставляет более мощные аннотации, чем в 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 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 );
}

Использование атрибута 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}