如果节点处于脱机状态，则加速cassandra查询

Question

工作代码：

using System;
using Cassandra;
namespace CassandraSelectTest
{
class Program
{
static void Main(string[] args)
{
var cluster = Cluster.Builder()
.AddContactPoints("192.168.0.18","192.168.0.21","192.168.0.22","192.168.0.23","192.168.0.24")
.WithPort(9042)
.Build();
var session = cluster.Connect("test_keyspace");
var results = session.Execute("SELECT * FROM test_table");
foreach(var result in results)
{
Console.WriteLine(result.GetValue<string>("col1"));
}
Console.WriteLine($"Finished");
Console.ReadKey();
}
}
}

---

设置：

Nodes = 5
Replication = 5
Consistency = 1

---

测试：

一次删除一个节点，看看上面的代码是否能继续工作。

---

结果：

代码在每个节点脱机后继续工作，然后在所有节点脱机时按预期给出错误。但是，脱机的节点越多，代码运行所需的时间就越长。每个脱机节点大约多出5秒。

---

速度：

5 nodes online = 1 second
4 nodes online = 5 seconds
3 nodes online = 10 seconds
2 nodes online = 15 seconds
1 node online = 20 seconds

---

问题：

是否可以加快代码中的查询速度，以便在节点离线时不会花费更长时间？或者，如果大多数节点处于脱机状态，至少可以减少运行查询所需的时间？

Answer 1

您是否在衡量该代码的总执行时间？还是您更感兴趣的是测量应用程序在初始化后运行查询所需的时间？

在初始化期间(cluster.Connect(，驱动程序在接触点集合上迭代，直到能够成功打开控制连接，因此，如果要加快初始化速度，必须从该列表中删除脱机节点。

此外，默认情况下，驱动程序在初始化期间运行一个预热操作，该操作包括打开到负载平衡策略返回的所有节点的连接，因此这里也会有一个超时。您可以尝试设置.WithPoolingOptions(new PoolingOptions().SetWarmup(false))以加快初始化速度。

禁用预热操作可能会使第一次查询变慢，直到驱动程序识别出哪些节点处于脱机状态。在这种情况下，减少查询执行时间的建议方法是使用推测重试(https://docs.datastax.com/en/developer/csharp-driver/3.12/features/speculative-retries)。