使用JMX指标计算写入延迟

import javax.management.*;
import java.lang.management.ManagementFactory;

public class JMXWriterLatencyMonitor {
    public static void main(String[] args) throws Exception {
        // 获取平台MBeanServer
        MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();

        // 定义MBean接口
        ObjectName name = new ObjectName("com.example:type=WriterLatency");

        // 创建MBean实例
        WriterLatency mbean = new WriterLatency();
        mbs.registerMBean(mbean, name);

        System.out.println("JMX Writer Latency Monitor is running...");

        // 模拟写入操作并记录延迟
        for (int i = 0; i < 100; i++) {
            long startTime = System.currentTimeMillis();
            // 模拟写入操作
            Thread.sleep((long) (Math.random() * 100));
            long endTime = System.currentTimeMillis();
            mbean.setWriteLatency(endTime - startTime);
        }
    }
}

// MBean接口定义
public interface WriterLatencyMBean {
    void setWriteLatency(long latency);
    long getWriteLatency();
}

// MBean实现类
public class WriterLatency implements WriterLatencyMBean {
    private long writeLatency;

    @Override
    public void setWriteLatency(long latency) {
        this.writeLatency = latency;
    }

    @Override
    public long getWriteLatency() {
        return writeLatency;
    }
}