jmx

jmx是java程序之间互为通信，rpc调用风格.应用场景:集群环境内快速度部署java 程序，可发布分析数据程序

package testplus2.game;

import java.util.Set;

import javax.management.ObjectName;
/**
 * jmx 服务接口 服务端与客户端
 * 
 * @author solq
 * */
public interface IJmxService {
	public void close();

	// /////////服务端部分//////////////
	
	/**
	 * 注册MBEAN
	 * */
	public void register(Object mbean);

	/**
	 * 启动jxm服务端
	 * */
	public void start();

	// /////////客户端部分//////////////
	/**
	 * 连接jxm服务端
	 * */
	public void connect();

	/**
	 * 获取mbean proxy
	 * @param clz 注意是接口
	 * */
	public <T> T getRpcProxy(Class<T> clz);
	/**
	 * 获取mbean proxy
	 * @param clz 注意是接口
	 * @param impClz 实现类
	 * */
	public <T> T getRpcProxy(Class<T> clz, Class<? extends T> impClz);
	/**
	 * 获取jxm服务端所有注册mbean 
	 * */
	public Set<ObjectName> getAllRegisterMBean();
}

package testplus2.game;

import java.io.IOException;
import java.rmi.registry.LocateRegistry;
import java.util.Set;

import javax.management.JMX;
import javax.management.MBeanServer;
import javax.management.MBeanServerConnection;
import javax.management.MBeanServerFactory;
import javax.management.ObjectName;
import javax.management.remote.JMXConnector;
import javax.management.remote.JMXConnectorFactory;
import javax.management.remote.JMXConnectorServer;
import javax.management.remote.JMXConnectorServerFactory;
import javax.management.remote.JMXServiceURL;

import com.sun.jdmk.comm.HtmlAdaptorServer;

/**
 * jmx 服务实现
 * 
 * @author solq
 * */
public class JmxService implements IJmxService {

	private boolean startServer;

	private String host;
	private int port;

	// server
	private MBeanServer mbeanServer;
	private JMXConnectorServer jmxConnectorServer;

	// client
	private JMXConnector jxmConnector;
	private MBeanServerConnection beanServerConnection;

	public JmxService(String host, int port) {
		this.host = host;
		this.port = port;
	}

	@Override
	public void register(Object obj) {
		initServer();
		try {
			ObjectName connectorName = new ObjectName(JxmUtli.getObjectName(obj
					.getClass()));
			mbeanServer.registerMBean(obj, connectorName);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	private void initServer() {
		if (mbeanServer == null) {
			mbeanServer = MBeanServerFactory.createMBeanServer();
		}
	}

	@Override
	public void start() {
		if (startServer) {
			System.out.println("已启动JMX :" + port);
			return;
		}
		this.startServer = true;
		initServer();
		try {

			// 启动server
			LocateRegistry.createRegistry(port);
			final JMXServiceURL url = new JMXServiceURL(
					"service:jmx:rmi://localhost/jndi/rmi://" + host + ":"
							+ port + "/jmxrmi");
			jmxConnectorServer = JMXConnectorServerFactory
					.newJMXConnectorServer(url, null, mbeanServer);
			jmxConnectorServer.start();

			// //创建适配器，用于能够通过浏览器访问MBean
			 HtmlAdaptorServer adapter = new HtmlAdaptorServer();
			 adapter.setPort(9797);
			 register(adapter);
			 adapter.start();
		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	@Override
	public void connect() {
		try {
			JMXServiceURL jmxServiceUrl = new JMXServiceURL(
					"service:jmx:rmi://localhost/jndi/rmi://" + host + ":"
							+ port + "/jmxrmi");
			JMXConnector connector = JMXConnectorFactory.connect(jmxServiceUrl);
			beanServerConnection = connector.getMBeanServerConnection();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	@Override
	public <T> T getRpcProxy(Class<T> clz) {
		return getRpcProxy(clz, clz);
	}

	@Override
	public <T> T getRpcProxy(Class<T> clz, Class<? extends T> impClz) {
		try {
			ObjectName hwName = new ObjectName(JxmUtli.getObjectName(impClz));
			return JMX.newMXBeanProxy(beanServerConnection, hwName, clz);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	@Override
	public void close() {
		if (jmxConnectorServer != null) {
			try {
				jmxConnectorServer.stop();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}

		if (jxmConnector != null) {
			try {
				jxmConnector.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

	@Override
	public Set<ObjectName> getAllRegisterMBean() {
		try {
			ObjectName filterName = new ObjectName("*:*");
			Set<ObjectName> objectNames = beanServerConnection.queryNames(
					filterName, null);
			return objectNames;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return null;
	}

	// getter
	public int getPort() {
		return port;
	}

	public String getHost() {
		return host;
	}

	public boolean isStartServer() {
		return startServer;
	}

	public MBeanServer getMbeanServer() {
		return mbeanServer;
	}

	public JMXConnectorServer getJmxConnectorServer() {
		return jmxConnectorServer;
	}

	public JMXConnector getJxmConnector() {
		return jxmConnector;
	}

	public MBeanServerConnection getBeanServerConnection() {
		return beanServerConnection;
	}

}

package testplus2.game;

public abstract class JxmUtli {

public static String getObjectName(Class<?> clz) {
	String name = clz.getName() + ":type=" + clz.getSimpleName();
	return name;
}

}

package testplus2.jmx;

import java.io.IOException;
import java.io.ObjectInputStream.GetField;
import java.rmi.registry.LocateRegistry;

import javax.management.InstanceAlreadyExistsException;
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.remote.JMXConnectorServer;
import javax.management.remote.JMXConnectorServerFactory;
import javax.management.remote.JMXServiceURL;

import testplus2.game.GamePlus;
import testplus2.game.GamePlusMBean;
import testplus2.game.JmxService;
import testplus2.game.JxmUtli;

public class TestJmxServer {
	private static int port = 5555;

	public static void main(String[] args) {
		test();
	} 
	static void test(){
		JmxService jmxService = new JmxService("localhost",port);
		//注册mbean 实例
		GamePlus gamePlus = new GamePlus();		
		jmxService.register(gamePlus);
		jmxService.start(); 
	}
}

package testplus2.jmx;

import java.util.Set;

import javax.management.MBeanServerConnection;
import javax.management.ObjectName;

import testplus2.game.GamePlus;
import testplus2.game.GamePlusMBean;
import testplus2.game.JmxService;

public class JmxClient {

	private static int port = 5555;

	public static void main(String args[]) throws Exception {
		test0();
	}

	private static void test0() throws Exception {

		JmxService jmxService = new JmxService("localhost",port);
		jmxService.connect();
		GamePlusMBean proxy = jmxService.getRpcProxy(GamePlusMBean.class,
				GamePlus.class);
		System.out.println(proxy.getAllConsoleMessage("abc"));

		Set<?> objectNames = jmxService.getAllRegisterMBean();

		for (Object name : objectNames) {
			ObjectName objName = (ObjectName) name;
			System.out
					.println("    Object Name: " + objName.getCanonicalName());
		}

		
		jmxService.close();
	}

}