微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

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

如何解决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 举报,一经查实,本站将立刻删除。