1

Astyanax 1.56.37 连接到在 Debian 上运行的 Cassandra 1.2.6：

在对仅包含一个位于 10.10.1.141 的节点的 Cassandra 集群执行快速连续插入时，在看似随机的点上，我将在控制台中看到以下内容：

- AddHost: 127.0.0.1
- RemoveHost: 10.10.1.141

在我收到此信息后，每次尝试连接到此键空间都会失败并显示相同的消息。

这是我的配置：

AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder()
        .forCluster("Titan Cluster")
        .forKeyspace(keyspaceName)
        .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()
            .setConnectionPoolType(ConnectionPoolType.TOKEN_AWARE)
            .setDiscoveryType(NodeDiscoveryType.RING_DESCRIBE)
            .setTargetCassandraVersion("1.2")
        )
        .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl("MyConnectionPool")
            .setPort(9160)
            .setMaxConnsPerHost(50)
            .setSeeds("10.10.1.141:9160")
            .setConnectTimeout(2000)
            .setSocketTimeout(30000)
            .setMaxTimeoutWhenExhausted(10000)
            .setMaxTimeoutCount(3)
            .setTimeoutWindow(10000)
            .setLatencyAwareBadnessThreshold(10)
            .setLatencyAwareUpdateInterval(1000)
            .setLatencyAwareResetInterval(10000)
            .setLatencyAwareWindowSize(100)
        )
        .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
        .buildKeyspace(ThriftFamilyFactory.getInstance());

    context.start();

后续尝试连接失败context.start()

4

2 回答 2

3

我也遇到了同样的问题，我的 Cassandra 和应用程序（Cassandra 客户端）在不同的机器上运行。

AddHost: 10.10.1.141  
AddHost: 127.0.0.1  
RemoveHost: 10.10.1.141

当我检查我的 Cassandra 环状态时，我注意到 Cassandra 正在使用 address 运行127.0.0.1，而不是10.10.1.141

root@10.10.1.141:/opt/dsc-cassandra$ **bin/nodetool ring**

Address    Rack        Status State   Load               Owns                        Token                                       
127.0.0.1  rack1       Up     Normal  169.87 KB       100.00%             -9217929600007243236                        
127.0.0.1  rack1       Up     Normal  169.87 KB       100.00%             -9140762708880451456                        
127.0.0.1  rack1       Up     Normal  169.87 KB       100.00%             -8952943573583903866                        
127.0.0.1  rack1       Up     Normal  169.87 KB       100.00%             -8891950316930533160*

在conf/cassandra.yaml中，我指定了主机名而不是 IP 地址listen_address。cassandra 将主机名解析为 localhost ( 127.0.0.1) 而不是实际的 IP ( 10.10.1.141)。改成listen_address实际IP后，客户端建立连接成功。

听地址：10.10.1.141

于 2014-03-28T10:25:33.103 回答
0

我在 Windows 上的 VirtualBox 上运行 Cassandra，所以 IP 类似于 168.192.0.14，对我来说，使用 NodeDiscoveryType.NONE 可以防止断开连接：

    AstyanaxContext<Keyspace> context = new AstyanaxContext.Builder()
        .forCluster(clusterName)
        .forKeyspace(keyspaceName)
        .withAstyanaxConfiguration(new AstyanaxConfigurationImpl()
            .setDiscoveryType(NodeDiscoveryType.NONE)
        )
        .withConnectionPoolConfiguration(new ConnectionPoolConfigurationImpl("MyConnectionPool")
            .setPort(9160)
            .setMaxConnsPerHost(3)
            .setSeeds("192.168.0.14:9160")
        )
        .withConnectionPoolMonitor(new CountingConnectionPoolMonitor())
        .buildKeyspace(ThriftFamilyFactory.getInstance());

    context.start();
    Keyspace keyspace = context.getClient();
于 2015-08-17T18:40:33.257 回答