JMX와 모니터링 — 실행 중인 JVM을 원격으로 관찰하고 제어하는 방법

┌─────────────────────────────────────────┐
│  관리 도구 (JConsole, VisualVM, Grafana) │
│  ← JMX 클라이언트                        │
└──────────┬──────────────────────────────┘
           │ JMX Remote (RMI/JMXMP)
┌──────────▼──────────────────────────────┐
│  MBean Server                           │
│  ┌──────────┐ ┌──────────┐ ┌─────────┐ │
│  │ 플랫폼    │ │ 애플리케이션│ │ 프레임워크│ │
│  │ MXBean   │ │ MBean    │ │ MBean   │ │
│  └──────────┘ └──────────┘ └─────────┘ │
└─────────────────────────────────────────┘

import java.lang.management.*;

MemoryMXBean memoryBean = ManagementFactory.getMemoryMXBean();
MemoryUsage heap = memoryBean.getHeapMemoryUsage();
System.out.println("힙 사용량: " + heap.getUsed() / 1024 / 1024 + " MB");

ThreadMXBean threadBean = ManagementFactory.getThreadMXBean();
System.out.println("활성 스레드: " + threadBean.getThreadCount());
long[] deadlocked = threadBean.findDeadlockedThreads();
if (deadlocked != null) {
    System.out.println("데드락 감지! 스레드 수: " + deadlocked.length);
}

for (GarbageCollectorMXBean gc : ManagementFactory.getGarbageCollectorMXBeans()) {
    System.out.println(gc.getName() +
        " - 수집 횟수: " + gc.getCollectionCount() +
        ", 총 시간: " + gc.getCollectionTime() + " ms");
}

RuntimeMXBean runtime = ManagementFactory.getRuntimeMXBean();
System.out.println("JVM 가동 시간: " + runtime.getUptime() / 1000 + " 초");

// 1. MBean 인터페이스 정의 (이름 규칙: 클래스명 + "MBean")
public interface AppConfigMBean {
    // 속성 (getter/setter)
    int getMaxConnections();
    void setMaxConnections(int max);
    String getAppVersion();     // 읽기 전용 (setter 없음)

    // 오퍼레이션
    void resetStatistics();
    String getStatus();
}

// 2. 구현 클래스
public class AppConfig implements AppConfigMBean {
    private volatile int maxConnections = 10;
    private final String appVersion = "2.1.0";
    private final AtomicLong requestCount = new AtomicLong();

    @Override
    public int getMaxConnections() { return maxConnections; }

    @Override
    public void setMaxConnections(int max) {
        if (max < 1 || max > 100)
            throw new IllegalArgumentException("1~100 범위");
        this.maxConnections = max;
        System.out.println("maxConnections 변경: " + max);
    }

    @Override
    public String getAppVersion() { return appVersion; }

    @Override
    public void resetStatistics() {
        requestCount.set(0);
        System.out.println("통계 초기화됨");
    }

    @Override
    public String getStatus() {
        return "OK - 요청 수: " + requestCount.get();
    }

    // MBean 외부용 메서드
    public void incrementRequest() {
        requestCount.incrementAndGet();
    }
}

public class Application {
    public static void main(String[] args) throws Exception {
        // MBeanServer 획득
        MBeanServer mbs = ManagementFactory.getPlatformMBeanServer();

        // MBean 등록
        AppConfig config = new AppConfig();
        ObjectName name = new ObjectName("com.myapp:type=Config,name=main");
        mbs.registerMBean(config, name);

        System.out.println("MBean 등록 완료. JConsole로 접속하세요.");

        // 애플리케이션 실행 유지
        Thread.currentThread().join();
    }
}

// MXBean 인터페이스 (@MXBean 어노테이션 또는 이름에 MXBean 접미사)
@MXBean
public interface ServerStatsMXBean {
    ServerInfo getServerInfo(); // 커스텀 타입도 CompositeData로 자동 변환
    List<ConnectionInfo> getActiveConnections();
}

// 커스텀 타입 (record 또는 getter가 있는 클래스)
public record ServerInfo(String hostname, int port, long uptime) {}
public record ConnectionInfo(String clientIp, long connectedAt) {}

public class AppConfig extends NotificationBroadcasterSupport
        implements AppConfigMBean {

    private long sequenceNumber = 0;

    @Override
    public void setMaxConnections(int max) {
        int old = this.maxConnections;
        this.maxConnections = max;

        // 변경 알림 발송
        Notification notification = new AttributeChangeNotification(
            this,                              // 소스
            sequenceNumber++,                  // 시퀀스 번호
            System.currentTimeMillis(),        // 타임스탬프
            "maxConnections 변경됨",            // 메시지
            "maxConnections",                  // 속성명
            "int",                             // 타입
            old,                               // 이전 값
            max                                // 새 값
        );
        sendNotification(notification);
    }
}

// 알림 리스너 등록
mbs.addNotificationListener(name,
    (notification, handback) -> {
        System.out.println("알림 수신: " + notification.getMessage());
    },
    null,  // 필터 (null = 모두 수신)
    null   // handback
);

java \
  -Dcom.sun.management.jmxremote.port=9999 \
  -Dcom.sun.management.jmxremote.authenticate=false \
  -Dcom.sun.management.jmxremote.ssl=false \
  -jar myapp.jar

java \
  -Dcom.sun.management.jmxremote.port=9999 \
  -Dcom.sun.management.jmxremote.authenticate=true \
  -Dcom.sun.management.jmxremote.password.file=/path/jmxremote.password \
  -Dcom.sun.management.jmxremote.access.file=/path/jmxremote.access \
  -Dcom.sun.management.jmxremote.ssl=true \
  -Djavax.net.ssl.keyStore=/path/keystore.p12 \
  -Djavax.net.ssl.keyStorePassword=password \
  -jar myapp.jar

# jmxremote.access
admin readwrite
monitor readonly

# jmxremote.password
admin secretPassword
monitor readPassword

// JMX 클라이언트
String url = "service:jmx:rmi:///jndi/rmi://server:9999/jmxrmi";
JMXServiceURL serviceUrl = new JMXServiceURL(url);

Map<String, Object> env = new HashMap<>();
env.put(JMXConnector.CREDENTIALS,
    new String[]{"admin", "secretPassword"});

try (JMXConnector connector = JMXConnectorFactory.connect(serviceUrl, env)) {
    MBeanServerConnection mbsc = connector.getMBeanServerConnection();

    // 속성 읽기
    ObjectName configName = new ObjectName("com.myapp:type=Config,name=main");
    int maxConn = (int) mbsc.getAttribute(configName, "MaxConnections");

    // 오퍼레이션 호출
    mbsc.invoke(configName, "resetStatistics", null, null);

    // 속성 변경
    mbsc.setAttribute(configName,
        new Attribute("MaxConnections", 20));
}

jconsole                    # 로컬 JVM 자동 감지
jconsole server:9999        # 원격 접속

visualvm                    # 별도 설치 필요

# JMX Exporter를 Java Agent로 실행
java -javaagent:jmx_prometheus_javaagent.jar=8080:config.yml \
     -jar myapp.jar

# config.yml
rules:
  - pattern: 'java.lang<type=Memory><HeapMemoryUsage>used'
    name: jvm_memory_heap_used_bytes
    type: GAUGE
  - pattern: 'com.myapp<type=Config,name=main><>MaxConnections'
    name: myapp_max_connections
    type: GAUGE