CSS圆角

package jmx;

/**
* 接口命名规则：xxxMBean
* 实现类：xxx
*/
public interface HelloMBean {

public void setName(String name);

public String getName();

public void print();

public void addName();
}

package jmx;

public class Hello implements HelloMBean {
private String name = "";

public Hello() {

}

@Override
public String getName() {
return name;
}

@Override
public void print() {
System.out.println("Hello, " + name + "!");
}

@Override
public void setName(String name) {
this.name = name;
}

@Override
public void addName() {
this.name = "zml";

}

}

package jmx;

import java.rmi.registry.LocateRegistry;

import javax.management.InstanceAlreadyExistsException;
import javax.management.InstanceNotFoundException;
import javax.management.IntrospectionException;
import javax.management.MBeanRegistrationException;
import javax.management.MBeanServer;
import javax.management.MBeanServerFactory;
import javax.management.MalformedObjectNameException;
import javax.management.NotCompliantMBeanException;
import javax.management.ObjectName;
import javax.management.ReflectionException;
import javax.management.remote.JMXConnectorServer;
import javax.management.remote.JMXConnectorServerFactory;
import javax.management.remote.JMXServiceURL;

public class JmxBeanDemo {

/**
* localhost:9998
* -Dcom.sun.management.jmxremote.port=9998
-Dcom.sun.management.jmxremote.ssl=false
-Dcom.sun.management.jmxremote.authenticate=false
*/
public static void main(String[] args)
throws InstanceAlreadyExistsException, MBeanRegistrationException,
NotCompliantMBeanException, MalformedObjectNameException,
NullPointerException, InterruptedException, IntrospectionException, InstanceNotFoundException, ReflectionException {
//		MBeanServer server = ManagementFactory.getPlatformMBeanServer();
//
//		ObjectName objectName = new ObjectName("jmx:type=hello");
//
//		server.registerMBean(new Hello(), objectName);
//
//		MBeanInfo meanInfo = server.getMBeanInfo(objectName);

try {
String DOMAIN = "localhost";
MBeanServer server = MBeanServerFactory.createMBeanServer(DOMAIN);
server.registerMBean(new Hello(), new ObjectName("jmx:type=hello"));
JMXServiceURL url = new JMXServiceURL("rmi", null, 9998, "/jndi/rmi://localhost:" + 1099 + "/zml");
// start()和stop()来启动和停止 JMXConnectorServer

//得到存储jmx用户信息的文件
//            String userFile =context.getRealPath("/")+"/Web-INF/classes/"+Constants.JMX_USERS_FILE;
//            //创建authenticator并且初始化RMI服务器
//            Map<string> env = new HashMap<string>();
//            env.put("jmx.remote.x.password.file", userFile);
//            env = null;
JMXConnectorServer jmxServer = JMXConnectorServerFactory.newJMXConnectorServer(url, null, server);
//service:jmx:rmi://localhost:9589/jndi/rmi://localhost:1099/zml
//service:jmx:rmi:///jndi/rmi://localhost:1099/zml
System.out.println(url);
// 在RMI上注册
LocateRegistry.createRegistry(1099);

jmxServer.start();

} catch (Exception e) {
e.printStackTrace();
}

Thread.sleep(Long.MAX_VALUE);

}

}

package jmx;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;

import javax.management.MBeanServerConnection;
import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXServiceURL;

public class JMXProxyTest {
public static void main(String[] args) {
JMXWrapper jmxWrapper = new JMXWrapper(HelloMBean.class,
"jmx:type=hello");
HelloMBean mbean = (HelloMBean) jmxWrapper.getProxy();
mbean.addName();
mbean.print();
}

}

class JMXInvokerHandler implements InvocationHandler {
private String name;

private MBeanServerConnection mbsc = null;

public JMXInvokerHandler(String name) {
this.name = name;
}

private MBeanServerConnection getMBeanServerConnection() {
if(null == mbsc){
JMXServiceURL url = null;
JMXConnector jmxc = null;
try {
url = new JMXServiceURL(
"service:jmx:rmi://localhost/jndi/rmi://localhost:1099/zml");
jmxc = JMXConnectorFactory.connect(url, null);
mbsc = jmxc.getMBeanServerConnection();
} catch (Exception e) {
e.printStackTrace();
}
}
return mbsc;
}

public Object invoke(Object proxy, Method method, Object[] args)
throws Throwable {
MBeanServerConnection connection = getMBeanServerConnection();
ObjectName objectName = new ObjectName(name);
String operationName = method.getName();
Class classes[] = method.getParameterTypes();
String[] signature = new String[classes.length];
for (int i = 0; i < signature.length; i++) {
signature[i] = classes[i].getName();
}
Object object = connection.invoke(objectName, operationName, args,
signature);
return object;
}
}

class JMXWrapper {
private Class fInterface;
private String name;
private JMXInvokerHandler handler;

public JMXWrapper(Class interfaces, String name) {
this.fInterface = interfaces;
this.name = name;
}

public Object getProxy() {
handler = new JMXInvokerHandler(name);
Object object = Proxy.newProxyInstance(fInterface.getClassLoader(),
new Class[] { fInterface }, handler);
return object;
}

}