通過JMX監控Jboss資料庫連接池

　　import java.util.Properties;

　　import java.util.Set;

　　import javax.management.MBeanInfo;

　　import javax.management.MBeanOperationInfo;

　　import javax.management.MBeanParameterInfo;

　　import javax.management.ObjectInstance;

　　import javax.management.ObjectName;

　　import javax.naming.InitialContext;

　　import org.jboss.jmx.adaptor.rmi.RMIAdaptor;

　　public class DataSourceManger {

　　public static void main(String[] args) {

　　// TODO 自動生成方法存根

　　try {

　　// Get RMIAdaptor Object

　　Properties pro = new Properties();

　　pro.setProperty("java.naming.factory.initial",

　　"org.jnp.interfaces.NamingContextFactory");

　　pro.setProperty("java.naming.provider.url", "jnp://localhost:1099");

　　pro.setProperty("java.naming.factory.url.pkgs",

　　"org.jboss.naming:org.jnp.interfaces");

　　InitialContext ic = new InitialContext(pro);

　　RMIAdaptor server = (RMIAdaptor) ic.lookup("jmx/rmi/RMIAdaptor");

　　ObjectName name = new ObjectName(

　　"jboss.jca:name=jdbc/baosigpo,service=ManagedConnectionPool");

　　ObjectName lname = new ObjectName(

　　"jboss.jca:name=jdbc/baosigpo,service=LocalTxCM");

　　String AvailableConnectionCount = server.getAttribute(name,

　　"AvailableConnectionCount").toString();

　　System.out.println("===========avlide============"

　　 AvailableConnectionCount);

　　String InUseConnectionCount = server.getAttribute(name,

　　"InUseConnectionCount").toString();

　　System.out.println("===========InUseConnectionCount============"

　　 InUseConnectionCount);

　　String ConnectionCreatedCount = server.getAttribute(name,

　　"ConnectionCreatedCount").toString();

　　System.out.println("===========ConnectionCreatedCount============"

　　 ConnectionCreatedCount);

　　String ConnectionDestroyedCount = server.getAttribute(name,

　　"ConnectionDestroyedCount").toString();

　　System.out

　　.println("===========ConnectionDestroyedCount============"

　　 ConnectionDestroyedCount);

　　ConnectionDestroyedCount = server.getAttribute(name,

　　"ConnectionDestroyedCount").toString();

　　System.out

　　.println("===========ConnectionDestroyedCount============"

　　 ConnectionDestroyedCount);

　　String[] argTypes = new String[0];

　　int i = 0;

　　i = Integer.parseInt(AvailableConnectionCount);

　　Object opReturn = null;

　　if (i < 1) {//監控可用連接數.

　　StringBuffer sb = new StringBuffer();

　　sb.append("oper before DataSource Pool info : rn");

　　sb.append(" AvailableConnectionCount="

　　 AvailableConnectionCount);

　　sb.append(" InUseConnectionCount=" InUseConnectionCount);

　　sb.append(" ConnectionCreatedCount="

　　 ConnectionCreatedCount);

　　sb.append(" ConnectionDestroyedCount="

　　 ConnectionDestroyedCount);

　　sb.append("rn");

　　//opReturn = server.invoke(name, "flush", argTypes, argTypes);

　　/*調用mbean的方法釋放連接 begin 本實現方法對應jboss3.2.3

　　對於jboss4以後的版本只需調用

　　//opReturn = server.invoke(name, "flush", argTypes, argTypes);

　　**/

　　opReturn = server.invoke(name, "stop", argTypes, argTypes);

　　opReturn = server.invoke(name, "start", argTypes, argTypes);

　　opReturn = server.invoke(lname, "stop", argTypes, argTypes);

　　opReturn = server.invoke(lname, "start", argTypes, argTypes);

　　/*調用mbean的方法釋放連接 end

　　**/

　　AvailableConnectionCount = server.getAttribute(name,

　　"AvailableConnectionCount").toString();

　　InUseConnectionCount = server.getAttribute(name,

　　"InUseConnectionCount").toString();

　　ConnectionCreatedCount = server.getAttribute(name,

　　"ConnectionCreatedCount").toString();

　　ConnectionDestroyedCount = server.getAttribute(name,

　　"ConnectionDestroyedCount").toString();

　　ConnectionDestroyedCount = server.getAttribute(name,

　　"ConnectionDestroyedCount").toString();

　　sb.append("oper afer DataSource Pool info :rn");

　　sb.append(" AvailableConnectionCount="

　　 AvailableConnectionCount);

　　sb.append(" InUseConnectionCount=" InUseConnectionCount);

　　sb.append(" ConnectionCreatedCount="

　　 ConnectionCreatedCount);

　　sb.append(" ConnectionDestroyedCount="

　　 ConnectionDestroyedCount);

　　//writeLog(sb.toString()); 操作日誌信息

　　System.out.println("===========op SUCCESS============");

　　}

　　} catch (Exception ex) {

　　ex.printStackTrace();

　　}

　　}

　　}