JMX一步步来(24页).doc

《JMX一步步来(24页).doc》由会员分享，可在线阅读，更多相关《JMX一步步来(24页).doc（25页珍藏版）》请在得力文库 - 分享文档赚钱的网站上搜索。

1、-JMX一步步来-第 25 页JMX一步步来1、JMX的Hello World 一、JMX简介 什么是JMX？在一篇网文中是这样说的：JMX(Java Management Extensions)是一个为应用程序植入管理功能的框架。JMX是一套标准的代理和服务，实际上，用户可以在任何Java应用程序中使用这些代理和服务实现管理，这句话我现在看着还是不知所云，云里雾里。我们还是从JMX能给我们提供什么好处入手来理解吧。举一个应用实例：在一个系统中常常会有一些配置信息，比如服务的IP地址，端口号什么的，那么如何来写这些代码呢？1. 程序初哥一般是写死在程序里，到要改变时就去改程序，然后再编译发布；

2、 2. 程序熟手则一般把这些信息写在一个配置文件里（JAVA一般都是*.properties文件），到要改变时只要改配置文件，但还是重新启动系统，以便读取配置文件里的新值； 3. 程序好手则会写一个段代码，把配置值缓存起来，系统在读值的时候，先看看配置文件有没有更动。如有更改则重读一遍，否则从缓存里读取值 4. 程序高手则懂得取物为我所用，用JMX！把配置属性集中在一个类，然后写一个叫MBean的东东，再配置一下就轻松搞定了。而且JMX自动提供了一个WEB页面来给你来改变这些配置信息。 二、准备工作JMX是一份规范，SUN依据这个规范在JDK（1.3、1.4、5.0）提供了JMX接口。而根据这

3、个接口的实现则有很多种，比如Weblogic的JMX实现、MX4J、JBoss的JMX实现。在SUN自己也实现了一份，不过在JDK1.4之前，这件JMX实现（一些JAR包）是可选的，你得去它的网站上下载。JDK5.0则内嵌了进来，安装JDK5.0就可以开发基于JMX的代码了。但JDK5.0并非包含所有SUN的关于JMX的代码，有一些工具类是排除在JDK5.0之外的。下面根据所使用的JDK版本情况，谈一谈开发环境的准备。去SUN网站下载SUN的JMX实现，共两个ZIP文件，下载网址：。如果在DOS下用命令行开发，则把这五个JAR包加入到classpath系统变量中。如果你用Eclipse开发，则

4、把JAR包加入到项目属性的Libratries（库）引用中。JDK5.0的jrelibrt.jar已经包含了jmxri.jar、jmxremote.jar、rmissl.jar三个包的代码。如果你用到jmxtools.jar、jmxremote_optional.jar的类，则需要将这两个类加入到classpath或Eclipse的项目库引用中。3、我使用的开发环境：JDK5.0 Eclipse3.2。注：因为用到jmxtools.jar中的HtmlAdaptorServer类，所以将此包加入到项目库引用中。jmxremote_optional.jar暂时不用到，不管它。三、HelloWorl

5、d实例1、Hello是一个需要被管理的类（普通类）java 代码1. packagecom.sunhill.jmx; 2. publicclassHelloimplementsHelloMBean 3. privateStringname; 4. publicStringgetName() 5. returnname; 6. publicvoidsetName(Stringname) 7. this.name=name; 8. publicvoidprintHello() 9. System.out.println(HelloWorld,+name); 10. publicvoidprintH

6、ello(StringwhoName) 11. System.out.println(Hello,+whoName); 2、要管理Hello则必须创建一个相应MBean，如下：java 代码1. packagecom.sunhill.jmx; 2. publicinterfaceHelloMBean 3. publicStringgetName(); 4. publicvoidsetName(Stringname); 5. publicvoidprintHello(); 6. publicvoidprintHello(StringwhoName); 说明：包含在MBean中方法都将是可以被管理

7、的。MBean起名是有规范的，就是原类名后加上MBean字样。3、创建一个Agent类java 代码1. packagecom.sunhill.jmx; 2. importjava.lang.management.ManagementFactory; 3. importjavax.management.MBeanServer; 4. importjavax.management.ObjectName; 5. m.HtmlAdaptorServer; 6. publicclassHelloAgent 7. publicstaticvoidmain(Stringargs)throwsExcepti

8、on 8. /MBeanServerserver=MBeanServerFactory.createMBeanServer(); 9. MBeanServerserver=ManagementFactory.getPlatformMBeanServer(); 10. ObjectNamehelloName=newObjectName(chengang:name=HelloWorld); 11. server.registerMBean(newHello(),helloName); 12. ObjectNameadapterName=newObjectName( 13. HelloAgent:n

9、ame=htmladapter,port=8082); 14. HtmlAdaptorServeradapter=newHtmlAdaptorServer(); 15. server.registerMBean(adapter,adapterName); 16. adapter.start(); 17. System.out.println(start.); 说明： 先创建了一个MBeanServer，用来做MBean的容器 将Hello这个类注入到MBeanServer中，注入需要创建一个ObjectName类 创建一个AdaptorServer，这个类将决定MBean的管理界面，这里用最普

10、通的Html型界面。AdaptorServer其实也是一个MBean。 chengang:name=HelloWorld的名字是有一定规则的，格式为：“域名:name=MBean名称”，域名和MBean名称都可以任意取。 4、运行HelloAgent，然后打开网页：http:/localhost:8082/,看效果!五、总结在实际系统中我们可以把name变成决定数库链接池的变量，这样我就可以对系统的运行参数进行实现的监控和配置（管理）。而且也可以对一些方法（如printHello）进行远程调用了。JMX一步步来2、JMX简介 一、JMX简介JMX是一种JAVA的正式规范，它主要目的是让程序且有

11、被管理的功能，那么怎么理解所谓的“被管理”呢？试想你开发了一个软件（如网站），它是在小时不简断运行的，那么你可能会想要“监控”这个软件的运行情况，比如收到了多少数据，有多少人登录等等。或者你又想“配置”这个软件，比如现在访问人数比较多，你想把数据连接池设置得大一些。当然，你也许会专门为这些管理来开发软件，但如果你借助JMX，则会发现创建这样的管理程序是如此简单。因为你无需为管理程序来开发界面，已经有通用的JMX管理软件，如MC4J，或者是用一般都附带提供的HTML网页来管理，你要做的仅仅是将自己要被管理和监控类的按照JMX规范修改一下即可。中间件软件WebLogic的管理页面就是基于JMX开发

12、的，而JBoss则整个系统都基于JMX构架。下面将JMX的一些概念，从JMX规范转帖如下：二、JMX构架中的各层及相关的组件1. 工具层（Instrumentation Level）(a) MBeans（标准的，动态的，开放的和模型MBeans）(b) 通知模型：Notification、NotificationListener等类(c) MBean元数据类：Attribute、Opreator等类 2. 代理层（Agent Level）(a) MBean Server(b) 代理服务。如前一篇的HtmlAdaptorServer等。 MBean中有getter和setter的就是属性，如前一

13、篇的Hello类中Name。如果只有getter则表示该属性只读。一共有四种MBean，如下：1. 标准MBeans（Standard MBeans）设计和实现是最简单的，这类MBean使用自己的方法名作为管理接口； 2. 动态MBeans（Dynamic MBeans）必须实现一个指定的接口，由于动态MBeans在运行期间暴露它们的管理接口，因此更为灵活； 3. 开放MBeans（Open MBeans）属于动态MBeans，这类MBean依靠基础数据类型来实现通用管理，并为友情用户进行自我声明； 4. 模型MBeans（Model MBeans）同样也是动态MBeans，这类MBeans是

14、完全可配置的，在运行期间进行自我声明；它们为资源动态工具提供一个一般性的，有默认行为的MBeans类。 在前一篇中的Hello、HelloMBean就是一个标准MBeans（Standard MBeans）。后面接下来的几篇，我们会继续介绍其他几种MBean。JMX一步步来3、Notification的使用 一、简介Mbean之间的通信是必不可少的，Notification就起到了在Mbean之间沟通桥梁的作用。JMX notification 由四部分组成： Notification 这个相当于一个信息包，封装了需要传递的信息 Notification broadcaster这相当于一个广播

15、器，把消息广播出去 Notification listerner这是一个监听器，用于监听广播出来的Notification消息 Notification filter这是一个过滤器，过滤掉不需要的Notification消息 Notification broadcaster不需要我们实现，JMX的内部已经有了。Notification filter一般也很少用。下面的例子主要用到了Notification、Notification listerner二、实例在第一篇的Hello中有一个printHello(String whoName)方法，意思根据碰到的是谁来打招呼，比如：Jack从对面走过

16、来，说：“hi”我们回之以礼，说：“Hello, jack”首先这需要Jack先说一个hi（相应一个操作方法），然后他说的话封装成声波（相当Notification消息包）传递出去。然后我们还要给Jakc装上一个监听器（Hello的耳朵？_），这个监听器将捕捉到Jack的声波语音包，并进行相应处理，即说“Hello, jack”。好，我们看看如何实现的：1、Jack类及其相应的MBean我们把Jack写成一个MBean，如下：java 代码1. importjavax.management.Notification; 2. importjavax.management.Notification

17、BroadcasterSupport; 3. publicclassJackextendsNotificationBroadcasterSupportimplementsJackMBean 4. privateintseq=0; 5. publicvoidhi() 6. Notificationn=newNotification(/创建一个信息包 7. jack.hi,/给这个Notification起个名称 8. this,/由谁发出的Notification 9. +seq,/一系列通知中的序列号,可以设任意数值 10. System.currentTimeMillis(),/发出时间 1

18、1. Jack);/发出的消息文本 12. /发出去 13. sendNotification(n); 说明： 必需继承NotificationBroadcasterSupport 此类只有一个hi方法，方法只有两句：创建一个Notification消息包，然后将包发出去 如果你还要在消息包上附加其他数据，Notification还有一个setUserData方法可供使用 2、接下来是他的MBeanjava 代码1. publicinterfaceJackMBean 2. publicvoidhi(); 3、创建一个Listener，监听到的Notification消息包将由此类负责处理。ja

19、va 代码1. importjavax.management.NotificationListener; 2. publicclassHelloListenerimplementsNotificationListener 3. publicvoidhandleNotification(Notificationn,Objecthandback) 4. System.out.println(type=+n.getType(); 5. System.out.println(source=+n.getSource(); 6. System.out.println(seq=+n.getSequenceN

20、umber(); 7. System.out.println(sendtime=+n.getTimeStamp(); 8. System.out.println(message=+n.getMessage(); 9. if(handback!=null) 10. if(handbackinstanceofHello) 11. Hellohello=(Hello)handback; 12. hello.printHello(n.getMessage(); 4、修改HelloAgent如下：java 代码1. importjavax.management.MBeanServer; 2. impor

21、tjavax.management.MBeanServerFactory; 3. importjavax.management.ObjectName; 4. importm.HtmlAdaptorServer; 5. publicclassHelloAgent 6. publicstaticvoidmain(Stringargs)throwsException 7. MBeanServerserver=MBeanServerFactory.createMBeanServer(); 8. ObjectNamehelloName=newObjectName(chengang:name=HelloW

22、orld); 9. Hellohello=newHello(); 10. server.registerMBean(hello,helloName); 11. ObjectNameadapterName=newObjectName(HelloAgent:name=htmladapter,port=8082); 12. HtmlAdaptorServeradapter=newHtmlAdaptorServer(); 13. server.registerMBean(adapter,adapterName); 14. Jackjack=newJack();/重点 15. server.regist

23、erMBean(jack,newObjectName(HelloAgent:name=jack);/重点 16. jack.addNotificationListener(newHelloListener(),null,hello);/重点 17. adapter.start(); 18. System.out.println(start.); 三、运行1、先运行HelloAgent启动服务，再打开浏览器输入网址：http:/localhost:8082/2、进入“name=jack”项，然后单击“hi”按钮来执行它。四、总结Notification和Java的事件模型是一样的，另外如果你买了

24、Eclipse从入门到精通，你会发现第22.4节也使用了和Notification和Java的事件模型相同的设计方式。Notification在我们的实际项目中也用到了，象我们现在的给移动做的项目中（基于JMX实现)，分散在各地方的工作站的日志，就是通过Notification方式，把每条产生的日志封装在Notification中实时发回主控服务器的。有机会我会发这一系统的关于日志的设计方案写一下，它实现了对各地工作站的集中的、实时的监控，非常实用。JMX一步步来4、动态MBean：DynamicMBean 关键字: JMX 一、前言动态MBean是在运行期才定义它的属性和方法，也就是说它有什

25、么属性和方法是可以动态改变的。动态MBean主要利用一些辅助类（构造函数类MBeanConstructorInfo、属性类MBeanAttributeInfo、方法类MBeanOperationInfo）来完成这个功能，所有的动态MBean必须实现DynamicMBean接口。DynamicMBean写好后，使用方法和第一篇文章中普通的MBean一样。给出一个动态MBean的实例，这个实例最初动态构了一个Name属性及一个print方法，当我们执行它的print方法之后，又给此MBean新增了一个print1方法。实例的代码如下：二、实例1、HelloDynamic类java 代码1. imp

26、ortjava.lang.reflect.Constructor; 2. importjava.util.Iterator; 3. e; 4. importjavax.management.AttributeList; 5. importjavax.management.DynamicMBean; 6. importjavax.management.MBeanAttributeInfo; 7. importjavax.management.MBeanConstructorInfo; 8. importjavax.management.MBeanException; 9. importjavax

27、.management.MBeanInfo; 10. importjavax.management.MBeanNotificationInfo; 11. importjavax.management.MBeanOperationInfo; 12. importjavax.management.MBeanParameterInfo; 13. importjavax.management.ReflectionException; 14. *authorSunnyPeng 15. *authorchangebyChen.Gang,addafeaturefordynamicaddoperation 1

28、6. *version1.0 17. publicclassHelloDynamicimplementsDynamicMBean 18. /这是我们的属性名称 19. privateStringname; 20. privateMBeanInfomBeanInfo=null; 21. privateStringclassName; 22. privateStringdescription; 23. privateMBeanAttributeInfoattributes; 24. privateMBeanConstructorInfoconstructors; 25. privateMBeanO

29、perationInfooperations; 26. MBeanNotificationInfomBeanNotificationInfoArray; 27. publicHelloDynamic() 28. init(); 29. buildDynamicMBean(); 30. privatevoidinit() 31. className=this.getClass().getName(); 32. description=SimpleimplementationofadynamicMBean.; 33. attributes=newMBeanAttributeInfo1; 34. c

30、onstructors=newMBeanConstructorInfo1; 35. operations=newMBeanOperationInfo1; 36. mBeanNotificationInfoArray=newMBeanNotificationInfo0; 37. privatevoidbuildDynamicMBean() 38. /设定构造函数 39. Constructorthisconstructors=this.getClass().getConstructors(); 40. constructors0=newMBeanConstructorInfo(HelloDyna

31、mic():ConstructsaHelloDynamicobject,thisconstructors0); 41. /设定一个属性 42. attributes0=newMBeanAttributeInfo(Name,java.lang.String,Name:namestring.,true,true,false); 43. /operatemethod我们的操作方法是print 44. MBeanParameterInfoparams=null;/无参数 45. operations0=newMBeanOperationInfo(print,print():printthename,p

32、arams,void,MBeanOperationInfo.INFO); 46. mBeanInfo=newMBeanInfo(className,description,attributes,constructors,operations,mBeanNotificationInfoArray); 47. /动态增加一个print1方法 48. privatevoiddynamicAddOperation() 49. init(); 50. operations=newMBeanOperationInfo2;/设定数组为两个 51. buildDynamicMBean(); 52. opera

33、tions1=newMBeanOperationInfo(print1,print1():printthename,null,void,MBeanOperationInfo.INFO); 53. mBeanInfo=newMBeanInfo(className,description,attributes,constructors,operations,mBeanNotificationInfoArray); 54. publicObjectgetAttribute(Stringattribute_name) 55. if(attribute_name!=null) 56. returnnul

34、l; 57. if(attribute_name.equals(Name) 58. returnname; 59. returnnull; 60. publicvoidsetAttribute(Attributeattribute) 61. if(attribute=null) 62. return; 63. StringName=attribute.getName(); 64. Objectvalue=attribute.getValue(); 65. try 66. if(Name.equals(Name) 67. /ifnullvalue,tryandseeifthesetterretu

35、rnsanyexception 68. if(value=null) 69. name=null; 70. /ifnonnullvalue,makesureitisassignabletotheattribute 71. elseif(Class.forName(java.lang.String).isAssignableFrom(value.getClass() 72. name=(String)value; 73. catch(Exceptione) 74. e.printStackTrace(); 75. publicAttributeListgetAttributes(Stringat

36、tributeNames) 76. if(attributeNames=null) 77. returnnull; 78. AttributeListresultList=newAttributeList(); 79. /ifattributeNamesisempty,returnanemptyresultlist 80. if(attributeNames.length=0) 81. returnresultList; 82. for(inti=0;iattributeNames.length;i+) 83. try 84. Objectvalue=getAttribute(attribut

37、eNamesi); 85. resultList.add(newAttribute(attributeNamesi,value); 86. catch(Exceptione) 87. e.printStackTrace(); 88. returnresultList; 89. publicAttributeListsetAttributes(AttributeListattributes) 90. if(attributes=null) 91. returnnull; 92. AttributeListresultList=newAttributeList(); 93. /ifattribut

38、eNamesisempty,nothingmoretodo 94. if(attributes.isEmpty() 95. returnresultList; 96. /foreachattribute,trytosetitandaddtotheresultlistifsuccessfull 97. for(Iteratori=attributes.iterator();i.hasNext();) 98. Attributeattr=(Attribute)i.next(); 99. try 100. setAttribute(attr); 101. Stringname=attr.getName(); 102. Objectvalue=getAttribute(name); 103. resultList.add(newAttribute(name,value); 104. catch(Exceptione) 105. e.printStackTrace(); 106.