使用gocql连接AWS上的Cassandra集群出现连接拒绝错误如何解决

• 首先修正代码逻辑问题
  报错中的空指针panic是代码逻辑缺陷导致：创建session出错后没有终止流程，后续代码直接调用了为nil的session对象。需要在错误判断分支增加终止逻辑：

  if err != nil {
      fmt.Println(err)
      // 新增错误处理：终止流程或者返回
      return
  }
  

• 排查Cassandra侧监听配置（核心问题来源）
  错误日志中出现dial tcp 127.0.0.1:9042的记录，说明Cassandra集群向客户端返回了本地回环地址作为节点访问地址，导致客户端尝试连接本地的9042端口，需要修改所有Cassandra节点的cassandra.yaml配置：
  1. 将rpc_address修改为实例内网IP或0.0.0.0（允许所有网卡访问）
  2. 显式设置broadcast_rpc_address为AWS实例的公网IP（客户端从公网访问场景），如果rpc_address设为0.0.0.0必须配置该参数，否则Cassandra启动失败
  3. 确认start_native_transport为true，native_transport_port保持默认9042（如果自定义端口需要在gocql代码中对应指定）
  4. 配置修改后重启Cassandra服务生效，在节点上执行netstat -tunlp | grep 9042确认监听地址不是127.0.0.1
• 排查网络连通性
  1. 确认AWS安全组入站规则已放通客户端公网IP的9042端口访问权限
  2. 确认AWS实例内部防火墙（ufw/firewalld/iptables）已放通9042端口
  3. 在客户端本地执行连通性测试：

     telnet x.xxx.xxx.xxx 9042
     # 或者用nc测试
     nc -zv x.xxx.xxx.xxx 9042
     

  若测试失败优先解决网络策略问题
• 优化gocql连接配置
  1. NewCluster参数填入所有Cassandra节点的公网IP，避免单点故障导致连接失败：

     cluster := gocql.NewCluster("节点1公网IP","节点2公网IP","节点3公网IP")
     

  2. 确认ProtoVersion和Cassandra版本匹配：Cassandra 3.x对应版本4，Cassandra 2.x对应版本3

内容的提问来源于stack exchange，提问作者Jesver