JMX与commons-modeler (by quqi99)

import java.util.ArrayList;





import java.util.List;





public class Router {	





List ipList=new ArrayList();	





public void addIP(String ip){		





System.out.println("addIP:"+ip);	





ipList.add(ip);	





}	





public void deleteIP(String ip){	





System.out.println("deleteIP:"+ip);		





ipList.remove(ip);	





}	





public  String[] getIPS(){	





if (ipList.isEmpty()) return new String[0];		





String[] x =(String[])ipList.toArray(new String[ipList.size()]);	





for(int i =0; i<x.length;i++){	





System.out.println(x[i]);		





}	





return x;	





}





}

public interface StandardRouterMBean {
      





String[] getIPS();	





void deleteIP(String ip);	





void addIP(String ip);





}

public class StandardRouter implements StandardRouterMBean{
      

public class	ModelMBeanUtils {
      





public static void CreateModlerMBean(MBeanServer server) {	





final  boolean READABLE = true;		





final  boolean WRITABLE = true;	





final  boolean BOOLEAN  = true;    





// 构造 IPS 只读属性信息





Descriptor descr1 = new DescriptorSupport();	





descr1.setField("name", "IPS");	





descr1.setField("descriptorType", "attribute");	





descr1.setField("displayName", "IP addresses");	





descr1.setField("getMethod", "getIPS");    		





ModelMBeanAttributeInfo IPSInfo = 		





new ModelMBeanAttributeInfo(	





"IPS",                        // 属性名		





String[].class.getName(),        //属性类型		





"IP addresses.",        // 属性描述文字		





READABLE, !WRITABLE, !BOOLEAN,  // 读写		





descr1                         // 属性描述子	





);	





//构造 getIPS 属性获取操作信息		





Descriptor descr6 = new DescriptorSupport();	





descr6.setField("name", "getIPS");	





descr6.setField("descriptorType", "operation");	





descr6.setField("role", "operation");		





MBeanParameterInfo [] deleteIPParams2 = null;	





ModelMBeanOperationInfo getIPSInfo = 			





new ModelMBeanOperationInfo(			





"getIPS",                   // 操作名	





"get all IP address.",    //描述		





deleteIPParams2,                         // 参数		





String[].class.getName(),      // 返回类型		





MBeanOperationInfo.ACTION,      // 作用			





descr6                        // 操作描述子		





);		





// 构造addIP操作信息		





Descriptor descr2 = new DescriptorSupport();	





descr2.setField("name", "deleteIP");	





descr2.setField("descriptorType", "operation");		





//构造参数信息		





MBeanParameterInfo [] deleteIPParams = new MBeanParameterInfo [1];	





deleteIPParams[0] = new MBeanParameterInfo("ip",String.class.getName(),"ip");





ModelMBeanOperationInfo deleteIPInfo = 		





new ModelMBeanOperationInfo(	





"deleteIP",                





"delete a Ip from router.",	





deleteIPParams,               





"void",      // return type		





MBeanOperationInfo.ACTION,    





descr2                        			





);	





// 构造addIP操作信息		





Descriptor descr3 = new DescriptorSupport();	





descr3.setField("name", "addIP");	





descr3.setField("descriptorType", "operation");		





ModelMBeanOperationInfo addIPInfo = 		





new ModelMBeanOperationInfo(		





"addIP",              





"add a Ip into router.",		





deleteIPParams,               





"void",      // return type		





MBeanOperationInfo.ACTION,    	





descr3      		





);      





//构造MBean信息		





Descriptor descr4 = new DescriptorSupport();	





descr4.setField("name", "Router");		





descr4.setField("descriptorType", "mbean");	





// create ModelMBeanInfo     	





ModelMBeanInfo info = new ModelMBeanInfoSupport(	





RequiredModelMBean.class.getName(),  // MBean类		





"Router",                           // description		





new ModelMBeanAttributeInfo[] {      // 所有的属性信息	





IPSInfo			





},		





null,                                // 所有的构造函数信息	





new ModelMBeanOperationInfo[] {      // 所有的操作信息	





getIPSInfo,			 





addIPInfo,			 





deleteIPInfo		 





},		  





null,                                // 所有的通知信息		





descr4                               //MBean 描述子		





);		





try {		 





// create and configure model mbean		 





RequiredModelMBean model = new RequiredModelMBean();       





//设置被管理的资源类对象		





model.setManagedResource(new Router(), "ObjectReference");		





model.setModelMBeanInfo(info);		





server.registerMBean(model, 





new ObjectName("jmx_work:name=ModelRouter"));      





}		





catch (Exception e) {		





e.printStackTrace();	





}    	





}





}

import javax.management.*;





public class RemoteHttpAgent {	





public static void main(String[] args) {	





try {		





// 创建MBean Server对象	





MBeanServer server = 		





MBeanServerFactory.createMBeanServer();	





// 创建标准MBean的对象名，对象名是MBean Server标识MBean的方法		





ObjectName name = 				





new ObjectName("jmx_work:name=StandardRouter");		





// 向MBean Server注册标准MBean		





server.registerMBean(new StandardRouter(), name);		





//创建 模型MBean并注册			





ModelMBeanUtils.CreateModlerMBean(server);		





//创建适配器对象	





com.sun.jdmk.comm.HtmlAdaptorServer adaptor =		





new com.sun.jdmk.comm.HtmlAdaptorServer();	





//向Bean Server注册适配器对象		





server.registerMBean(adaptor, 





new ObjectName("adaptor:protocol=HTTP"));





//设置并启动HTTP适配器服务		





adaptor.setPort(8080);		





adaptor.start();		





}catch (Exception e) {	





e.printStackTrace();	





}	





}





}

import javax.management.*;





public class LocalAgent {	





MBeanServer server= null;	





public  LocalAgent(){		





try {		





// 创建MBean Server对象		





server = MBeanServerFactory.createMBeanServer();	





// 创建标准MBean的对象名，对象名是MBean Server标识MBean的方法		





ObjectName name = 			





new ObjectName("jmx_work:name=StandardRouter");		





// 向MBean Server注册标准MBean		





server.registerMBean(new StandardRouter(), name);			





//创建 模型MBean并注册			





ModelMBeanUtils.CreateModlerMBean(server);	





}	





catch (Exception e) {	





e.printStackTrace();	





}	





}	





public void printIPS(ObjectName on){		





// Create the new object and associated MBean	





String signature[] = new String[0];	





Object params[] = new Object[0];		





String[] ips;			





try {			





ips = (String[]) server.getAttribute(on, "IPS");	





for(int i =0;i<ips.length;i++){			





System.out.println("LocalAgent:printIPS:"+ips[i]);		





}			





}catch (Exception e) 





{			





// TODO Auto-generated catch block		





e.printStackTrace();		





}		





}





public void addIP(ObjectName on,String ip){		





// Create the new object and associated MBean	





String signature[] = new String[]{"java.lang.String"};  //定义了参数的类型	





Object params[] = new Object[]{ip};   //定义了参数的值		





try {		





server.invoke(on, "addIP",params, signature);	





} catch (Exception e) {	





// TODO Auto-generated catch block		





e.printStackTrace();		





}			





}	





public void deleteIP(ObjectName on,String ip){	





// Create the new object and associated MBean	





String signature[] = new String[]{"java.lang.String"};  //定义了参数的类型	





Object params[] = new Object[]{ip};   //定义了参数的值		





try {		





server.invoke(on, "deleteIP",params, signature);	





} catch (Exception e) {	





// TODO Auto-generated catch block	





e.printStackTrace();		





}				





}





public static void main(String[] args) {	





LocalAgent la= new LocalAgent();		





try {		





ObjectName on = new ObjectName("jmx_work:name=StandardRouter");		





la.addIP(on, "10.1.34.123");		





la.printIPS(on);			





la.deleteIP(on, "10.1.34.123");		





la.printIPS(on);		





}





catch (MalformedObjectNameException e) {	





// TODO Auto-generated catch block		





e.printStackTrace();	





}





catch (NullPointerException e) {	





// TODO Auto-generated catch block	





e.printStackTrace();		





}	





}





}

<?xml version="1.0"?>





<!DOCTYPE mbeans-descriptors PUBLIC 





"-//Apache Software Foundation//DTD Model MBeans Configuration File" 





"http://jakarta.apache.org/commons/dtds/mbeans-descriptors.dtd">





<mbeans-descriptors> 





<mbean       name="ModelerRouter"   





description="modeler Router MBean"  





domain="jmx_work"               





group="Modeler"                





type="Router">   





<attribute   name="IPS"       





description="get All IP Adress"        





type="java.lang.String[]"           





writeable="false"         





getMethod="getIPS"/>  





<operation   name="addIP"   





description="add a ip into the router" 





impact="ACTION"         





returnType="void">   





<parameter	name="ip"        





description="the Ip will be added."   





type="java.lang.String"/>   





</operation>  





<operation   name="deleteIP"     





description="remove a ip from the router"    





impact="ACTION"       





returnType="void">   





<parameter	name="ip"   





description="the Ip will be deleted."     





type="java.lang.String"/>  





</operation>  





</mbean>  





</mbeans-descriptors>

public class RemoteHttpAgent {	





private  MBeanServer mserver;	





private  Registry  mregistry;	





private  HtmlAdaptorServer madaptor=null;	





public RemoteHttpAgent(int port){	





mserver=createServer();		





mregistry=createRegistry();		





createHttpAdaptor(port);	





}





private   Registry createRegistry() {	





Registry registry=null;			





try {			





URL url = this.getClass().getResource("/mbean-descriptors.xml");	





InputStream stream = url.openStream();		





Registry.loadRegistry(stream);			





stream.close();			





registry = Registry.getRegistry();		





} 





catch (Throwable t) {	





t.printStackTrace(System.out);	





System.exit(1);		





}		





return (registry);





}	





private MBeanServer createServer() {		





if (mserver == null) {			





try {				





mserver = Registry.getServer();			 





}





catch (Throwable t) {	





t.printStackTrace(System.out);		





System.exit(1);			 





}		  





}		  





return (mserver);	 





}





private void createHttpAdaptor(int port){	





madaptor =	new HtmlAdaptorServer();	 





//向Bean Server注册适配器对象	 





try {	





mserver.registerMBean(madaptor, 	





new ObjectName("adaptor:protocol=HTTP"));	 





} 





catch (Exception e) {
      





e.printStackTrace();	





}	





madaptor.setPort(port);	  





madaptor.start();	





}	





public static void main(String[] args){	





RemoteHttpAgent rha = new RemoteHttpAgent(80);		





try {		





rha.createMBean("ModelerRouter");		





} 





catch (Exception e) {	





e.printStackTrace();





}	





}	





public  void createMBean(String mname)	





throws Exception {		





ManagedBean managed = mregistry.findManagedBean(mname);		





if (managed == null) {			





Exception e = new Exception("ManagedBean is not found with "+mname);		





throw new MBeanException(e);		





}		





String domain = managed.getDomain();		





if (domain == null)			





domain = mserver.getDefaultDomain();		





Router r = new Router();		





ModelMBean mbean = managed.createMBean(r);		





ObjectName oname = new ObjectName(domain+":name=" + managed.getName());		





mserver.registerMBean(mbean, oname);	





}





}

public ModelMBeanOperationInfo createOperationInfo() {  





if (info != null)          





return (info);       





ParameterInfo params[] = getSignature();      





MBeanParameterInfo parameters[] =        





new MBeanParameterInfo[params.length];  





for (int i = 0; i < params.length; i++) 





parameters[i] = params[i].createParameterInfo();     





int impact = ModelMBeanOperationInfo.UNKNOWN;      





if ("ACTION".equals(getImpact()))        





impact = ModelMBeanOperationInfo.ACTION;     





else if ("ACTION_INFO".equals(getImpact()))      





impact = ModelMBeanOperationInfo.ACTION_INFO;  





else if ("INFO".equals(getImpact()))          





impact = ModelMBeanOperationInfo.INFO;    





info = new ModelMBeanOperationInfo          





(getName(), getDescription(), parameters,  





getReturnType(), impact);  





Descriptor descriptor = info.getDescriptor();      





descriptor.removeField("class");





//       descriptor.setField("role", getRole());   





descriptor.setField("role","operation" );    





System.out.println(""+descriptor.toString());   





info.setDescriptor(descriptor);     





return (info);  





}