工作代码:
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
问题:
有没有可能加快代码中的查询速度,以便在节点脱机时不会花费更长的时间?或者,如果大多数节点处于脱机状态,至少可以减少运行查询所需的时间?
1条答案
按热度按时间nhaq1z211#
你在测量代码的总执行时间吗?或者您更感兴趣的是测量应用程序在初始化之后运行查询所需的时间吗?
初始化期间(
cluster.Connect
),驱动程序将迭代接触点集合,直到它能够成功打开控制连接,因此如果要加快初始化速度,则必须从该列表中删除脱机节点。另外,默认情况下,驱动程序在初始化期间运行预热操作,该操作包括打开到负载平衡策略返回的所有节点的连接,因此这里也会有一个超时。您可以尝试设置
.WithPoolingOptions(new PoolingOptions().SetWarmup(false))
使初始化更快。禁用预热操作可能会使第一个查询变慢,直到驱动程序识别出哪些节点处于脱机状态。在这种情况下,减少查询执行时间的建议方法是使用推测性重试(https://docs.datastax.com/en/developer/csharp-driver/3.12/features/speculative-retries).