Erreur lors de la connexion à Cassandra à l'aide de Java Pilote pour Apache Cassandra 1.0 de com.exemple.cassandra

Lors de la connexion à Cassandra client à l'aide de java pilote pour Cannsandra par DataStax, il est en train de lancer d'erreur suivant..

Exception in thread "main" com.datastax.le pilote.de base.des exceptions.NoHostAvailableException: Tous hôte(s) essayé pour la requête a échoué (essayé: [/127.0.0.1])

S'il vous plaît suggérer...

Merci!

Mon code java est comme ceci:

package com.example.cassandra;

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Host;
import com.datastax.driver.core.Metadata;

public class SimpleClient {

private Cluster cluster;

public void connect(String node){

    cluster = Cluster.builder().addContactPoint(node).build();
    Metadata metadata = cluster.getMetadata();
    System.out.println(metadata.getClusterName());
}   


public void close()
{
cluster.shutdown();
}

public static void main(String args[]) {

SimpleClient client = new SimpleClient();
client.connect("127.0.0.1");
client.close();
}
  • Juste pour ajouter plus de clarté: je suis sûr que je suis connecté à cassandra. Il est encore en montrant cette erreur
InformationsquelleAutor Saurabh Deshpande | 2013-05-28
  1. 13

    Dans mon cas, j'ai couru dans cette question que j'ai utilisé de la RPC par défaut de port de 9160 lors de la connexion. On peut trouver un autre port pour CQL de cassandra.yaml -

    start_native_transport: true
# port for the CQL native transport to listen for clients on
native_transport_port: 9042

    Une fois que j'ai changé le code pour utiliser le port 9042 la tentative de connexion a réussi - 

    public BinaryDriverTest(String cassandraHost, int cassandraPort, String keyspaceName) {
    m_cassandraHost = cassandraHost;
    m_cassandraPort = cassandraPort;
    m_keyspaceName = keyspaceName;

    LOG.info("Connecting to {}:{}...", cassandraHost, cassandraPort);
    cluster = Cluster.builder().withPort(m_cassandraPort).addContactPoint(cassandraHost).build();
    session = cluster.connect(m_keyspaceName);
    LOG.info("Connected.");
}

public static void main(String[] args) {
    BinaryDriverTest bdt = new BinaryDriverTest("127.0.0.1", 9042, "Tutorial");
}
    InformationsquelleAutor Bharadwaj
  2. 5

    J'ai eu ce problème et il a été trié par réglage de la ReadTimeout dans SocketOptions:

    Cluster cluster = Cluster.builder().addContactPoint("localhost").build();
cluster.getConfiguration().getSocketOptions().setReadTimeoutMillis(HIGHER_TIMEOUT);
    InformationsquelleAutor Aneesh Vijendran
  3. 4

    Aller à votre Apache Cassandra répertoire conf et activer le protocole binaire

    Cassandra protocole binaire
    Le pilote Java utilise le protocole binaire qui a été introduit dans Cassandra 1.2. Il ne fonctionne qu'avec une version de Cassandra supérieure ou égale à 1,2. En outre, le protocole binaire du serveur n'est pas démarré avec le fichier de configuration par défaut dans Cassandr un 1.2. Vous devez modifier le cassandra.fichier yaml pour chaque nœud:

    start_native_transport: true

    Puis redémarrez le nœud.

    InformationsquelleAutor Orbita
  4. 4

    J'ai été aussi ayant le même problème. J'ai installé Cassandra dans un autre pc sous Linux et a essayé de se connecter via la Fenêtre pc. Je n'étais pas autorisé à créer la connexion.

    Mais quand on modifier cassandra.yaml, de mettre mon pc linux adresse ip à rpc_address et redémarrage, il me permet de me connecter avec succès,

    # The address or interface to bind the Thrift RPC service and native transport
# server to.
#
# Set rpc_address OR rpc_interface, not both. Interfaces must correspond
# to a single address, IP aliasing is not supported.
#
# Leaving rpc_address blank has the same effect as on listen_address
# (i.e. it will be based on the configured hostname of the node).
#
# Note that unlike listen_address, you can specify 0.0.0.0, but you must also
# set broadcast_rpc_address to a value other than 0.0.0.0.
#rpc_address: localhost
rpc_address: 192.168.0.10
    InformationsquelleAutor Prasanna Sujeewa
  5. 3

    Juste poster ce que pour les personnes qui pourraient avoir le même problème que moi, quand j'ai eu ce message d'erreur. S'est avéré que mon complexe de l'arbre des dépendances porté sur une ancienne version de com.google.les collections, ce qui a brisé le CQL pilote. La suppression de cette dépendance et de s'en remettre entièrement à la goyave a résolu mon problème.

    • Merci pour votre astuce, il a résolu mon problème
    InformationsquelleAutor VHristov
  6. 3

    J'ai eu le même problème de test d'un nouveau cluster avec un nœud.

    Après la suppression de ce du Cluster builder, j'ai été en mesure de se connecter: 

    .withLoadBalancingPolicy(new DCAwareRoundRobinPolicy("US_EAST"))

    Il a été en mesure de se connecter.

    InformationsquelleAutor Brandon Kearby
  7. 2

    Dans mon cas, cela a été un port de problème, j'ai oublié de mettre à jour

    Vieux port RPC est 9160

    Nouveau binaire port est 9042

    InformationsquelleAutor oleksii
  8. 2

    J'ai moi aussi rencontré ce problème, et il a été causé par une simple erreur dans la déclaration qui a été soumis.

    session.prepare(null);

    De toute évidence, le message d'erreur est trompeur.

    InformationsquelleAutor ernest_k
  9. 1

    Modifier 

    /etc/cassandra/cassandra.yaml

    et changement

    rpc_address à 0.0.0.0,broadcast_rpc_address et listen_address à l'adresse ip du cluster.

    InformationsquelleAutor Manjunatha H C
  10. 0

    Vérifier les points ci-dessous:

    i) vérifier ip du serveur

    ii) vérifier le port d'écoute

    iii) les données de la pile client de dépendance doit correspondre à la version du serveur.

    Sur le fichier yaml, les dernières versions a au-dessous des propriétés activé:

        start_native_transport: true
    native_transport_port: 9042
    InformationsquelleAutor Sonu
  11. 0

    En supposant que vous avez des configurations par défaut en place, vérifiez la version du pilote de compatibilité. Pas toutes les versions de pilote sont compatibles avec toutes les versions de Cassandra, s'ils prétendent compatibilité descendante. Veuillez voir le lien ci-dessous.

    http://docs.datastax.com/en/developer/java-driver/3.1/manual/native_protocol/

    J'ai rencontré un problème similaire & la modification de la version du pilote résolu mon problème.

    Remarque: j'espère que vous utilisez Maven (ou quelque chose de similaire) pour résoudre les dépendances. Sinon, vous pourriez avoir à télécharger un grand nombre de dépendances pour les versions supérieures de pilote.

    InformationsquelleAutor Mausam