使用 c# 连接 AWS cassandra

Question

我正在尝试使用此代码连接到 AWS Cassandra：

       var pathToCAFile = $"{Directory.GetCurrentDirectory()}/AmazonRootCA1.pem";
        X509Certificate2[] certs = new X509Certificate2[] { new X509Certificate2(pathToCAFile, "amazon") };
        X509Certificate2Collection certificateCollection = new X509Certificate2Collection(certs);
        var options = new Cassandra.SSLOptions(SslProtocols.Tls11, true, ValidateServerCertificate);
        options.SetCertificateCollection(certificateCollection);
        Cluster cluster = Cluster
                            .Builder()
                            .WithCredentials("username", "password")
                            .WithPort(9142)
                            .AddContactPoint("cassandra.us-east-1.amazonaws.com")
                           .WithSSL()
                            .WithLoadBalancingPolicy(new DefaultLoadBalancingPolicy("us-east-1"))
                            .Build();

        // Connect to the nodes using a keyspace
        var session = cluster.Connect("system_distributed");

 

        // Execute a query on a connection synchronously
        var rs = session.Execute("select * from system.peers");

这是我得到的错误：

"Cassandra.NoHostAvailableException: '所有主机尝试查询失败 （试过 3.83.169.143:9142: AuthenticationException '远程 根据验证程序，证书无效。')'

这个异常最初是在这个调用栈中抛出的：

Cassandra.Connections.Control.ControlConnection.Connect(bool) System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess（System.Threading.Tasks.Task） System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification（System.Threading.Tasks.Task） System.Runtime.CompilerServices.ConfiguredTaskAwaitable.ConfiguredTaskAwaiter.GetResult() Cassandra.Connections.Control.ControlConnection.InitAsync() System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess（System.Threading.Tasks.Task） System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification（System.Threading.Tasks.Task） System.Runtime.CompilerServices.ConfiguredTaskAwaitable.ConfiguredTaskAwaiter.GetResult() ... [调用堆栈被截断]

Answer 1

我假设您使用的是 DataStax C# 驱动程序。如果是这种情况，请参阅有关 SSL/TLS 的文档部分，其中还包含几个示例的链接：https://docs.datastax.com/en/developer/csharp-driver/3.15/features/tls/

如果该 sn-p 是准确的，那么您实际上并没有在 Builder.WithSSL() 方法上设置 SSLOptions。

如果这不起作用并且代码示例对您没有帮助，请向我们展示ValidateServerCertificate 方法，以便我们查看证书验证可能出现的问题。

---

编辑（来自我下面的评论）：

TLS/SSL documentation page 有一个部分与此处相关：使用自定义根证书启用服务器身份验证。

如文档中所述，您要么必须在运行应用程序的机器上安装该证书，要么必须提供类似于this one 的自定义证书验证器。

SSLOptions.SetCertificateCollection() 方法用于客户端身份验证，因此它不适用于您需要服务器身份验证的情况。