Elipseを使用し、javaから Cassandra に接続ができない。

Question

前提・実現したいこと

Eclipseを使用した開発環境で、Javaからcassandraにアクセスし、何か（キースペース等、とりあえずcassandraにアクセスして何か）を表示しようと試みています。

以下のサイト等参考にしながら行っています。
http://d.hatena.ne.jp/akishin999/20100430/1272642657

該当のソースコード

import java.io.UnsupportedEncodingException;
import java.util.Date;
import java.util.Map;

import org.apache.cassandra.thrift.Cassandra;
import org.apache.cassandra.thrift.Column;
import org.apache.cassandra.thrift.ColumnPath;
import org.apache.cassandra.thrift.ConsistencyLevel;
import org.apache.cassandra.thrift.InvalidRequestException;
import org.apache.cassandra.thrift.NotFoundException;
import org.apache.cassandra.thrift.TimedOutException;
import org.apache.cassandra.thrift.UnavailableException;
import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;

import com.datastax.driver.core.KeyspaceMetadata;

/**
 * シンプルなインサート。
 * 
 */
public class SimpleInsert1 {

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

			// Thrift を使用して Cassandra に接続
			TTransport port = new TSocket("localhost", 9160);
			TProtocol protocol = new TBinaryProtocol(port);
			Cassandra.Client client = new Cassandra.Client(protocol);
			port.open();

			// クラスタ名の表示
			System.out.printf("Cluster name : [%s]\n", client.describe_cluster_name());

			// バージョンの表示
			System.out.printf("Version : [%s]\n", client.describe_version());

//            // 接続中クラスタの全キースペースを取得
//			for (String keyspace : client.describe_keyspaces()) {
//				// キースペース名の表示
//				System.out.printf("Keyspace : [%s]\n", keyspace);
//				// キースペース内の全 Column Family の取得
//				for (Map.Entry<String, Map<String, String>> entry : client.describe_keyspace(keyspace).entrySet()) {
//					System.out.printf("\tColumn Family : [%s]\n", entry.getKey());
//					for (Map.Entry<String, String> innerEntry : entry.getValue().entrySet()) {
//						System.out.printf("\t\t[%s]:[%s]\n", innerEntry.getKey(), innerEntry.getValue());
//					}
//				}
//			}

			port.close();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

補足情報（使用バージョンなど）

Eclipse:Version: 2018-09 (4.9.0)
cassandra:apache-cassandra-3.11.3 6

発生している問題・エラーメッセージ

上記バージョンでおこなていますが、デバッグするとport.open();のところでエラーが検出されます。
一体どういう理由が考えられるのでしょうか？

org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused (Connection refused)
	at org.apache.thrift.transport.TSocket.open(TSocket.java:187)
	at SimpleInsert1.main(SimpleInsert1.java:34)
Caused by: java.net.ConnectException: Connection refused (Connection refused)
	at java.net.PlainSocketImpl.socketConnect(Native Method)
	at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
	at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
	at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
	at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
	at java.net.Socket.connect(Socket.java:589)
	at org.apache.thrift.transport.TSocket.open(TSocket.java:182)
	... 1 more

以下のメッセージにもはまっており、デバッグができかねる状況です。

「注: この要素の Javadoc は、添付されたソースまたは添付された Javadoc で見つかりませんでした。」

試したこと

以下を設定しましたが表示されません。

調べていますが解決していません。可能であればこちらもご教授頂ければ助かります。

状況

これくらいは自力で調査していけと言われそうですが、このテーマを行ってから結構時間がたっています。
java、eclipseにもそんなに詳しいわけではなく、調べるところが多いです。
効率のいい道筋があればいいですが試行錯誤でできることから少しずつでも前に進めています。
もう少しスピードをあげたいです。
解決の方向としておそらく今回のバージョンに合わせ、接続箇所を変更する必要があると思いますので、そこを中心に調査中です。
しかしながらその調査にあたりわからないことが色々あり、例えば上記のjavadocに関してで、これを設定しないとデバッグの調査が進みません。
１つ１つの調査に時間がかかりすぎています。
調査はもちろん進めますが、何かわかることがあればお力いただきたいです。

どうかよろしくお願いします。

Answer 1

【1】
エラーメッセージに**Connection refused (Connection refused)**とありますので、接続できなかったよエラーですね。
現時点で出されている情報から推測すると、下記が考えられます。

• ローカルにCassandraが構築されていない。
• Cassandraのポートが空いていない。
• Cassandraにログインするための情報を別の場所で持ってるんでしょうけど、そのパスワード等が間違っている。

【2】
自分が業務で、WebアプリケーションでCassandraを使用した時は、下記URLに乗ってる感じで接続させましたが、絶対Thrift使わないといけないんでしょうか？（datastaxのJavaのドライバーとか

http://blog.katty.in/6408

【3】
注: この要素の Javadoc は、添付されたソースまたは添付された Javadoc で見つかりませんでした。
については、単純にJavadocが書かれていないか、関連付いてないかと思うので下記を試すのはいかがでしょうか。
http://www.atmarkit.co.jp/ait/articles/0408/03/news106.html

Comments

[kenji267]

回答ありがとうございます。
(1)ローカルでは使用できているので、2,3番目だと考えていますが、なぜかここのことを記載している情報が少なく、止まっています。
(2)Thriftを使用しているのはeclipseで使用する時の情報で、Thriftを使用している情報が多いからです。特に深い理由はありません。あとこの情報でもそうですが、リンク切れがあったり、Mavenとか知りませんので、その調査に時間がかかったりします。
(3)上記試したのですがうまいこといきませんでした。

(1)ですが、cqlは実行できていますが、どこでポートが開いていないのか等の調査が知識不足です。
(2)ですが環境構築の練習としてまた試してみます。
(3)ですが、追加で画像アップしたのですがapi先が明らかに間違っていました。

一旦このテーマは区切りをつけ、(2)等を試しながら、今一度取り組みたいと思います。
ありがとうございます。

[yukapome789]

【3】ですが、記載したURLの内容と同じことをやってもだめですよ。記事に「本稿では、J2SDK 1.4のrt.jar（Javaの標準ライブラリ）とJavadocの関連付けを例に、EclipseでライブラリとJavadocを関連付ける方法を紹介します。」と書かれてます。質問者さんの環境で、どの部分のJavadocが読み込めないエラーが出てるのかわからないですが、Thriftのライブラリのどこかなら、ThriftのJavadocのパスを指定してあげないとだめです。

[yukapome789]

あと、Javaのバージョン関係あるかもなので確認してみると良いです。https://stackoverflow.com/questions/29446187/cassandra-refusing-connection

[yukapome789]

連投すみません。この記事も確認してみて下さい。pc_ipaddressの設定について書かれてます。http://app.road.jp.net/?p=1801

[kenji267]

回答ありがとうございます。
本件に取り組むにあたり他に行うことがあるだろうと考えまずはvagrant環境でcqlの処理など基本的な所から取り組んでいます。近い日に何とか上記回答を活かせるようにしたいと思います。
本件は一旦クローズし、近いうちに仕切り直したいと思います。