了解Cassandra系统.使用c#驱动程序查询
本文关键字:驱动程序 查询 使用 Cassandra 系统 了解 | 更新日期: 2023-09-27 18:07:36
我不知道为什么当我从节点1查询对等表时,我得到与接触点相同的对等。
当我将IP更改为46(node2)时,我得到45(node1),但从45(node1)查询,我得到45(node1)
Cluster clusterconn = Cluster.Builder().WithCredentials(txtuser.Text, txtsec.Text).AddContactPoint("192.168.0.45).Build();
ISession Conn_session = clusterconn.Connect("system");
var con_result = Conn_session.Execute("select peer FROM system.peers");
// lstnode.Items.Add(txt_pip.Text);
foreach (var rows in con_result)
{
//var value = row.GetValue<int>("id");
lstnode.Items.Add(rows["peer"].ToString());
}
您正在看到驱动程序负载平衡策略的效果。system.peers
是一个本地表,在每个节点上都是不同的。当您使用驱动程序执行查询时,它将在节点之间进行负载平衡,每次给出不同的结果。
如果多次执行并打印结果,您应该看到对等体在节点之间交替。