Spring Boot Cassandra 错误连接到节点endPoint=localhost:1234,hostId=null,hashCode=37hfeouh3,

问题描述

在我的 Spring Boot Cassandra 构建中,我收到以下错误:s0-admin-1] cdodiccontrol.ControlConnection : [s0] 连接到节点时出错(endPoint=localhost:1234,hostId=null,hashCode=37hfeouh3),尝试下一个节点(ConnectionInitException:[s0|control|connecting...] 协议初始化请求,第 1 步(OPTIONS):发送请求失败(io.netty.channel.stacklessClosedChannelException))

实体类

@Data
@Builder
@Table
public class Class1 {
    @Id
    private String id;
    private String data;
    private Class2 data2;
    private Integer data3;
    ...
}
public class2 Class2 {
    @Id
    @JasonProperty
    private String id;
    @Indexed
    @JasonProperty
    private String data;
@JasonProperty
    private String data2;
@JasonProperty
    private Integer data3;
    ...
}
@Configuration
@EnableCassandraRepositories
@ConfigurationProperties(prefix = "DBProperties")
public class ApplicationConfig extends AbstractCassandraConfiguration {

    private String DBKEYSPACE;

    @Override
    protected String getKeyspaceName() {
        return DBKEYSPACE;
    }

    public String[] getEntityBasePackages() {
        return new String[] { "com.oreilly.springdata.cassandra" };
    }
}
@ConfigurationProperties(prefix = "DBPROPERTIES")
@Slf4j
public class factorybeanAppConfig {

    private String contactPoints;
    private String keySpace;
    private Integer port;
    private String password;
    private String username;
    private String dataCenter;

    /*
     * Factory bean that creates the com.datastax.oss.driver.api.core.CqlSession instance
     */

    @Bean
    public CqlSessionfactorybean session() {

        //log it we made it.
        log.info("I made it to CqlSessionfactorybean");
        CqlSessionfactorybean session = new CqlSessionfactorybean();
        session.setContactPoints(URLINFO);
        log.info("Contact Points: " +URLINFO);
        session.setKeyspaceName(DBKEYSPACE);
        //session.setPort(OURPORT);
        session.setUsername(username);
        session.setPassword(password);
        session.setLocalDatacenter(LOCALDCENTER informatION);

        return session;
    }
}

我无法找到一个好的例子,甚至无法让它正常工作。查看此文档:https://docs.spring.io/spring-data/cassandra/docs/current/reference/html/#cassandra.core 这是我实现示例 55 唯一要做的事情

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)