1. Zuhause
  2. Frage und Antwort
  3. Couchbase Java API bekomme ConnectException

Couchbase Java API bekomme ConnectException

2016-04-13 4 views
2

Ich erstelle ein dummy JSON und versuche, es abzufragen. Ich mache das mit JAVA. Der Code ist wie folgt: -Couchbase Java API bekomme ConnectException

import static com.couchbase.client.java.query.Select.select; 
import static com.couchbase.client.java.query.dsl.Expression.s; 
import static com.couchbase.client.java.query.dsl.Expression.x; 

import com.couchbase.client.java.Bucket; 
import com.couchbase.client.java.Cluster; 
import com.couchbase.client.java.CouchbaseCluster; 
import com.couchbase.client.java.document.JsonDocument; 
import com.couchbase.client.java.document.json.JsonObject; 
import com.couchbase.client.java.env.CouchbaseEnvironment; 
import com.couchbase.client.java.env.DefaultCouchbaseEnvironment; 
import com.couchbase.client.java.query.Query; 
import com.couchbase.client.java.query.Statement; 

public class AccessData { 
    public static void main(String[] args) { 
     CouchbaseEnvironment env = DefaultCouchbaseEnvironment.builder() 
       .queryEnabled(true) 
       .build(); 
     Cluster cluster = CouchbaseCluster.create(env, "127.0.0.1"); 
     Bucket bucket = cluster.openBucket("default", ""); 
     JsonObject testDataBlog = JsonObject.create().put("type", "blog").put("data", "blablabla"); 
     JsonObject testDataComment = JsonObject.create().put("type", "comment").put("data", "ho hey"); 
     bucket.upsert(JsonDocument.create("testDp4Blog", testDataBlog)); 
     bucket.upsert(JsonDocument.create("testDp4Comment", testDataComment)); 
     Statement statement = select("*").from("default").where(x("type").eq(s("blog"))); 
     Query createIndex = Query.simple("CREATE PRIMARY INDEX ON default"); 
     bucket.query(createIndex); 
     Statement withPlaceholders = select("*").from("default").where(x("type").eq(x("$1"))); 
} 
}

Auf den obigen Code ausgeführt wird, ich die folgende Fehlermeldung erhalten: -

Apr 13, 2016 10:02:33 PM com.couchbase.client.core.CouchbaseCore <init> 
INFO: CoreEnvironment: {sslEnabled=false, sslKeystoreFile='null', sslKeystorePassword='null', queryEnabled=true, queryPort=8093, bootstrapHttpEnabled=true, bootstrapCarrierEnabled=true, bootstrapHttpDirectPort=8091, bootstrapHttpSslPort=18091, bootstrapCarrierDirectPort=11210, bootstrapCarrierSslPort=11207, ioPoolSize=4, computationPoolSize=4, responseBufferSize=16384, requestBufferSize=16384, kvServiceEndpoints=1, viewServiceEndpoints=1, queryServiceEndpoints=1, ioPool=NioEventLoopGroup, coreScheduler=CoreScheduler, packageNameAndVersion=couchbase-java-client/2.1.0-dp2 (git: 2.1.0-dp2), dcpEnabled=false, retryStrategy=BestEffort, maxRequestLifetime=75000, [email protected]50b, [email protected]d6f64b1, obser[email protected]32a1bec0} 
Apr 13, 2016 10:02:36 PM com.couchbase.client.core.endpoint.AbstractEndpoint$2 operationComplete 
WARNING: [null][KeyValueEndpoint]: Could not connect to endpoint, retrying with delay 32 MILLISECONDS: 
java.net.ConnectException: Connection refused: no further information: /127.0.0.1:11210 
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) 
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:712) 
    at com.couchbase.client.deps.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:208) 
    at com.couchbase.client.deps.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:281) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:528) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) 
    at com.couchbase.client.deps.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) 
    at com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) 
    at java.lang.Thread.run(Thread.java:745) 

Apr 13, 2016 10:02:37 PM com.couchbase.client.core.endpoint.AbstractEndpoint$2 operationComplete 
WARNING: [null][KeyValueEndpoint]: Could not connect to endpoint, retrying with delay 32 MILLISECONDS: 
java.net.ConnectException: Connection refused: no further information: /127.0.0.1:11210 
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) 
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:712) 
    at com.couchbase.client.deps.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:208) 
    at com.couchbase.client.deps.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:281) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:528) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) 
    at com.couchbase.client.deps.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) 
    at com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) 
    at java.lang.Thread.run(Thread.java:745) 

Apr 13, 2016 10:02:38 PM com.couchbase.client.core.endpoint.AbstractEndpoint$2 operationComplete 
WARNING: [null][KeyValueEndpoint]: Could not connect to endpoint, retrying with delay 32 MILLISECONDS: 
java.net.ConnectException: Connection refused: no further information: /127.0.0.1:11210 
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) 
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:712) 
    at com.couchbase.client.deps.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:208) 
    at com.couchbase.client.deps.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:281) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:528) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) 
    at com.couchbase.client.deps.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) 
    at com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) 
    at java.lang.Thread.run(Thread.java:745) 

Apr 13, 2016 10:02:39 PM com.couchbase.client.core.endpoint.AbstractEndpoint$2 operationComplete 
WARNING: [null][KeyValueEndpoint]: Could not connect to endpoint, retrying with delay 32 MILLISECONDS: 
java.net.ConnectException: Connection refused: no further information: /127.0.0.1:11210 
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) 
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:712) 
    at com.couchbase.client.deps.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:208) 
    at com.couchbase.client.deps.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:281) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:528) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382) 
    at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354) 
    at com.couchbase.client.deps.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:116) 
    at com.couchbase.client.deps.io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:137) 
    at java.lang.Thread.run(Thread.java:745) 

Exception in thread "main" java.lang.RuntimeException: java.util.concurrent.TimeoutException 
    at com.couchbase.client.java.util.Blocking.blockForSingle(Blocking.java:93) 
    at com.couchbase.client.java.CouchbaseCluster.openBucket(CouchbaseCluster.java:108) 
    at com.couchbase.client.java.CouchbaseCluster.openBucket(CouchbaseCluster.java:99) 
    at com.couchbase.client.java.CouchbaseCluster.openBucket(CouchbaseCluster.java:89) 
    at AccessData.main(AccessData.java:21) 
Caused by: java.util.concurrent.TimeoutException 
    ... 5 more

Irgendwelche Hinweise, es zu beheben?

Quelle

2016-04-13 Anonymous

Antwort

0

Es sieht so aus, als ob Sie ziemlich veraltete Versionen des Servers und des SDK sowie Entwicklervorschauversionen verwenden!

Ich rate Ihnen dringend, eine saubere Neuinstallation von Couchbase Server 4.1.0 durchzuführen und das Java SDK in der neuesten Version, 2.2.7, zu verwenden. Ein paar Dinge haben sich geändert:

  • Sie nicht die queryEnabled(true) brauchen, wenn die Umwelt
  • Konfiguration Query hat N1qlQuery

Der Fehler zeigt an erhalten umbenannt worden, dass, wenn der Client versucht, eine Verbindung Auf localhost antwortet nichts (zumindest auf Port 11210). Können Sie überprüfen, ob der Knoten korrekt in der web console ist?

Noch einmal lieber Couchbase mit 4.1.0 installieren. Wenn Sie keine bestimmten Daten in Ihrer aktuellen Instanz behalten möchten, führen Sie eine vollständige Neuinstallation durch (indem Sie zuerst die aktuelle Installation entfernen. Siehe here).

Quelle

2016-05-11 18:42:29

Verwandte Themen

 Verwandte Themen