@Cacheable 测试方法

Question

我在课堂内有一个@cach的方法。 我尝试在第一次呼叫该方法后创建该缓存，然后，第二个调用不应进入方法 getcacheleads 。

@Service
public class LeadService {

    @Autowired
    private LeadRepository leadRepository;

    @Autowired
    public LeadService(LeadRepository leadRepository) {
        this.leadRepository = leadRepository;
    }

    public void calculateLead(Lead leadBean) {
        Lead lead = this.getCacheLeads(leadBean);
    }

    @Cacheable(cacheNames="leads", key="#leadBean.leadId")
    public Lead getCacheLeads(Lead leadBean){
        Lead result = leadRepository.findByLeadId(leadBean.getLeadId());
        ***logic to transform de Lead object***
        return result;
    }
}

但是，在测试中，从未使用过缓存，将其称为两次使用相同的参数（ serviceSiscalled ），以确保将其调用两次以检查它。

@ExtendWith(SpringExtension.class)
public class LeadServiceTest {

    private LeadService leadService;
    
    @Mock
    private LeadRepository leadRepository;
    
    @Autowired 
    CacheManager cacheManager;
    
    @BeforeEach
    public void setUp(){
        leadService = new LeadService(leadRepository);
    }

    @Configuration
    @EnableCaching
    static class Config {
        @Bean
        CacheManager cacheManager() {
            return new ConcurrentMapCacheManager("leads"); 
        }
    }
    
    @Test
    public void testLead(){
        givenData();
        serviceIsCalled();
        serviceIsCalled();
        checkDataArray();
    }
    
    private void givenData() {
        Lead lead = new Lead();
        lead.setLeadId("DC635EA19A39EA128764BB99052E5D1A9A");
        
        Mockito.when(leadRepository.findByLeadId(any()))
        .thenReturn(lead);
    }
    
    private void serviceIsCalled(){
        Lead lead = new Lead();
        lead.setLeadId("DC635EA19A39EA128764BB99052E5D1A9A");
        leadService.calculateLead(lead);
    }
    
    private void checkDataArray(){
        verify(leadRepository, times(1)).findByLeadId(anyString());
    }
}

为什么叫2次？

Answer 1

这里发生了很多事情，有人看到这个并回答你的问题肯定需要阅读字里行间的内容。

首先，您的 Spring 配置甚至不正确。您使用 ConcurrentMapCacheManager “静态”声明 Spring 应用程序（和测试）使用的所有缓存的名称 构造函数接受缓存名称数组作为参数。

注意：通过名称显式标识的缓存，并且只有这些缓存在运行时可用。

@Bean
CacheManager cacheManager() {
    return new ConcurrentMapCacheManager("LEAD_DATA"); 
}

在这种情况下，您的第一个也是唯一的缓存称为“LEAD_DATA”。

注意：仅无参数构造函数 允许在运行时按名称动态创建缓存。

但是，然后，在您的 @Service LeadService 类中， @Cacheable getCacheLeads(:Lead) 方法中，您声明缓存用作“线索”。

@Service
public class LeadService {

    @Cacheable(cacheNames="leads", key="#leadBean.leadId")
    public Lead getCacheLeads(Lead leadBean){
        // ...
    }
}

这种未命中配置实际上会导致运行时出现类似于以下内容的异常：

java.lang.IllegalArgumentException: Cannot find cache named 'leads' for Builder[public io.stackoverflow.questions.spring.cache.StaticCacheNamesIntegrationTests$Lead io.stackoverflow.questions.spring.cache.StaticCacheNamesIntegrationTests$LeadService.load(io.stackoverflow.questions.spring.cache.StaticCacheNamesIntegrationTests$Lead)] caches=[leads] | key='#lead.id' | keyGenerator='' | cacheManager='' | cacheResolver='' | condition='' | unless='' | sync='false'

    at org.springframework.cache.interceptor.AbstractCacheResolver.resolveCaches(AbstractCacheResolver.java:92)
    at org.springframework.cache.interceptor.CacheAspectSupport.getCaches(CacheAspectSupport.java:252)
    at org.springframework.cache.interceptor.CacheAspectSupport$CacheOperationContext.<init>(CacheAspectSupport.java:724)
    at org.springframework.cache.interceptor.CacheAspectSupport.getOperationContext(CacheAspectSupport.java:265)
    at org.springframework.cache.interceptor.CacheAspectSupport$CacheOperationContexts.<init>(CacheAspectSupport.java:615)
    at org.springframework.cache.interceptor.CacheAspectSupport.execute(CacheAspectSupport.java:345)
    at org.springframework.cache.interceptor.CacheInterceptor.invoke(CacheInterceptor.java:64)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:753)
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:698)
    at io.stackoverflow.questions.spring.cache.StaticCacheNamesIntegrationTests$LeadService$EnhancerBySpringCGLIB$86664246.load(<generated>)
...
..
.

此外，我没有看到 LeadsService bean 调用 @Cacheable 的“外部”任何内容， getCacheLeads(..) 方法。在您的测试中，您正在调用：

leadService.calculateLead(lead);

如下所示：

private void serviceIsCalled(){
    Lead lead = new Lead();
    lead.setLeadId("DC635EA19A39EA128764BB99052E5D1A9A");
    leadService.calculateLead(lead);
}

如果 calculateLead(:Lead) LeadService 方法正在调用 @Cacheable，getCacheLeads(:Lead) LeadService 方法（内部），那么这不会导致缓存功能启动，因为您已经在 Spring 设置的 AOP 代理“后面”为您的 LeadService bean“启用”缓存行为。

请参阅 Spring 框架 AOP 文档。

注意： Spring 的缓存抽象，如Spring 的事务管理，是建立在Spring AOP 基础设施，就像 Spring 中的许多其他东西一样。

在您的情况下，这意味着：

Test -> <PROXY> -> LeadService.calculateLead(:Lead) -> LeadService.getCacheLeads(:Lead)

但是，在 LeadSevice.calculateLead(:Lead) 和 LeadService.getCacheLeads(:Lead) 之间，不涉及代理，因此 Spring 的缓存行为不会被应用。

仅...

Test (or some other bean) -> <PROXY> -> LeadService.getCacheLeads(:Lead)

将导致用被调用的缓存拦截器装饰的 AOP 代理并应用缓存行为。

您可以看到，如果正确配置和使用，您的用例将正常工作，如我的 示例测试类，以您的域为模型。

查找解释为什么您的配置在您的情况下会失败的注释。