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")