Получить динамический параметр, на который есть ссылка в аннотации, с помощью Spring SpEL Expression

Question

Я пытаюсь создать аннотацию, которая очень похожа на то, что предоставляет @Cacheable Annotation Spring.

При использовании в верхней части метода это выглядит следующим образом:

@CleverCache(key = "'orders_'.concat(#id)")
public Order getOrder(int id) {

Когда я использую то же самое с использованием Cacheable, он каким-то образом может интерпретировать это выражение SpEL и генерировать ключ, который имеет значение orders_1234 (для id = 1234)

Мой совет соответствия выглядит какследующее:

@Around("CleverCachePointcut(cleverCache)")
public Object clevercache(ProceedingJoinPoint joinPoint, CleverCache cleverCache) throws Throwable {
    String expression = cleverCache.key();
    //FIXME: Please add working code here :D - extracting the key by interpreting the passed SpEL Expression in expression

Я определенно получил там выражение, но я еще не понял, как заставить его работать, чтобы оно правильно интерпретировало выражение SpEL.

Еще один вспомогательный синтаксисдолжно быть key = "T(com.example.Utils).createCacheKey(#paramOfMethodByName)", где вызывается статический помощник для создания ключа.

Есть идеи, как это может работать?Код, из которого у меня есть фрагменты, доступен по адресу: https://github.com/eiselems/spring-redis-two-layer-cache/blob/master/src/main/java/com/marcuseisele/example/twolayercache/clevercache/ExampleAspect.java#L35

Любая помощь действительно приветствуется!

Answer 1

На самом деле довольно просто оценить SpEL, если у вас есть необходимая контекстная информация.Пожалуйста, обратитесь к этой статье , чтобы узнать, как программно анализировать SpEL.

Что касается этой контекстной информации, вы не очень много объяснили о типах методов, которые вы аннотировали @CleverCache,Дело в том, что pointcut перехватывает все аннотированные методы, и я не знаю, является ли первый параметр каждого из них int ID.В зависимости от ответа на этот вопрос проще (всего один простой случай) или сложнее (вам нужно if-else, чтобы просто найти методы с целочисленным идентификатором), чтобы получить значение аргумента ID из перехваченного метода.Или, может быть, у вас есть все виды выражений, ссылающихся на несколько типов и имен параметров метода, переменных экземпляра или чего-то еще.Сложность решения связана со сложностью требований.Если вы предоставите больше информации, возможно, я также смогу предоставить дополнительную помощь.

---

Обновление: Посмотрев ваше репозиторий GitHub, я изменил ваш аспект для простого случая:

package com.marcuseisele.example.twolayercache.clevercache;

import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.expression.EvaluationContext;
import org.springframework.expression.Expression;
import org.springframework.expression.ExpressionParser;
import org.springframework.expression.spel.standard.SpelExpressionParser;
import org.springframework.expression.spel.support.StandardEvaluationContext;
import org.springframework.stereotype.Component;

import java.util.Map;
import java.util.concurrent.TimeUnit;

@Aspect
@Component
@Slf4j
public class ExampleAspect {
    private static final ExpressionParser expressionParser = new SpelExpressionParser();

    private Map<String, RedisTemplate> templates;

    public ExampleAspect(Map<String, RedisTemplate> redisTemplateMap) {
        this.templates = redisTemplateMap;
    }

    @Pointcut("@annotation(cleverCache)")
    public void CleverCachePointcut(CleverCache cleverCache) {
    }

    @Around("CleverCachePointcut(cleverCache) && args(id)")
    public Object clevercache(ProceedingJoinPoint joinPoint, CleverCache cleverCache, int id) throws Throwable {
        long ttl = cleverCache.ttl();
        long grace = cleverCache.graceTtl();

        String key = cleverCache.key();
        Expression expression = expressionParser.parseExpression(key);
        EvaluationContext context = new StandardEvaluationContext();
        context.setVariable("id", id);
        String cacheKey = (String) expression.getValue(context);
        System.out.println("### Cache key: " + cacheKey);

        long start = System.currentTimeMillis();
        RedisTemplate redisTemplate = templates.get(cleverCache.redisTemplate());
        Object result;
        if (redisTemplate.hasKey(cacheKey)) {
            result = redisTemplate.opsForValue().get(cacheKey);
            log.info("Reading from cache ..." + result.toString());

            if (redisTemplate.getExpire(cacheKey, TimeUnit.MINUTES) < grace) {
                log.info("Entry is in Grace period - trying to refresh it");
                try {
                    result = joinPoint.proceed();
                    redisTemplate.opsForValue().set(cacheKey, result, grace+ttl, TimeUnit.MINUTES);
                    log.info("Fetch was successful - new value will be returned");
                } catch (Exception e) {
                    log.warn("An error occured while trying to refresh the value - extending the old one", e);
                    //TODO: think about only adding 5 minutes on top of grace, or 50% of ttl on top of grace
                    //if protected by a circuit breaker we could go REALLY low here
                    redisTemplate.opsForValue().getOperations().expire(cacheKey, grace+ttl, TimeUnit.MINUTES);
                }

            }

        } else {
            result = joinPoint.proceed();
            log.info("Giving from method ..." + result.toString());
            redisTemplate.opsForValue().set(cacheKey, result, ttl + grace, TimeUnit.MINUTES);
        }

        long executionTime = System.currentTimeMillis() - start;
        log.info("{} executed in {} ms", joinPoint.getSignature(), executionTime);
        log.info("Result: {}", result);
        return result;
    }
}

Разница выглядит следующим образом: