使用 Cassandra Metrics 进行监控

Question

一段时间以来，我一直在使用 Cassandra 及其 C++ 驱动程序编写 API 来插入和获取数据。但是，既然我已经创建了集群，我想为我的集群开发监控工具。

我想构建一个应用程序（最好使用 C++，我不想使用第 3 方应用程序），它将存储集群管理特定属性，例如集群中每个节点的内存利用率、每个操作的延迟、空间被每个节点上的每个表占用等。我读到了“Cassandra 中的指标”（https://cassandra.apache.org/doc/latest/operating/metrics.html），但我不知道如何在构建我的应用程序时准确使用它们，因为我之前没有使用过 Java（请原谅） ！）。 可以使用 C++ 构建这样的应用程序吗？如果在 C++ 中进行了大量工作，那么如果您可以共享一些 Java 代码，其中这些 Cassandra Metrics 已用于监控 Cassandra 集群，那将是非常有益的。

操作系统：RHEL Cassandra 版本：3.11.2

Answer 1

Cassandra 3.x 使用您提到的 drop wizard api。如果您可以将Jolokia jar 添加到您的部署服务器，这将允许您使用简单的 http 请求访问 java jmx 数据。 Jolokia 通过 rest api 公开了 java 中的所有 mbean。

Answer 2

似乎没有任何用于 JMX 的 c++ 库，但在 Java 中很容易获得 JMX 指标，您所需要的只是标准 jdk。以下代码演示了如何连接到 cassandra 节点并获取“down”节点数。

import java.util.HashMap;
import java.util.Map;

import javax.management.MBeanServerConnection;
import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;

public class Main {
    public static void main( String[] args ) throws Exception {
        String node = args[0];
        String port = args[1];
        String username = args[2];
        String password = args[3];

        JMXServiceURL url = new JMXServiceURL( "service:jmx:rmi:///jndi/rmi://" + node + ":" + port + "/jmxrmi" );
        String[] credentials = {username, password};

        Map<String, String[]> environment = new HashMap<>();
        environment.put( JMXConnector.CREDENTIALS, credentials );
        JMXConnector jmxConnector = JMXConnectorFactory.connect( url, environment );
        MBeanServerConnection mbsc = jmxConnector.getMBeanServerConnection();//Get metrics bean
        ObjectName oName = new ObjectName( "org.apache.cassandra.net:type=FailureDetector" );//create JMX object name
        int downNodes = (int) mbsc.getAttribute( oName, "DownEndpointCount" ); //get number of unavailable nodes

        System.out.println("Down node count: " + downNodes);
    }
}

有关 jmx 的更多详细信息，您可以在 Oracle documentation 中找到

要获取JMX对象名和属性名，可以使用jdk自带的jconsole工具：