배포 모니터링

명령 이벤트

명령 이벤트는 MongoDB 데이터베이스 명령어와 관련된 이벤트입니다. 명령 이벤트를 생성하는 데이터베이스 명령어의 몇 가지 예에는 find, insert, delete, count 등이 있습니다.

명령 이벤트를 모니터 하려면 CommandListener 인터페이스를 구현하는 클래스를 만들고 해당 클래스의 인스턴스 를 MongoClient 인스턴스 에 등록합니다.

MongoDB database 명령에 대한 자세한 내용은 MongoDB Server 매뉴얼의 데이터베이스 명령 을 참조하세요.

class CommandCounter implements CommandListener {
    private final Map<String, Integer> commands = new HashMap<String, Integer>();
    @Override
    public synchronized void commandSucceeded(final CommandSucceededEvent event) {
        String commandName = event.getCommandName();
        int count = commands.getOrDefault(commandName, 0);
        commands.put(commandName, count + 1);
        System.out.println(commands);
    }
    @Override
    public void commandFailed(final CommandFailedEvent event) {
        System.out.printf("Failed execution of command '%s' with id %s%n",
                event.getCommandName(),
                event.getRequestId());
    }
}

MongoClientSettings settings = MongoClientSettings.builder()
        .applyConnectionString(URI)
        .addCommandListener(new CommandCounter())
        .build();
try (MongoClient mongoClient = MongoClients.create(settings)) {
    MongoDatabase database = mongoClient.getDatabase(DATABASE);
    MongoCollection<Document> collection = database.getCollection(COLLECTION);
    // Run some commands to test the counter
    FindPublisher<Document> findPublisher1 = collection.find();
    FindPublisher<Document> findPublisher2 = collection.find();
    Flux.from(findPublisher1).blockLast();
    Flux.from(findPublisher2).blockLast();
}

{find=1}
{find=2}
{find=2, endSessions=1}

서버 검색 및 이벤트 모니터링하기

서버 검색 및 모니터링(SDAM) 이벤트란 드라이버를 연결한 MongoDB 인스턴스 혹은 클러스터의 상태 변경과 관련된 이벤트를 말합니다.

드라이버는 SDAM 이벤트 9개를 정의합니다. 드라이버는 이러한 이벤트 9개를 개별 리스너 인터페이스 3개로 나누고, 각 인터페이스는 이벤트 9개 중 이벤트 3개를 수신합니다. 다음은 인터페이스 3개와 해당 인터페이스가 수신하는 이벤트입니다.

• ClusterListener: 토폴로지-관련 이벤트

• ServerListenermongod 혹은 mongos 프로세스와 관련된 이벤트

• ServerMonitorListener: 하트비트 관련 이벤트

SDAM 이벤트 유형을 모니터링하려면 위의 인터페이스 3개 중 하나를 구현하는 클래스를 작성하고 해당 클래스의 인스턴스를 MongoClient 인스턴스에 등록합니다.

드라이버의 각 SDAM 이벤트에 대한 자세한 설명은 MongoDB SDAM 로깅 및 모니터링 사양을 참조하세요.

class IsWritable implements ClusterListener {
    private boolean isWritable;
    @Override
    public synchronized void clusterDescriptionChanged(final ClusterDescriptionChangedEvent event) {
        if (!isWritable) {
            if (event.getNewDescription().hasWritableServer()) {
                isWritable = true;
                System.out.println("Able to write to server");
            }
        } else if (!event.getNewDescription().hasWritableServer()) {
            isWritable = false;
            System.out.println("Unable to write to server");
        }
    }
}

MongoClientSettings settings = MongoClientSettings.builder()
        .applyConnectionString(URI)
        .applyToClusterSettings(builder ->
                builder.addClusterListener(new IsWritable()))
        .build();
try (MongoClient mongoClient = MongoClients.create(settings)) {
    MongoDatabase database = mongoClient.getDatabase(DATABASE);
    MongoCollection<Document> collection = database.getCollection(COLLECTION);
    // Run a command to trigger a ClusterDescriptionChangedEvent
    FindPublisher<Document> findPublisher = collection.find();
    Flux.from(findPublisher).blockLast();
}

Able to write to server

연결 풀 이벤트

연결 풀 이벤트 는 운전자 가 보유한 연결 풀 과 관련된 이벤트 입니다. 연결 풀 은 MongoDB deployment 에서 운전자 가 유지 관리하는 개방형 TCP 연결의 설정하다 입니다. 연결 풀은 애플리케이션 이 MongoDB deployment 를 사용하여 수행해야 하는 네트워크 핸드셰이크 횟수를 줄이고 애플리케이션 을 더 빠르게 실행 데 도움이 될 수 있습니다.

연결 풀 이벤트를 모니터링하려면 ConnectionPoolListener 인터페이스를 구현하는 클래스를 작성하고 해당 클래스의 인스턴스를 MongoClient 인스턴스에 등록합니다.

class ConnectionPoolLibrarian implements ConnectionPoolListener {
    @Override
    public void connectionCheckedOut(final ConnectionCheckedOutEvent event) {
        System.out.printf("Fetching the connection with id %s...%n",
                event.getConnectionId().getLocalValue());
    }
    @Override
    public void connectionCheckOutFailed(final ConnectionCheckOutFailedEvent event) {
        System.out.println("Something went wrong! Failed to checkout connection.");
    }
}

MongoClientSettings settings = MongoClientSettings.builder()
        .applyConnectionString(URI)
        .applyToClusterSettings(builder ->
                builder.addClusterListener(new IsWritable()))
        .build();
try (MongoClient mongoClient = MongoClients.create(settings)) {
    MongoDatabase database = mongoClient.getDatabase(DATABASE);
    MongoCollection<Document> collection = database.getCollection(COLLECTION);
    // Run a command to trigger a ClusterDescriptionChangedEvent
    FindPublisher<Document> findPublisher = collection.find();
    Flux.from(findPublisher).blockLast();
}

Let me get you the connection with id 21...

JMX 지원

JMX 연결 풀 모니터링을 활성화하려면 JMXConnectionPoolListener 클래스의 인스턴스를 MongoClient 객체에 추가합니다.

JMXConnectionPoolListener 클래스는 다음과 같은 작업을 수행합니다.

1. 운전자 가 다음을 사용하여 연결 풀 을 유지 관리하는 각 mongod 또는 mongos 프로세스 에 대해 MXBean 인스턴스를 생성합니다.

2. 이러한 MXBean 인스턴스를 플랫폼 MBean 서버 에 등록합니다.

플랫폼 MBean 서버에 등록된 MXBean은 다음과 같은 속성이 있습니다.

드라이버로 생성된 MXBean 인스턴스는 모두 "org.mongodb.driver" 도메인 아래에 있습니다.

이 하위 섹션에서 설명하는 주제에 대한 자세한 내용은 Oracle의 다음 리소스를 참조하세요.

• 플랫폼 MBean 서버 참조 문서

• MXBean 문서

• MBean 문서

JMX 및 JConsole 예시

다음 예시 는 JMX 및 JConsole 을 사용하여 드라이버의 연결 풀을 모니터 하는 방법을 보여줍니다. JConsole은 Java 플랫폼과 함께 제공되는 JMX 호환 GUI 모니터링 도구입니다.

다음 코드 스니펫은 MongoClient 인스턴스에 JMXConnectionPoolListener를 추가합니다. 그런 다음 코드는 실행을 일시 중지하므로 JConsole로 이동하여 연결 풀을 검사할 수 있습니다.

JMXConnectionPoolListener connectionPoolListener = new JMXConnectionPoolListener();
try (MongoClient mongoClient = MongoClients.create(URI)) {
    System.out.println("Navigate to JConsole to see your connection pools...");
    // Pauses the code execution so you can navigate to JConsole and inspect your connection pools
    Thread.sleep(Long.MAX_VALUE);
}

Navigate to JConsole to see your connection pools...

서버 를 시작한 후 터미널에서 다음 명령을 실행 하여 JConsole을 엽니다.

jconsole

JConsole이 열리면 GUI에서 다음 작업을 수행합니다.

1. 앞의 예시 코드를 실행하는 Java 프로세스를 선택합니다.

2. 경고 대화 상자에서 Insecure Connection 를 클릭합니다.

3. MBeans 탭을 클릭합니다.

4. "org.mongodb.driver" 도메인에서 연결 풀 이벤트를 검사합니다.

JConsole에서 연결 풀을 더 이상 검사하지 않으려면 다음 작업을 수행하세요.

1. JConsole 창 을 닫아 JConsole을 종료합니다.

2. 앞의 코드 스니펫을 실행 Java 프로그램을 중지합니다.

JMX 및 JConsole에 대한 자세한 내용은 Oracle의 다음 리소스를 참조하세요.

• JConsole 문서

• 모니터링 및 관리 가이드

클래스에대한 JMXConnectionPoolListener 자세한 내용은 JMXConnectionPoolListener에 대한 API 설명서를 참조하세요.