Spring Data Hazelcast Repository не работает

Я пытаюсь подключить приложение Springboot(v1.4.2) к кластеру Hazelcast, чтобы найти сохраненные данные. Для этого я использую экземпляр hazelcast-client и создал HazelcastRepository для поиска моих данных.

Проблема в том, что мой репозиторий не находит никаких данных. Он всегда возвращает пустой список, когда я тестирую с помощью findAll() или null, когда я тестирую с помощью findOne():

Ниже приведены мои Сервисы / Хранилище / Домен / Коды конфигурации:

@Service
public class MyService {

    private static final Logger log = LoggerFactory.getLogger(MyService .class);

    private final MyHCRepository repository;

    @Autowired
    public MyService (final MyHCRepository repository) {
        this.repository = repository;
    }

    public String get(final String name) {
        List<Element> elements= repository.findByName(name);
        return elements.toString();
    }
}

Вот мой репо и домен:

@Repository
public interface MyHCRepository extends HazelcastRepository<Element, Integer> {
    List<Element> findByName(String name);
}

@Data
@KeySpace
public class Element implements Serializable {

    private Integer id;
    private String name;
}

Вот мой конфиг hazelcast-клиента:

@Configuration
@EnableHazelcastRepositories
public class HazelcastConfiguration {

    @Bean
    @Qualifier("client")
    public HazelcastInstance hazelcastClientInstance() {
        final ClientConfig clientConfig = new ClientConfig();
        final ClientNetworkConfig networkConfig = new ClientNetworkConfig();
        networkConfig.setAddresses(singletonList("127.0.0.1"));
        clientConfig.setNetworkConfig(networkConfig);
        return HazelcastClient.newHazelcastClient(clientConfig);
    }

    @Bean
    public KeyValueTemplate keyValueTemplate() {
        return new KeyValueTemplate(new HazelcastKeyValueAdapter(hazelcastClientInstance()));
    }
}

И в моем pom я использую эти зависимости:

<dependencies>
        <dependency>
            <groupId>com.hazelcast</groupId>
            <artifactId>hazelcast-client</artifactId>
            <version>3.6.6</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-logging</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>com.hazelcast</groupId>
            <artifactId>spring-data-hazelcast</artifactId>
            <version>1.0</version>
            <exclusions>
                <exclusion>
                    <artifactId>spring-data-keyvalue</artifactId>
                    <groupId>org.springframework.data</groupId>
                </exclusion>
                <exclusion>
                    <groupId>com.hazelcast</groupId>
                    <artifactId>hazelcast</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <artifactId>spring-data-keyvalue</artifactId>
            <groupId>org.springframework.data</groupId>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
    </dependencies>

Я не получил ни ошибок, ни исключений. Как будто не было данных в моем кластере Hazelcast, но я знаю, что есть. С моим клиентом, если я подключаюсь и загружаю Карту из Hazelcast-Cluster следующим образом:

client.getMap("mapsName");

затем я получил свои данные, но если я попытаюсь использовать репозиторий Hazelcast, я ничего не найду. Может кто-нибудь сказать мне, что не так?

1 ответ

Решение

Все хорошо, я нашел проблему. Мне просто нужно было связать имя моей карты с аннотацией @Keyspace внутри моего класса Domain (Element) -> @Keyspace("myMapName")

Другие вопросы по тегам