JMX和MBean以及pojo-mbean学习

最近在看一个开源的Cache框架,里面提到使用JMX来查看Cache的命中率以及响应时间等,因而翻了一些JMX的文章,整理了一下。 html

    1. 问题:什么是JMX? java

    2. 问题:JMX的架构是什么样子的? 缓存

    3. 问题:JMX以及Mbean中的 概念都有那些? 架构

    4. 问题:如何编写一个简单的Standard MBean? 框架

    5. 问题:如何编写一个DynamicMBean? 函数

    6. 问题:Open MBean 和Mode MBean是做用是啥? this

    7. 问题:按照MBean的规范写,是否是有点繁琐,有没有简单点的办法? google

 

        问题:什么是JMX? spa

        JMX(java management extensions)java管理程序扩展,是一个为应用程序、设备、系统等植入管理功能的框架。 .net

        JMX使用了最简单的一类javaBean,使用有名的MBean,其内部包含了数据信息,这些信息多是程序配置信息、模块信息、系统信息、统计信息等。MBean能够操做可读可写的属性、直接操做某些函数。

        

        问题:JMX的架构是什么样子的?      

        

 

        

        问题:JMX使用三层架构,各个层的详细描述是怎么样的?

Probe Level负责资源的检测(获取信息),包含MBeans,一般也叫作Instrumentation Level。

The Agent Level 或者叫作MBean Server,是JMX的核心,链接这个Mbeans和应用程序。

Remote Management Level经过connectors和adaptors来远程操做MBeanServer, Applications能够是你们比较熟悉的控制台,例如JConsole。

       

        JMX以及Mbean中的 概念都有那些?

一、MBean

一般是一个java类,他提供接口,能够是这个类具备管理功能。

Standard Mbean是最简单的MBean,他能管理的资源必须定义在接口中,而后MBean必须实现这个接口,命名必须遵照必定的规范。

1
2
3
4
5
6
MBean interface:
一、名字必须以MBean结尾
二、必须与签名暴漏属性和操做
MBean implement
一、必须有个名字和接口中"MBean"的前缀相同
二、实现接口中的方法

Dynamic Mbean必须实现DynamicMBean,全部的属性和方法都在运行时定义。

1
2
一、必须实现DynamicMBean接口
二、在实现类中实现DynamicMBean中的方法

二、MBean Server

管理MBean的一个java类,须要向MBean Server中注册一个MBean以后,这个MBean才会具备管理功能,MBeanServer还提供了查询和注解监听器的功能,不一样的JMX实现中MBean Server实现也不一样。

三、JMX agent

agent是为了管理一些列的MBean而提供的一系列服务。agent能够利用protocal adapters(例如HTTP)和connectors使不一样的客户端能够访问MBean。

 

        问题:如何编写一个简单的Standard MBean?

一、编写MBean的接口:TestMBean.java

定义了属性的get和set方法以及一个操做方法

1
2
3
4
5
public  interface  TestMBean {
     public  void  printHelloWorld();
     public  String getName();
     public  void  setName(String name);
}

二、写一个类实现刚才的MBean接口Test.java

1
2
3
4
5
6
7
8
9
10
11
12
public  class  Test  implements  TestMBean {
     private  String name;
     public  void  printHelloWorld() {
         System.out.println(name+ ",welcome to this world." );
     }
     public  String getName() {
         return  name;
     }
     public  void  setName(String name) {
         this .name = name;
     }
}

三、编写一个main函数(将MBean注册到MBeanServer中)Main.java

1
2
3
4
5
6
7
8
9
10
11
12
import  java.lang.management.ManagementFactory;
import  javax.management.MBeanServer;
import  javax.management.ObjectName;
public  class  Main {
     public  static  void  main(String[] args)  throws  Exception{
         MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
         ObjectName name =  new  ObjectName( "agent:name=test" );
         Test testMBean =  new  Test();
         mBeanServer.registerMBean(testMBean, name);
         Thread.sleep( 5000000 );
     }
}

四、经过JConsole来连接java进程,获取agent信息,经过MBeanServer来操做MBean



 

 

 

        问题:如何编写一个DynamicMBean?

一、搞一个类继承DynamicMBean(  TestDynamic.java)

初始化MBeanMeta 信息,包括Attribute和operation

实现Invoke方法

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
import  javax.management.Attribute;
import  javax.management.AttributeList;
import  javax.management.AttributeNotFoundException;
import  javax.management.DynamicMBean;
import  javax.management.InvalidAttributeValueException;
import  javax.management.MBeanAttributeInfo;
import  javax.management.MBeanException;
import  javax.management.MBeanInfo;
import  javax.management.MBeanOperationInfo;
import  javax.management.ReflectionException;
public  class  TestDynamic  implements  DynamicMBean {
     private  String name =  "iamzhongyong" ;
 
     public  String getName() {
         return  name;
     }
 
     public  void  setName(String name) {
         this .name = name;
     }
 
     public  void  printName(){
         System.out.println(name);
     }
     public  Object getAttribute(String attribute)
             throws  AttributeNotFoundException, MBeanException,
             ReflectionException {
         if (attribute== null ){
             throw  new  AttributeNotFoundException();
         }
         if ( "name" .equalsIgnoreCase(attribute)){
             return  getName();
         }
         throw  new  AttributeNotFoundException();
     }
 
     public  void  setAttribute(Attribute attribute)
             throws  AttributeNotFoundException, InvalidAttributeValueException,
             MBeanException, ReflectionException {
         String name = attribute.getName();
         Object value = attribute.getValue();
         if ( "name" .equalsIgnoreCase(name)){
             this .setName(String.valueOf(value));
             return ;
         }
         throw  new  AttributeNotFoundException();
     }
 
     public  AttributeList getAttributes(String[] attributes) {
         return  null ;
     }
 
     public  AttributeList setAttributes(AttributeList attributes) {
         return  null ;
     }
 
     public  Object invoke(String actionName, Object[] params, String[] signature)
             throws  MBeanException, ReflectionException {
         if ( "printName" .equals(actionName)){
             printName();
         }
         return  null ;
     }
 
     public  MBeanInfo getMBeanInfo() {
         MBeanAttributeInfo[] dAttributes =  new  MBeanAttributeInfo[] {
                 new  MBeanAttributeInfo( "name" "String" "缓存名称" true ,   true false )};
         MBeanOperationInfo opers[] = {
                 new  MBeanOperationInfo( "printName" , "print" , null , "void" ,MBeanOperationInfo.ACTION)};
 
         MBeanInfo info =  new  MBeanInfo( this .getClass().getName(),
                                         "TestDynamic" ,
                                         dAttributes,
                                         null ,
                                         opers,
                                         null );
         return  info;
     }
}

二、main函数编写(注册到MBeanServer中)

1
2
3
4
5
6
7
8
9
10
11
12
import  java.lang.management.ManagementFactory;
import  javax.management.MBeanServer;
import  javax.management.ObjectName;
public  class  Main {
     public  static  void  main(String[] args)  throws  Exception{
         MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
         ObjectName name =  new  ObjectName( "agent:name=test" );
         TestDynamic testMBean =  new  TestDynamic();
         mBeanServer.registerMBean(testMBean, name);
         Thread.sleep( 5000000 );
     }
}

 

 

 

        问题:Open MBean 和Mode MBean是做用是啥?

        其实这两类也是动态的MBean,OpenMBean和其余MBean不一样之处在于公共接口的返回值有所限制,只能是基本类型或者openmbean包内的类型。(可能主要考虑到远端管理系统,可能不具有MBean接口中的特殊的类)

普通的动态的MBean缺乏一些管理系统的支持,例如MBean的状态持久化或者日志记录等,由于JMX厂商提供不一样的MobleMBean的实现,方便用户进行操做。

使用pojo-mbean来减小MBean繁琐的操做

 

 

 

        问题:按照MBean的规范写,是否是有点繁琐,有没有简单点的办法?

有的,基于POJO-MBean来作JMX,经过注解来实现一些繁琐的步骤,让动态MBean不在那么蛋疼。

pojo-mbean提供了一种基于注解来减小繁琐的MBean的方式(http://code.google.com/p/pojo-mbean/)。

pojo-mbean没有依赖任何第三方的包,须要JDK5以上,经过注解标示一个类,是这个类做为MBean,包括属性、操做以及参数等。

版本依赖:

1
2
3
4
5
<dependency>
     <groupId>org.softee</groupId>
     <artifactId>pojo-mbean</artifactId>
     <version> 1.1 </version>
</dependency>

主要原理:

一、在注册MBeanServer的时候,扫描注解的类文件

二、而后转换MBean的Meta信息,把相关的信息经过反射完成

三、抽象类实现DynamicMBean

实例代码以下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
import  org.softee.management.annotation.Description;
import  org.softee.management.annotation.MBean;
import  org.softee.management.annotation.ManagedAttribute;
import  org.softee.management.annotation.ManagedOperation;
import  org.softee.management.annotation.Parameter;
import  org.softee.management.helper.MBeanRegistration;
 
 
@MBean (objectName= "pojo-agent-test:name=HelloWorld" )
@Description ( "HelloWorld MBean by pojo-mbean" )
public  class  HelloWorld {
 
     private  String name ;
 
     private  int  age;
 
     @ManagedOperation
     @Description ( "print the name and age" )
     public  void  print(){
         System.out.println( "name=" +name+ ",age=" +age);
     }
     @ManagedOperation
     @Description ( "increment the age and then return the new age" )
     public  int  incrementAge( @Parameter ( "age" ) int  age){
         this .age =  this .age+age;
         return  this .age;
     }
 
     @ManagedAttribute  @Description ( "about name" )
     public  String getName() {
         return  name;
     }
     @ManagedAttribute
     public  void  setName(String name) {
         this .name = name;
     }
 
     @ManagedAttribute  @Description ( "about age" )
     public  int  getAge() {
         return  age;
     }
     @ManagedAttribute
     public  void  setAge( int  age) {
         this .age = age;
     }
     /**
      * 把MBean注册到MBeanServer中
      * @throws Exception
      */
     public  void  initMBeanServer()  throws  Exception{
          new  MBeanRegistration( this ).register();
     }
 
     public  static  void  main(String[] args)  throws  Exception{
         HelloWorld a =  new  HelloWorld();
         a.initMBeanServer();
         Thread.sleep( 500000 );
     }
}

 

        基于此,以后经过MBean来实现一些监控或者管理,就能比较方便了。

 

参考文章:

http://en.wikipedia.org/wiki/Java_Management_Extensions

http://homepages.thm.de/~hg51/Veranstaltungen/Komponenten-11/Folien/components-jmx.pdf

http://my.oschina.net/zhongl/blog/29075

http://www.blogjava.net/heavensay/archive/2012/09/24/386308.html

相关文章
相关标签/搜索