JMX 와 RMI를 이용한 원격지 자원관리 (1) JMX패키지..

StartTomcatBean.java

package jmx;


public interface StartTomcatMBean{

    public abstract int tomcatStart();

    public abstract int tomcatStop();
}


======================================================================

StartTomcat.java


package jmx;
import java.io.*;

public class StartTomcat
    implements StartTomcatMBean
{

    public StartTomcat()
    {
    }

    public int tomcatStart()
    {
        int code = 0;
        try
        {
            Runtime r = Runtime.getRuntime();
            Process pro = r.exec("E:\\apache-tomcat-5.5.27\\bin\\startup.bat");
            BufferedReader stdInput = new BufferedReader(new InputStreamReader(pro.getInputStream()));
            String s = null;
            System.out.println("shutdown Tomcat....");
            while((s = stdInput.readLine()) != null)
                System.out.println(s);
            code = pro.waitFor();
        }
        catch(Exception e)
        {
            System.out.println("tmocatStart_error...");
            e.printStackTrace();
        }
        return code;
    }

    public int tomcatStop()
    {
        int code = 0;
        try
        {
            Runtime r = Runtime.getRuntime();
            Process pro = r.exec("E:\\apache-tomcat-5.5.27\\bin\\shutdown.bat");
            BufferedReader stdInput = new BufferedReader(new InputStreamReader(pro.getInputStream()));
            for(String s = null; (s = stdInput.readLine()) != null;)
                System.out.println(s);

            code = pro.waitFor();
        }
        catch(Exception exception) { }
        return code;
    }
}

======================================================================

jmxAgent.java



package jmx;

import java.io.PrintStream;
import java.rmi.registry.LocateRegistry;
import java.util.HashMap;
import java.util.Map;
import javax.management.*;
import javax.management.remote.*;

// Referenced classes of package jmx:
//            StartTomcat

public class jmxAgent
{

    public jmxAgent()
    {
        server = null;
        server = MBeanServerFactory.createMBeanServer("JmxAgent");
        intiAgent();
    }

    public void intiAgent()
    {
        JMXServiceURL serviceUrl = null;
        ObjectName connectorName = null;
        ObjectName WeblogicControlMBeanName = null;
        try
        {
            LocateRegistry.createRegistry(7777);
            serviceUrl = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:7777/server");
            Map environment = new HashMap();
            environment.put("jmx.remote.jndi.rebind", "true");
            connectorName = new ObjectName("JmxAgent:name=RmiConnector");
            WeblogicControlMBeanName = new ObjectName("JmxAgent:name=tomcatControl");
            JMXConnectorServer connector = JMXConnectorServerFactory.newJMXConnectorServer(serviceUrl, environment, server);
            server.registerMBean(new StartTomcat(), WeblogicControlMBeanName);
            server.registerMBean(connector, connectorName);
            connector.start();
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
    }

    public static void main(String args[])
    {
        new jmxAgent();
        System.out.println("jmxAgent Start.........");
    }

    private MBeanServer server;
}

======================================================================

Client.java

package jmx;

import java.io.IOException;
import java.io.PrintStream;
import java.net.MalformedURLException;
import javax.management.*;
import javax.management.remote.*;

// Referenced classes of package jmx:
//            StartTomcatMBean

public class Client
{

    public Client()
    {
    }

    public void foo()
        throws MalformedObjectNameException, NullPointerException, IOException
    {
        ObjectName resourceControlMBeanName = null;
        java.util.Map creationEnvirnoment = null;
        java.util.Map connectionEnvironment = null;
        try
        {
            resourceControlMBeanName = new ObjectName("JmxAgent:name=tomcatControl");
            JMXServiceURL serviceURL = new JMXServiceURL("service:jmx:rmi:///jndi/rmi://localhost:7777/server");
            JMXConnector cntor = JMXConnectorFactory.newJMXConnector(serviceURL, creationEnvirnoment);
            cntor.connect(connectionEnvironment);
            javax.management.MBeanServerConnection mbsc = cntor.getMBeanServerConnection();
            StartTomcatMBean resource = (StartTomcatMBean)MBeanServerInvocationHandler.newProxyInstance(mbsc, resourceControlMBeanName, StartTomcatMBean.class, false);
            resource.tomcatStart();
            cntor.close();
        }
        catch(RuntimeErrorException e)
        {
            System.out.println((new StringBuilder("Error 1--->")).append(e).toString());
            e.printStackTrace();
        }
        catch(MalformedURLException e)
        {
            System.out.println((new StringBuilder("Error 2--->")).append(e).toString());
            e.printStackTrace();
        }
    }
}

[출처] 오라클자바커뮤니티 - http://www.oraclejavanew.kr/bbs/board.php?bo_table=LecJavaNet&wr_id=37

• JAVA
• ORACLE
• iPhone/Android
• .NET
• 표준웹/HTML5
• 채용/취업무료교육
• 초보자(재학생)코스

Spring3.X, MyBatis, Hibernate실무과정	총	5일	35시간		10-21
자바초보에서안드로이드까지	총	18일	54시간		10-22
JAVA&WEB프레임워크실무과정	총	33일	99시간		10-24
Spring3.X, MyBatis, Hibernate실무과정	총	12일	36시간		10-25
자바초보에서안드로이드까지	총	8일	56시간		10-26
Spring3.X, MyBatis, Hibernate실무과정	총	5일	35시간		10-27
JAVA&WEB프레임워크실무과정	총	14일	98시간		10-27