cassandra：如何使用 lb 连接 cassandra 集群？答案

【问题标题】：cassandra: how to connect cassandra cluster using lb?cassandra：如何使用 lb 连接 cassandra 集群？
【发布时间】：2013-06-24 16:55:05
【问题描述】：

我目前正在尝试在我们的生产环境中设置 cassandra 集群（4 个节点和 2 个种子）。当我用逗号分隔的主机名和端口连接时，它工作正常。

cluster = HFactory.getOrCreateCluster("Test Cluster", "host1:9160,host2:9160,host3:9160,host4:9160");

但是当我在连接到单个节点的 lb 上配置集群名称并在 Hector thrift 客户端中配置相同名称时。但我得到了以下的感觉，

cluster = HFactory.getOrCreateCluster("Test Cluster", "lbname");

严重：me.prettyprint.hector.api.exceptions.HectorException：所有主机池都标记为已关闭。重试负担推给客户端。

me.prettyprint.hector.api.exceptions.HectorException: All host pools marked down. Retry burden pushed out to client.
        at me.prettyprint.cassandra.connection.HConnectionManager.getClientFromLBPolicy(HConnectionManager.java:393)
        at me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(HConnectionManager.java:249)
        at me.prettyprint.cassandra.service.AbstractCluster.describeKeyspace(AbstractCluster.java:199)
        at com.july.storage.cassandra.util.CassandraDBUtil.getDb(CassandraDBUtil.java:107)
        at com.july.storage.cassandra.util.CassandraDBUtil.hasTable(CassandraDBUtil.java:91)
        at com.july.storage.cassandra.action.CassandraHandler.getCall(CassandraHandler.java:65)
        at com.july.storage.service.StorageService.GET(StorageService.java:58)
        at com.july.storage.cassandra.action.CassandraHandler.main(CassandraHandler.java:571)

【问题讨论】：

标签： cassandra

【解决方案1】：

不要在 Cassandra 前面使用负载平衡器。让您的客户端连接到所有节点。负载均衡器只会出现单点故障，并增加不必要的延迟。

【讨论】：

如果我以后想添加更多节点，我需要去更改每个使用集群的客户端。还有其他可能吗？
大多数驱动程序都有自动对等发现，因此它们只需要一个种子节点来连接，然后连接到所有其他节点（或一些，取决于配置）。对于 Hector，向下滚动到用户指南中的“使用节点自动发现”：github.com/rantav/hector/wiki/User-Guide
我使用的是 cassandra 1.2.5。集群有 4 个节点。集群中有两个种子节点。我已启用 AutoDiscoverHosts 并使用种子节点在我的客户端中创建集群。如果该种子节点已启动，我可以在集群中的所有节点中写入/读取数据。但如果它关闭，“所有主机池都标记为关闭。重试负担推到客户端”正在抛出。没有进一步的读/写发生。 (i) 即使我们启用了 AutoDiscoverHosts，在从客户端创建集群时是否必须提供所有节点？
如果您要连接的节点已关闭，则没有节点可以询问集群中的其他节点。