JMX3:数据类型

#java #jmx #tech

上两篇已经介绍了jmx的基本知识. 不过在真实的应用场景下,我们经常需要暴露比较复杂的数据类型. jmx支持吗? 答案是肯定的. 那就写代码试试吧:

//一个简单的数据类
public class MyDataType {
    private String name;
    private int    age;
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public int getAge() {
        return age;
    }
    public void setAge(int age) {
        this.age = age;
    }
}

//定义一个MBean
public interface DataTypeMBean {
    int getCount();
    List<String> getNames();
    MyDataType getMyDataType();
    List<MyDataType> getMyDataTypeList();
}

//定义一个实现类
public class DataType implements DataTypeMBean {
    @Override
    public int getCount() {
        return 2014;
    }
    @Override
    public List<String> getNames() {
        return Arrays.asList("happy", "new", "year");
    }
    @Override
    public MyDataType getMyDataType() {
        MyDataType dataType = new MyDataType();
        dataType.setAge(10);
        dataType.setName("lucy");
        return dataType;
    }
    @Override
    public List<MyDataType> getMyDataTypeList() {
        MyDataType lucy = new MyDataType();
        lucy.setAge(10);
        lucy.setName("lucy");
        MyDataType lily = new MyDataType();
        lily.setAge(11);
        lily.setName("lily");
        return Arrays.asList(lucy,lily);
    }
    public static void main(String[] args) throws Exception {
        MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
        ObjectName name = new ObjectName("name.chengchao:type=DataType");
        DataType mbean = new DataType();
        mBeanServer.registerMBean(mbean, name);
        System.out.println("started...");
        Thread.sleep(Long.MAX_VALUE);
    }
}

打开jconsole验证一下,发现有点问题,只要是自定义的类型显示了不可用.看来这条路子是走不通了.google之.发现jmx支持opentype

主要是用到两个类: CompositeData:支持自定义类型 TabularData:CompositeData集合

对应上面的例子改造一下: 

//MBean接口的改造
public interface DataTypeMBean {

    int getCount();

    List<String> getNames();

    CompositeData getMyDataType() throws Exception;

    TabularData getMyDataTypeList() throws Exception;
}

//实现的改造:
public class DataType implements DataTypeMBean {

    @Override
    public int getCount() {
        return 2014;
    }

    @Override
    public List<String> getNames() {
        return Arrays.asList("happy", "new", "year");
    }

    @Override
    public CompositeData getMyDataType() throws Exception {
        String[] itemNames = { "name", "age" };
        OpenType<?>[] openTypes = new OpenType[] { SimpleType.STRING, SimpleType.INTEGER };
        CompositeType compositeType = new CompositeType("MyDataType", "my dataType test", itemNames, itemNames,
                                                        openTypes);
        Object[] items = { "lucy", 10 };
        CompositeData dataType = new CompositeDataSupport(compositeType, itemNames, items);
        // MyDataType dataType = new MyDataType();
        // dataType.setAge(10);
        // dataType.setName("lucy");
        return dataType;
    }

    @Override
    public TabularData getMyDataTypeList() throws Exception{
        String[] itemNames = { "name", "age" };
        OpenType<?>[] openTypes = new OpenType[] { SimpleType.STRING, SimpleType.INTEGER };
        CompositeType compositeType = new CompositeType("MyDataType", "my dataType test", itemNames, itemNames,
                                                        openTypes);
        TabularType tabularType = new TabularType("MyDataListType", "my dataType List test", compositeType, itemNames);
        TabularData tabularData = new TabularDataSupport(tabularType);
        CompositeData lucy = new CompositeDataSupport(compositeType, itemNames, new Object[]{"lucy", 10});
        CompositeData lily = new CompositeDataSupport(compositeType, itemNames, new Object[]{"lily", 11});
        tabularData.put(lucy);
        tabularData.put(lily);
//        MyDataType lucy = new MyDataType();
//        lucy.setAge(10);
//        lucy.setName("lucy");
//        MyDataType lily = new MyDataType();
//        lily.setAge(11);
//        lily.setName("lily");
        return tabularData;
    }

    public static void main(String[] args) throws Exception {
        MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
        ObjectName name = new ObjectName("name.chengchao:type=DataType");
        DataType mbean = new DataType();
        mBeanServer.registerMBean(mbean, name);
        System.out.println("started...");
        Thread.sleep(Long.MAX_VALUE);
    }
}