@Cacheable 不工作，仍在调用缓存方法

Question

我正在尝试使用@Cacheable 来缓存角色，而不管参数如何。但是@Cacheable 并不能很好地工作，并且该方法会被调用两次。

缓存配置：

@Configuration
@EnableCaching
public class CachingConfig {

    @Bean
    public CacheManager cacheManager(@Value("${caching.ttl.period}") long period,
                                     @Value("${caching.ttl.unit}") String unit) {
        return new ConcurrentMapCacheManager() {
            @Override
            public Cache createConcurrentMapCache(String name) {
                return new ConcurrentMapCache(name, CacheBuilder.newBuilder()
                        .expireAfterWrite(period, TimeUnit.valueOf(unit)).build().asMap(), true);
            }
        };
    }
}

角色映射服务：

@Service
public class RoleMappingService {
private final AdminClient adminClient;

    public RoleMappingService(AdminClient adminClient) {
        this.adminClient = adminClient;
    }

    @Cacheable(value = "allRoles", key = "#root.method")
    public List<Role> getAllRoles(String sessionToken) {
        AdminSession adminSession = new AdminSession();
        AdminSession.setSessionToken(sessionToken);

        List<RoleGroup> allRoleGroups = this.adminClient.getAllRoleGroups(adminSession)
                .orElse(Collections.emptyList());

        List<Role> allRoles = allRoleGroups
                .stream()
                .map(RoleGroup::getRoles)
                .flatMap(List::stream)
                .collect(Collectors.toList());

        return allRoles;
    }

测试：

@SpringBootTest(classes = Application.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)

public class RoleCachingTest {

    private final JFixture fixture = new JFixture();

    private AdminClient adminClient = mock(AdminClient.class);

    @Test
    public void allRolesShouldBeCached(){
        RoleGroup mockRoleGroup = mock(RoleGroup.class);
        Role mockRole = this.fixture.create(Role.class);

        when(this.adminClient.getAllRoleGroups(any(AdminSession.class)))
                .thenReturn(Optional.of(Arrays.asList(mockRoleGroup)));

        when(mockRoleGroup.getRoles()).thenReturn(Arrays.asList(mockRole));

        RoleMappingService sut = new RoleMappingService(adminClient);

        List<Role> firstRes = sut.getAllRoles(
                fixture.create(String.class));

        List<Role> secondRes = sut.getAllRoles(
                fixture.create(String.class));
        assertEquals(firstRes.size(), secondRes.size());
        assertEquals(firstRes.get(0).getId(), secondRes.get(0).getId());
        assertEquals(firstRes.get(0).getRoleName(), secondRes.get(0).getRoleName());

        // The getAllRoleGroups() should not be called on the second call
        verify(this.adminClient, times(1)).getAllRoleGroups(any(AdminSession.class));

    }

在这个测试中 adminClient.getAllRoleGroups() 总是会被调用两次，而我预计它只会被调用一次，因为 @Cacheable。

项目结构： project structure

Answer 1

我认为您的 @Cacheable 注释不起作用，因为您没有为类指定接口。这是因为 Spring 为缓存创建了代理。 Spring 在其文档中指定了以下内容。我觉得你没有指定代理目标类，这意味着它将默认为 false。如果为 false，它将使用基于 JDK 接口的代理。但在你的情况下，你的类，即 RollMappingService 没有实现接口。使用方法 getAllRoles 创建接口 RollMappingService 并实现它，将解决您的问题。

控制为带有@Cacheable 或@CacheEvict 注释的类创建什么类型的缓存代理。如果 proxy-target-class 属性设置为 true，则创建基于类的代理。如果 proxy-target-class 为 false 或省略该属性，则创建基于标准 JDK 接口的代理。 （有关不同代理类型的详细检查，请参阅第 9.6 节“代理机制”。）

同时修改你的测试类，通过以下方式为 RoleMappingService 创建 Spring bean，并将 AdminClient 的模拟注入其中

 @Mock
private AdminClient mockedAdminClient;

@InjectMocks
@Autowired
private RoleMappingService roleMappingService

@Before
public void setUp() throws Exception {
    MockitoAnnotations.initMocks(this);
    ReflectionTestUtils.setField(roleMappingService, 
    "adminClient",
            mockedAdminClient);
}