Hazelcast Repository 仍然查询数据库

Question

我正在开发一个 Spring Boot 项目。在那，我有一个名为 ProductMap 的实体，我想将其保存在缓存中。我使用 MapLoader 完成了这项工作，并为地图定义了如下配置。

@Bean
    public Config hazelcastConfig() {
        return new Config().setInstanceName("hazelcast-instance").addMapConfig(
                new MapConfig().setName("ProductMap")
                        .setMapStoreConfig(
                                new MapStoreConfig().setEnabled(true).setInitialLoadMode(MapStoreConfig.InitialLoadMode.EAGER)
                                        .setClassName("com.hazelcast.example.HzTest.config.ProductMapLoader")
                        ));
    }

ProductMap 实体：

@Data
@Entity
@KeySpace("ProductMap")
@Table
public class ProductMap implements Serializable {

    @Id
    @org.springframework.data.annotation.Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer Id;

    private String name;

    private Integer category;

    private Integer productType;
}

ProductMapLoader：

@Log4j2
@Component
public class ProductMapLoader implements MapLoader<Integer, ProductMap>, ApplicationContextAware {

    private static ProductMapRepository productMapRepository;

    @Override
    public synchronized ProductMap load(Integer integer) {
        System.out.println("Load::" + integer);
        return productMapRepository.findById(integer).get();
    }

    @Override
    public synchronized Map<Integer, ProductMap> loadAll(Collection<Integer> collection) {
        Map<Integer, ProductMap> result = new HashMap<>();
        for (Integer key : collection) {
            ProductMap productMap = this.load(key);
            if (productMap != null) {
                result.put(key, productMap);
            }
        }
        return result;
    }

    @Override
    public synchronized Iterable<Integer> loadAllKeys() {
        System.out.println("load all keys" + productMapRepository);
        return productMapRepository.findAllProdMapKeys();
    }

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        productMapRepository = applicationContext.getBean(ProductMapRepository.class);
    }
}

我在启动时加载缓存，

@PostConstruct
public void Init() {
       IMap map = hazelcastInstance.getMap("ProductMap");  // this will load the cache 
}

在里面还创建了一个HazelcastRepository，

public interface ProductMapKvRepo extends KeyValueRepository<ProductMap, Integer> {

    List<ProductMap> findByProductType(Integer productType);
}

在我的一种服务方法中，它调用了productMapKvRepo.findAll() 和productMapKvRepo.findByProductType(1). 但存储库仍然查询数据库。

Hibernate: select productmap0_.id as id1_0_, productmap0_.category as category2_0_, productmap0_.name as name3_0_, productmap0_.product_type as product_4_0_ from product_map productmap0_
Hibernate: select productmap0_.id as id1_0_, productmap0_.category as category2_0_, productmap0_.name as name3_0_, productmap0_.product_type as product_4_0_ from product_map productmap0_ where productmap0_.product_type=?

使用的依赖项：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-cache</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-jpa</artifactId>
    </dependency>
    <dependency>
        <groupId>com.hazelcast</groupId>
        <artifactId>hazelcast</artifactId>
        <version>3.12.7</version>
    </dependency>
    <dependency>
        <groupId>com.hazelcast</groupId>
        <artifactId>hazelcast-client</artifactId>
        <version>3.12.7</version>
    </dependency>
    <dependency>
        <groupId>com.hazelcast</groupId>
        <artifactId>spring-data-hazelcast</artifactId>
        <version>2.2.5</version>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.postgresql</groupId>
        <artifactId>postgresql</artifactId>
        <version>42.2.13</version>
    </dependency>
</dependencies>

谁能告诉我这里出了什么问题，我该怎么办？

Answer 1

您的日志表明您的 Spring Data 存储库是 Hibernate 支持的，这意味着您的项目配置错误。 Spring Data Hazelcast 不使用 Hibernate 从 Hazelcast IMDG 集群中读取数据。

如果打算（最有可能）使用 Hibernate，那么您应该考虑将其原生二级缓存功能与 Hazelcast 一起使用，而不是将 Spring Data 存储库包装在 MapLoader 中。您可以找到示例here。

但是，如果您想通过 MapLoader 应用 read-through 缓存模式，则需要使用 spring-data-hazelcast 工件从 Hazelcast 读取数据直接集群。

Answer 2

当我使用 Spring Boot v2.1.3.RELEASE 和 Spring v5.1.5.RELEASE 时，spring 正在为两个存储库注入 SimpleJpaRepository 类型： MyStandardRepository 和 MyHazelCastRepository，只有 @EnableHazelcastRepositories 存在

将@EnableJpaRepositories 也添加到我的HazelcastConfiguration 类中：

spring 然后将SimpleKeyValueRepository bean 类型注入MyHazelCastRepository：

@Configuration
@EnableHazelcastRepositories(basePackages = {"com.test.repository.hazelcast"})
@EnableJpaRepositories(basePackages = {"com.test.repository.dao"})

public class HazelcastConfiguration {
    
    @Bean
    HazelcastInstance hazelcastInstance() {
         return Hazelcast.newHazelcastInstance();
    }
    @Bean
    public KeyValueOperations keyValueTemplate() {
        return new KeyValueTemplate(new HazelcastKeyValueAdapter(hazelcastInstance()));
    }
    @Bean
     public HazelcastKeyValueAdapter  hazelcastKeyValueAdapter(HazelcastInstance hzInstance) {
        return new HazelcastKeyValueAdapter(hzInstance);
     }
     
}