JMXTest.java 文件源码

public static void objectNames(KafkaJMX kafkaJMX) {
  kafkaJMX.doWithConnection("10.16.238.94", 8888, Optional.of(""), Optional.of(""), false, new JMXExecutor() {

    @Override
    public void doWithConnection(MBeanServerConnection mbsc) {
      // KafkaMetrics kafkaMetrics = new KafkaMetrics();
      try (FileWriter fw = new FileWriter("objectNames.json", true);
          BufferedWriter bw = new BufferedWriter(fw);
          PrintWriter out = new PrintWriter(bw)) {
        Set<ObjectInstance> beans = mbsc.queryMBeans(null, null);
        JSONArray objectName = new JSONArray();
        for (ObjectInstance bean : beans) {
          if (excludeInternalTopic && bean.getObjectName().toString().contains("__consumer_offsets")) {
            continue;
          }
          System.out.println("ObjectName: " + bean.getObjectName());
          objectName.put(bean.getObjectName().toString());
          MBeanInfo mbeanInfo = mbsc.getMBeanInfo(bean.getObjectName());
          System.out.println("\tMBeanInfo: " + mbeanInfo);
          MBeanAttributeInfo[] attributes = mbeanInfo.getAttributes();
          String[] attributeArr = new String[attributes.length];
          for (int i = 0; i < attributes.length; i++) {
            attributeArr[i] = attributes[i].getName();
          }
          AttributeList attributeList = mbsc.getAttributes(bean.getObjectName(), attributeArr);
          List<Attribute> attributeList1 = attributeList.asList();

          for (Attribute attr : attributeList1) {
            System.out.println("\t\tName: " + attr.getName() + " Value: " + attr.getValue());
          }
        }
        out.println(objectName.toString());
      } catch (Exception e) {

      }
    }
  });

}