了解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());

        }

了解Cassandra系统.使用c#驱动程序查询

您正在看到驱动程序负载平衡策略的效果。system.peers是一个本地表,在每个节点上都是不同的。当您使用驱动程序执行查询时,它将在节点之间进行负载平衡,每次给出不同的结果。

如果多次执行并打印结果,您应该看到对等体在节点之间交替。