Spring Boot 2 Cassandra несколько пространств ключей или кластеров

Я работаю над версией Spring Boot 2.0.3.RELEASE и spring-data-cassandra-2.0.8. Мне нужно подключиться к 2 различным кластерам Cassandra. CassandraAutoConfiguration Spring Boot, похоже, поддерживает только 1 кластер Cassandra.

Как заставить его работать с автоматически созданной реализацией @Repository от spring-data-cassandra?

Вы можете сделать вот так lankydanblog.com/2017/10/22/… исходный код github.com/lankydan/spring-data-cassandra/tree/…

— 01.09.2018 01:43

spring-boot spring-data-cassandra

01.09.2018 00:29

Пользовательский скаляр GraphQL

Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...

Поднятие тревоги для долго выполняющихся методов в Spring Boot

Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...

Принятие принципов SOLID в Spring Boot: Создание обслуживаемых и масштабируемых приложений

Запросы к JPA

Версия Java на основе версии загрузки

Если вы зайдете на официальный сайт Spring Boot , там представлен start.spring.io , который упрощает создание проектов Spring Boot, как показано ниже.

Документирование API с помощью Swagger на Springboot

В предыдущей статье мы уже узнали, как создать Rest API с помощью Springboot и MySql .

2 132

Ответы 1

У вас может быть несколько конфигураций кластера Cassandra.

/**
 * Configuration class for keyspace: big_data (Cluster 1)
 *
 */
@Configuration
@EnableCassandraRepositories(basePackages = "com.bigdata.cassandra.repository.data",
    cassandraTemplateRef = "keyspaceBigDataServiceTemplate")
public class CassandraBigDataServiceConfiguration {

  @Autowired
  private Properties cassandraProperties;

  @Bean
  public CassandraClusterFactoryBean cluster() {

    CassandraClusterFactoryBean cluster = new CassandraClusterFactoryBean();
    cluster.setContactPoints(cassandraProperties.getCassandraBigDataContactPoint());
    cluster.setPort(cassandraProperties.getCassandraBigDataPort());
    cluster.setSslEnabled(cassandraProperties.isCassandraBigDataSslEnabled());
    return cluster;
  }

  @Bean
  public CassandraMappingContext mappingContext() {
    return new CassandraMappingContext();
  }

  @Bean
  public CassandraConverter converter() {
    return new MappingCassandraConverter(mappingContext());
  }

  @Bean("keyspaceBigDataServiceSession")
  public CassandraSessionFactoryBean session() {

    CassandraSessionFactoryBean session = new CassandraSessionFactoryBean();
    session.setCluster(cluster().getObject());
    session.setKeyspaceName(cassandraProperties.getCassandraBigDataKeyspaceReporting());
    session.setConverter(converter());
    session.setSchemaAction(SchemaAction.NONE);

    return session;
  }

  @Bean("keyspaceBigDataServiceTemplate")
  public CassandraOperations cassandraTemplate() {
    return new CassandraTemplate(session().getObject());
  }

}

Другой кластер с другим пространством ключей: отчетность

/**
 * Configuration class for keyspace: reporting (Cluster 2)
 *
 */
@Configuration
@EnableCassandraRepositories(basePackages = "com.bigdata.cassandra.repository.reports",
    cassandraTemplateRef = "keyspaceReportingServiceTemplate")
public class CassandraReportingServiceConfiguration {

  @Autowired
  private Properties cassandraProperties;

  @Bean
  public CassandraClusterFactoryBean cluster() {

    CassandraClusterFactoryBean cluster = new CassandraClusterFactoryBean();
    cluster.setContactPoints(cassandraProperties.getCassandraReportingContactPoint());
    cluster.setPort(cassandraProperties.getCassandraReportingPort());
    cluster.setSslEnabled(cassandraProperties.isCassandraReportingSslEnabled());
    return cluster;
  }

  @Bean
  public CassandraMappingContext mappingContext() {
    return new CassandraMappingContext();
  }

  @Bean
  public CassandraConverter converter() {
    return new MappingCassandraConverter(mappingContext());
  }

  @Bean("keyspaceReportingServiceSession")
  public CassandraSessionFactoryBean session() {

    CassandraSessionFactoryBean session = new CassandraSessionFactoryBean();
    session.setCluster(cluster().getObject());
    session.setKeyspaceName(cassandraProperties.getCassandraReportingKeyspaceReporting());
    session.setConverter(converter());
    session.setSchemaAction(SchemaAction.NONE);

    return session;
  }

  @Bean("keyspaceReportingServiceTemplate")
  public CassandraOperations cassandraTemplate() {
    return new CassandraTemplate(session().getObject());
  }

}

Вам нужно будет указать свойства для каждого кластера, к которому вы хотите подключиться:

# big_data keyspaces are in Cluster 1
cassandra-cluster1.contact-points=1.set.cluster1.ip
cassandra-cluster1.port=9042
cassandra-cluster1.keyspace-reporting.name=big_data
cassandra-cluster1.ssl.enabled=true

# reporting keyspace are in Cluster 2
cassandra-cluster2.contact-points=2.set.cluster2.ip
cassandra-cluster2.port=9042
cassandra-cluster2.keyspace-2.name=keyspace_2 // can have multiple keyspaces of course 
cassandra-cluster2.keyspace-reporting.name=reporting
cassandra-cluster2.ssl.enabled=true

Слой @Repository также необходимо изменить, чтобы отразить несколько ключевых пространств, хотя

— 15.11.2020 02:29

01.09.2018 09:35