Apache Cassandra JDBC连接错误

Question

我想通过jdbc连接到远程服务器上的cassandra 1.2.4。

package cassandraclient; 
import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.PreparedStatement; 
import java.sql.SQLException; 
import java.sql.Statement; 
import java.util.logging.Level; 
import java.util.logging.Logger; 

public class CassClient { 
public static void main(String[] args) { 
    try { 

     Class.forName("org.apache.cassandra.cql.jdbc.CassandraDriver"); 

     Connection con = DriverManager.getConnection("jdbc:cassandra://<domain>:7199"); 

     String query = "CREATE KEYSPACE CassandraClientTest WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };"; 
     Statement statement = con.createStatement(); 

     boolean success = statement.execute(query); 
     System.out.println("created keyspace " + success); 
     statement.close(); 

     con.close(); 

    } 
    catch (ClassNotFoundException ex) { 
     ex.printStackTrace(); 
    } 
    catch (SQLException ex) { 
     ex.printStackTrace(); 
    } 
} 
} 

当我尝试建立连接时，出现以下异常。

java.sql.SQLNonTransientConnectionException: org.apache.thrift.transport.TTransportException 
     at org.apache.cassandra.cql.jdbc.CassandraConnection.<init>(CassandraConnection.java:156) 
     at org.apache.cassandra.cql.jdbc.CassandraDriver.connect(CassandraDriver.java:92) 
     at java.sql.DriverManager.getConnection(DriverManager.java:582) 
     at java.sql.DriverManager.getConnection(DriverManager.java:207) 
     at cassandraclient.CassClient.main(CassClient.java:17) 
    Caused by: org.apache.thrift.transport.TTransportException 
     at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132) 
     at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84) 
     at org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129) 
     at org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101) 
     at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84) 
     at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378) 
     at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297) 
     at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204) 
     at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69) 
     at org.apache.cassandra.thrift.Cassandra$Client.recv_describe_cluster_name(Cassandra.java:1101) 
     at org.apache.cassandra.thrift.Cassandra$Client.describe_cluster_name(Cassandra.java:1089) 
     at org.apache.cassandra.cql.jdbc.CassandraConnection.<init>(CassandraConnection.java:125) 
     ... 4 more 

还有一些我注意到的东西。 cassandra的标准端口是9160，我没有指定另一个端口。但是当我尝试再次启动cassandra时，它给了我以下例外。

Error: Exception thrown by the agent : java.rmi.server.ExportException: Port already in use: 7199; nested exception is: 
      java.net.BindException: Address already in use 

这就是为什么我在url中我得到这个异常所使用的端口7199. 当我使用端口9160（和其他港口像9161..2）。

java.sql.SQLNonTransientConnectionException: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect 
     at org.apache.cassandra.cql.jdbc.CassandraConnection.<init>(CassandraConnection.java:156) 
     at org.apache.cassandra.cql.jdbc.CassandraDriver.connect(CassandraDriver.java:92) 
     at java.sql.DriverManager.getConnection(DriverManager.java:582) 
     at java.sql.DriverManager.getConnection(DriverManager.java:207) 
     at cassandraclient.CassClient.main(CassClient.java:28) 
    Caused by: org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect 
     at org.apache.thrift.transport.TSocket.open(TSocket.java:183) 
     at org.apache.cassandra.cql.jdbc.CassandraConnection.<init>(CassandraConnection.java:123) 
     ... 4 more 
    Caused by: java.net.ConnectException: Connection refused: connect 
     at java.net.PlainSocketImpl.socketConnect(Native Method) 
     at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:351) 
     at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:213) 
     at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:200) 
     at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366) 
     at java.net.Socket.connect(Socket.java:529) 
     at org.apache.thrift.transport.TSocket.open(TSocket.java:178) 
     ... 5 more 

我将不胜感激您的帮助。

Answer 1

这里发生了一些事情。

最简单的问题来解决：

java.rmi.server.ExportException：端口已在使用中：7199; java.net.BindException：地址已在使用

尽管C *使用端口9160的节俭，它也使用端口7199的JMX。这个例外基本上意味着别的什么东西阻止了C *使用那个端口，我的钱在另一个cassandra服务器上。

使用activity monitor/tast管理器确保您已经停止了所有cassandra实例，然后尝试重新启动服务器，并且如果在osx/linux上使用-f标志在forground中启动服务器，则可以更容易停止！

Windows> cassandra.bat 
OSX/Linux$ ./cassandra -f 

下一个问题（我不知道如果这是一个问题，或者你只是决定混淆连接字符串）

Connection con = DriverManager.getConnection("jdbc:cassandra://<domain>:7199"); 

这是不正确的，你需要指定一个IP地址在<domain>部分。 E.g：

Connection con = DriverManager.getConnection("jdbc:cassandra://127.0.0.1:9160"); 
Connection con = DriverManager.getConnection("jdbc:cassandra://mycassndrahost:9160"); 

你也不能使用端口7199，它需要通过JMX并具有除非你改变的配置在cassandra-env.sh文件是免费的。

让我知道你如何继续。