AWS VPC中的Couchbase连接错误(TIMING OUT)

Question

我遇到了连接问题,这在亚马逊环境(AWS)中的私有虚拟vpc中是一个奇怪的问题.我的上下文是这样的,我在这个子网中有子网我有2台机器客户端机器,我使用Couchbase java SDK和Couchbase服务器的机器.两者都是大型实例.当前的java版本1.6.我在安全组上打开了Couchbase的所有必需端口(8091,8092,11210).我正在使用curl命令测试连接,以测试与存储桶的连接,这里没有问题.奇怪的行为是当我尝试使用java客户端访问视图时,因为我收到超时错误,尽管java客户端已成功通过身份验证.

这是我的日志的样子:

(CacheManager.java:102) -B06C9F5CFF85- Cache client checked out [stdout]
INFO com.couchbase.client.CouchbaseConnection: Added {QA sa=/10.0.X.XXX:11210, #Rops=0, #Wops=0, #iq=0, topRop=null, topWop=null, toWrite=0, interested=0} to connect queue
INFO com.couchbase.client.CouchbaseConnection: Connection state changed for sun.nio.ch.SelectionKeyImpl@57a220c2
INFO net.spy.memcached.auth.AuthThread: Authenticated to 10.0.X.XXX/10.0.X.XXX:11210
Added 10.0.X.XXX to connect queue
INFO com.couchbase.client.CouchbaseClient: viewmode property isn't defined. Setting viewmode to production mode
INFO com.couchbase.client.http.AsyncConnectionManager: Opening new Couchbase HTTP connection
INFO com.couchbase.client.http.AsyncConnectionManager$ConnRequestCallback: /10.0.X.XXX:8092 - Session request successful
ERROR com.couchbase.client.ViewNode$EventLogger: Connection timed out: [10.0.X.XXX/10.0.X.XXX:8092]
and then after a while
INFO com.couchbase.client.ViewConnection: Node 10.0.X.XXX has no ops in the queue
INFO com.couchbase.client.ViewNode: I/O reactor terminated for 10.0.X.XXX
SHUTTING DOWN (informed client)) INFO com.couchbase.client.CouchbaseConnection: Shut down Couchbase client

因此突然连接超时而没有任何理由,然后客户端正在关闭自己.

其他上下文数据:Couchbase服务器企业2.0 Java 1.6 Ubuntu 11.10服务器x64

在我的本地计算机上,我有一个Couchbase在本地局域网中的本地虚拟机中运行,我没有使用它的问题.

任何人都可以帮助调试这个.我们想把Couchbase投入生产,但如果没有这个,我们就无法前进.

提前感谢您提供任何帮助或信息.

Answer 1

每个 couchbase 客户文档 -

Couchbase 集群中任何给定节点的默认超时为 2.5 秒。如果 Couchbase SDK 此时未收到服务器的响应，它将断开与 Couchbase Server 的连接并尝试连接到另一个节点。

如果您的连接不好或不可靠，您可能需要更改“OpTimeout”值。

CouchbaseConnectionFactoryBuilder b = new CouchbaseConnectionFactoryBuilder();
            b.setOpTimeout(5000);
            client = new CouchbaseClient(b.buildCouchbaseConnection(nodes, "bucket-name", "pass"));