Java Language
JMX

Wprowadzenie

Prosty przykład z platformą MBean Server

Załóżmy, że mamy serwer, który rejestruje nowych użytkowników i wita ich z pewną wiadomością. I chcemy monitorować ten serwer i zmienić niektóre z jego parametrów.

Po pierwsze, potrzebujemy interfejsu z naszymi metodami monitorowania i kontroli

public interface UserCounterMBean {
    long getSleepTime();

    void setSleepTime(long sleepTime);

    int getUserCount();

    void setUserCount(int userCount);

    String getGreetingString();

    void setGreetingString(String greetingString);

    void stop();
}

I kilka prostych implementacji, które pozwolą nam zobaczyć, jak to działa i jak na to wpływamy

public class UserCounter implements UserCounterMBean, Runnable {
    private AtomicLong sleepTime = new AtomicLong(10000);
    private AtomicInteger userCount = new AtomicInteger(0);
    private AtomicReference<String> greetingString = new AtomicReference<>("welcome");
    private AtomicBoolean interrupted = new AtomicBoolean(false);

    @Override
    public long getSleepTime() {
        return sleepTime.get();
    }

    @Override
    public void setSleepTime(long sleepTime) {
        this.sleepTime.set(sleepTime);
    }

    @Override
    public int getUserCount() {
        return userCount.get();
    }

    @Override
    public void setUserCount(int userCount) {
        this.userCount.set(userCount);
    }

    @Override
    public String getGreetingString() {
        return greetingString.get();
    }

    @Override
    public void setGreetingString(String greetingString) {
        this.greetingString.set(greetingString);
    }

    @Override
    public void stop() {
        this.interrupted.set(true);
    }

    @Override
    public void run() {
        while (!interrupted.get()) {
            try {
                System.out.printf("User %d, %s%n", userCount.incrementAndGet(), greetingString.get());
                Thread.sleep(sleepTime.get());
            } catch (InterruptedException ignored) {
            }
        }
    }
}

Dla prostego przykładu z zarządzaniem lokalnym lub zdalnym musimy zarejestrować nasz komponent MBean:

import javax.management.InstanceAlreadyExistsException;
import javax.management.MBeanRegistrationException;
import javax.management.MBeanServer;
import javax.management.MalformedObjectNameException;
import javax.management.NotCompliantMBeanException;
import javax.management.ObjectName;
import java.lang.management.ManagementFactory;

public class Main {
    public static void main(String[] args) throws MalformedObjectNameException, NotCompliantMBeanException, InstanceAlreadyExistsException, MBeanRegistrationException, InterruptedException {
        final UserCounter userCounter = new UserCounter();
        final MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
        final ObjectName objectName = new ObjectName("ServerManager:type=UserCounter");
        mBeanServer.registerMBean(userCounter, objectName);

        final Thread thread = new Thread(userCounter);
        thread.start();
        thread.join();
    }
}

Następnie możemy uruchomić naszą aplikację i połączyć się z nią za pomocą jConsole, który można znaleźć w $JAVA_HOME/bin . Najpierw musimy znaleźć nasz lokalny proces Java za pomocą naszej aplikacji

następnie przejdź do zakładki MBeans i znajdź ten komponent MBean, którego użyliśmy w naszej klasie Main jako ObjectName (w powyższym przykładzie to ServerManager ). W sekcji Attributes możemy zobaczyć atrybuty. Jeśli podasz tylko metodę get, atrybut będzie czytelny, ale nie do zapisu. Jeśli podasz zarówno metody get, jak i set, atrybut będzie czytelny i zapisywalny.

Określone metody można wywoływać w sekcji Operations .

Jeśli chcesz mieć możliwość korzystania ze zdalnego zarządzania, potrzebujesz dodatkowych parametrów JVM, takich jak:

-Dcom.sun.management.jmxremote=true //true by default
-Dcom.sun.management.jmxremote.port=36006 
-Dcom.sun.management.jmxremote.authenticate=false 
-Dcom.sun.management.jmxremote.ssl=false

Parametry te można znaleźć w rozdziale 2 przewodników JMX . Następnie będziesz mógł połączyć się z aplikacją za pomocą jConsole zdalnie za pomocą jconsole host:port lub z podaniem host:port lub service:jmx:rmi:///jndi/rmi://hostName:portNum/jmxrmi w GUI jConsole.

Przydatne linki:

• Przewodniki JMX
• Najlepsze praktyki JMX