带有Spring Boot数据的Hazelcast MapStore JPA循环依赖

Question

我正在使用Spring Boot数据jpa和hazelcast开发Spring Boot 2.4.1项目。我正试图建立一个分布式地图，并读取数据库。我已经实现了com。黑兹卡斯特。地图MapLoader，但当我尝试运行应用程序时，由于循环依赖关系，它无法启动。似乎JpaRepository需要HazelcastInstance首先可用，但HazelcastInstance需要MapLoader，MapLoader反过来需要JpaRepository准备就绪。至少从日志和这篇文章来看是这样的。

有人知道如何解决这个问题吗？

波姆。xml

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.4.1</version>
    <relativePath/> <!-- lookup parent from repository -->
</parent>

...

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

<dependency>
    <groupId>com.hazelcast</groupId>
    <artifactId>hazelcast-all</artifactId>
    <version>4.1.1</version>
</dependency>

配置：

@Configuration
public class HZConfig {
    
    @Bean
    Config config(RVOLoader rvoLoader) {}
        Config config = new Config();
        config.getMapConfig("rvoMap").getMapStoreConfig().setImplementation(rvoLoader);
        config.getMapConfig("rvoMap").getMapStoreConfig()
            .setInitialLoadMode(MapStoreConfig.InitialLoadMode.EAGER);

        return config;
    }

    @Bean
    HazelcastInstance hazelcastInstance(Config config) {
        HazelcastInstance hz = Hazelcast.newHazelcastInstance(config);
        return hz;
    }
}

地图加载器：

@Component
public class MyResourceMapLoader implements MapLoader<Long, MyResource> {
    
    private final MyResourceRepository repo;

    public MyResourceMapLoader(MyResourceRepository repo) {
        this.repo = repo;
    }

    @Override
    public MyResource load(Long key) {
        return this.repo.findById(key).orElse(null);
    }

    @Override
    public Map<Long, MyResource> loadAll(Collection<Long> keys) {
        Map<Long, MyResource> myResourceMap = new HashMap<>();
        for (Long key : keys) {
            MyResource myResource = this.load(key);
            if (myResource != null) {
                myResourceMap.put(key, myResource);
            }
        }
        return myResourceMap;
    }

    @Override
    public Iterable<Long> loadAllKeys() {
        return this.repo.findAllIds();
    }
}   

JpaRepository：

java prettyprint-override">@Repository
public interface MyResourceRepository extends JpaRepository<MyResource, Long> {

    List<MyResource> findAll();

    @Query("SELECT m.id from MyResource m")
    Iterable<Long> findAllIds();

}

Answer 1

一个解决方案，

@Bean
public Config config(YourMapStoreFactory yourMapStoreFactory) {
    ...
    config.getMapConfig("rvoMap").getMapStoreConfig().setFactoryImplementation(yourMapStoreFactory);

使地图存储工厂成为组件，而不是地图存储

@Component
public class YourMapStoreFactory implements MapStoreFactory {

    @Autowired
    private MyResourceRepository repo;

    public MapLoader newMapStore(String mapName, Properties properties) {
        if (mapName.equals("rvoMap") {
            return new MyResourceMapLoader(repo);