问题描述
在我的 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 (将#修改为@)