2017-08-10 114 views
0

具有的Apache Cassandra的版本的全新安装3.7datastax卡桑德拉的Java NoHostAvailableException

安装成功,我可以用任何问题访问cqlsh。

[[email protected] bin]$ cqlsh Connected to Test Cluster at 127.0.0.1:9042. [cqlsh 5.0.1 | Cassandra 3.7 | CQL spec 3.4.2 | Native protocol v4]

但是,当我尝试通过DataStax Cassandra客户端连接,我打NoHostAvailableException。

下面是示例代码我试图在控制台

import com.datastax.driver.core.*; 
public class DBHitTEst { 
public static void main(String[] args) throws Exception { 
    // TODO Auto-generated method stub 
    Session session = null; 
    Cluster cluster = Cluster.builder() 
      .addContactPoints("127.0.0.1").withPort(9042) 
      .build(); 
    System.out.println("Connecting to cluster ..."); 
    session = cluster.connect(); 
    System.out.print("Connected !"+session); 
}} 

异常如下所示。

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder". SLF4J: Defaulting to no-operation (NOP) logger implementation SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details. Connecting to cluster ... Aug 10, 2017 7:58:23 AM io.netty.channel.ChannelInitializer channelRegistered WARNING: Failed to initialize a channel. Closing: [id: 0x7d2724c5] java.lang.NoSuchMethodError: io.netty.util.AttributeKey.valueOf(Ljava/lang/String;)Lio/netty/util/AttributeKey; at com.datastax.driver.core.Message.(Message.java:39) at com.datastax.driver.core.Connection$Initializer.initChannel(Connection.java:1425) . . . Exception in thread "main" com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /127.0.0.1:9042 (com.datastax.driver.core.exceptions.TransportException: [/127.0.0.1:9042] Cannot connect)) at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:232) at com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:79) at com.datastax.driver.core.Cluster$Manager.negotiateProtocolVersionAndConnect(Cluster.java:1600) at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1518) at com.datastax.driver.core.Cluster.init(Cluster.java:159) at com.datastax.driver.core.Cluster.connectAsync(Cluster.java:330) at com.datastax.driver.core.Cluster.connectAsync(Cluster.java:305) at com.datastax.driver.core.Cluster.connect(Cluster.java:247) at com.cassandra.db.executables.DBHitTEst.main(DBHitTEst.java:14)

库的引用

cassandra-driver-core-3.3.0.jar 
guava-23.0.jar 
log4j-api-2.8.2.jar 
metrics-core-3.0.2.jar 
netty-all-4.0.9.Final.jar 
slf4j-api-1.7.25.jar 

重要CONFIGS是cassandra.yaml

start_rpc: false 
start_native_transport: true 
native_transport_port: 9042 
rpc_address: localhost 
rpc_port: 9160 
listen_address: localhost 
seeds: "127.0.0.1" 

其他系统细节

[[email protected] conf]$ hostname 
LOGDPM01 

[[email protected] conf]$ more /etc/hosts 
127.0.0.1 localhost localhost.localdomain localhost4 localhost4.localdomain4 
::1   localhost localhost.localdomain localhost6 localhost6.localdomain6 

[[email protected] conf]$ ping LOGDPM01 
PING LOGDPM01 (10.0.2.15) 56(84) bytes of data. 
64 bytes from LOGDPM01 (10.0.2.15): icmp_seq=1 ttl=64 time=0.055 ms 

运行centos VM.Kindly让我知道我在哪里错了?

+0

你在虚拟机上运行C *并试图从该虚拟机之外运行你的代码?运行'netstat -anp | grep 9042'在主机上运行你的代码。 –

+0

不是C *和代码都在同一个VM中 – user3619698

+0

run'netstat -anp | grep 9042'在开始应用之前给出输出 –

回答

0

库不匹配是抛出我在控制台中观察到的警告。

WARNING: Failed to initialize a channel. Closing: [id: 0x7d2724c5] java.lang.NoSuchMethodError: io.netty.util.AttributeKey.valueOf(Ljava/lang/String;)Lio/netty/util/AttributeKey; at com.datastax.driver.core.Message.(Message.java:39) at com.datastax.driver.core.Connection$Initializer.initChannel(Connection.java:1425) . . .

在从Cassandra安装的lib文件夹中选择正确的库时,直接对问题进行排序。