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;
}
}