高可用中间件 Java架构 系统监控

import io.prometheus.client.Counter;
import io.prometheus.client.Gauge;
import io.prometheus.client.exporter.HTTPServer;
 
public class MonitoringService {
 
    // 定义计数器，用于监控请求总数
    private static final Counter requestTotal = Counter.build()
            .name("service_requests_total")
            .labelNames("method")
            .help("Total requests served.")
            .register();
 
    // 定义计数器，用于监控错误数
    private static final Counter errorTotal = Counter.build()
            .name("service_errors_total")
            .labelNames("cause")
            .help("Total errors.")
            .register();
 
    // 定义度量，用于监控当前活跃的连接数
    private static final Gauge activeConnections = Gauge.build()
            .name("service_active_connections")
            .help("Active connections.")
            .register();
 
    public static void main(String[] args) {
        HTTPServer server = new HTTPServer(8080); // 开启一个HTTP服务器监听8080端口
 
        // 示例代码：模拟业务逻辑
        while (true) {
            // 处理请求
            processRequest();
            // 模拟错误发生
            simulateError();
            // 模拟连接变化
            simulateConnectionChange();
 
            // 为了简洁，这里不包含具体的业务逻辑实现
            // ...
        }
    }
 
    private static void processRequest() {
        // 请求方法随机，这里仅为示例
        String method = "GET"; // 实际应用中应该是动态的
        requestTotal.labels(method).inc(); // 增加请求计数
    }
 
    private static void simulateError() {
        // 错误原因随机，这里仅为示例
        String cause = "timeout"; // 实际应用中应该是动态的
        errorTotal.labels(cause).inc(); // 增加错误计数
    }
 
    private static void simulateConnectionChange() {
        // 模拟连接数增加或减少
        activeConnections.inc(); // 假设有新的连接
        // ...
        // 实际应用中应该跟踪连接的开启和关闭
    }
}

这个简化的Java代码示例展示了如何使用Prometheus客户端库来创建监控指标，并且将它们暴露给一个HTTP服务器。在实际的应用程序中，你需要替换示例代码中的processRequest()和simulateError()方法，以反映你的业务逻辑。同时，你需要实现simulateConnectionChange()方法来跟踪活跃连接的增减。这样，你就可以通过Prometheus拉取这些监控指标，并利用Grafana之类的工具进行可视化。