使用 C# 驱动程序了解 Cassandra system.peers 查询

Question

当我从节点 1 查询 peers 表时，我不确定为什么会得到与联络点相同的 peer。

当我将 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());



        }

Answer 1

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

如果您多次执行并打印结果，您应该会看到节点之间交替出现对等节点。

阅读一些关于负载平衡策略的内容here。