如何使用 cqlsh 连接到 Cassandra（远程主机）答案

【问题标题】：How to connect to Cassandra(remotehost) using cqlsh如何使用 cqlsh 连接到 Cassandra（远程主机）
【发布时间】：2015-11-28 15:49:10
【问题描述】：

我无法 cqlsh 到远程主机

 ./cqlsh xx.xx.x.xxx 9042
   Connection error: ('Unable to connect to any servers', {'10.101.33.163':   
   ConnectionException(u'Did not get expected SupportedMessage response; 
   instead, got: <ErrorMessage code=0000 [Server error]      
   message="io.netty.handler.codec.DecoderException: 
   org.apache.cassandra.transport.ProtocolException: Invalid or unsupported 
   protocol version: 4">',)})

我正在使用 cqlsh 5.0.1 和 python 2.7.10

  ./cqlsh --version
     cqlsh 5.0.1
  python -V
    Python 2.7.10

我在 mac 上使用 http://www.datastax.com/2012/01/working-with-apache-cassandra-on-mac-os-x 的说明下载了 cassandra。

我本地的 Cassandra 是 2.2.1（我从 zip 文件中了解到），看起来远程主机上的 cassandra 不是 2.2.1（我假设它是 2.0 或 2.1）。在不明确知道远程主机上的版本的情况下，如何尝试连接到远程主机上的 cassandra

【问题讨论】：

看起来像这样 - stackoverflow.com/questions/31444098/…

标签： cassandra cqlsh

【解决方案1】：

1) 确保服务正在运行：

$ ps 辅助 | grep 卡桑德拉

示例： 106 7387 5.1 70.9 2019816 1454636 ? SLl Sep02 16:39 /usr/lib/jvm/java-7-oracle/jre//bin/java -Ddse.system_cpu_cores=2 -Ddse.system_memory_in_mb=2003 -Dcassandra.config.loader=com.datastax.bdp.config .DseConfigurationLoader -Ddse.system_cpu_cores=2 -Ddse.system_memory_in_mb=2003 -Dcassandra.config.loader=com.datastax.bdp.config.DseConfigurationLoader -ea -javaagen...

2) 通过检查服务器配置确保您使用的是正确的 IP：

$ ifconfig

例子：

eth1 Link encap:Ethernet HWaddr 08:00:27:a6:4e:46
inet addr:192.168.56.10 Bcast:192.168.56.255 Mask:255.255.255.0 inet6 地址：fe80::a00:27ff:fea6:4e46/64 范围：链接 UP BROADCAST RUNNING MULTICAST MTU:1500 Metric:1

3) 确保您可以从您所在的服务器连接到该 IP：

$ ssh user@xxx.xxx.xx.xx

4) 检查节点的状态并确认它显示相同的 IP：

$nodetool 状态

5）运行命令连接IP（如果不使用默认只指定端口）：

$ cqlsh xxx.xxx.xx.xx

【讨论】：

你能区分我们可以在哪个服务器上运行哪个命令吗？试图达到同样的目的。从一台服务器连接到安装了 cassabdra 单集群的另一台服务器'

【解决方案2】：

您可能需要将 2.1 或 2.0 的 cqlsh 放在您的 mac 上，以匹配您尝试连接的服务器。所以这是我首先要尝试的。

【讨论】：

简单明了。为我工作！

【解决方案3】：

我遇到了同样的错误（在 Windows 8.1 上运行 Cassandra 2.2.0），并找到了 Gustav Grusell 对我有用的解决方法：https://issues.apache.org/jira/browse/CASSANDRA-9467?focusedCommentId=14693410&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-14693410

他提出的解决方法是修改您的 cqlsh.py 脚本以接受协议版本。进行这些更改后，您将能够通过将--protocolversion=3 传递给 cqlsh 来指定协议版本 3（例如）。

在您的 Cassandra bin 文件夹中找到 cqlsh.py 并在进行这些更改之前对其进行备份。

在其他 parser.add_option 语句旁边添加以下行（~第 175 行）：

parser.add_option("--protocolversion", default=DEFAULT_PROTOCOL_VERSION, help='Specify protocol version (default: %default).')

在 def read_options(cmdlineargs, environment): 下的其他选项值旁边添加以下内容（~第 2520 行）：

optvalues.protocolversion =  option_with_default(configs.get, 'cql', 'protocolversion', DEFAULT_PROTOCOL_VERSION)

在def read_options(cmdlineargs, environment):（~第2574行）的return语句之前添加以下内容

if options.protocolversion:
    try:
        options.protocolversion = int(optvalues.protocolversion)
    except ValueError:
        options.protocolversion=DEFAULT_PROTOCOL_VERSION

修改 def main(options, hostname, port): 中的 Shell 命令以包含协议版本（~第 2657 行）：

                  connect_timeout=options.connect_timeout,
                  protocol_version=options.protocolversion)

这是我的 cqlsh.py 现在的样子：http://pastebin.com/f9D2zEE4

【讨论】：