모니터링

이 페이지의 내용

명령 모니터링

클러스터 모니터링
연결 풀 모니터링

운전자 는 JMX 를 사용하여 운전자 의 다양한 측면을 모니터 할 수 있는 MXBean을 만듭니다.

드라이버는 단일 유형인 ConnectionPoolStatisticsMBean 의 MXBean 인스턴스를 생성합니다. 드라이버는 연결하는 각 서버에 대해 하나의 ConnectionPoolStatisticsMBean 인스턴스를 등록합니다. 예를 들어, 복제본 세트에 연결되면 드라이버는 복제본 세트의 숨겨지지 않은 각 멤버에 대한 인스턴스를 생성합니다.

각 MXBean 인스턴스 는 도메인과 명명된 속성 설정하다 으로 구성된 고유한 객체 이름을 사용하여 등록해야 합니다. 운전자 에 의해 생성된 모든 MXBean 인스턴스는 도메인 org.mongodb.driver 에 있습니다. ConnectionPoolStatisticsMBean 인스턴스에는 다음과 같은 속성이 있습니다.

clusterId: 클라이언트가 생성한 고유 식별자로, 애플리케이션 에 동일한 MongoDB 서버 배포서버 에 연결된 여러 MongoClient 인스턴스가 있는 상황에서 객체 이름의 고유성을 보장하는 데 필요합니다.
host: 서버의 호스트 이름
port: 서버 가 수신 대기 중인 포트
minSize: 유휴 멤버 및 사용 중인 멤버를 포함하여 풀의 최소 허용 크기입니다.
maxSize: 유휴 멤버와 사용 중인 멤버를 포함하여 풀의 최대 허용 크기입니다.
size: 유휴 멤버와 사용 중인 멤버를 포함한 풀의 현재 크기
checkedOutCount: 현재 사용 중인 연결의 현재 수

JMX 연결 풀 모니터링은 기본적으로 비활성화되어 있습니다. 활성화하려면 MongoClientSettings 인스턴스를 생성할 때 com.mongodb.management.JMXConnectionPoolListener 인스턴스를 추가합니다.

val settings: MongoClientSettings =
        MongoClientSettings.builder()
        .applyToConnectionPoolSettings((builder: ConnectionPoolSettings.Builder) => builder.addConnectionPoolListener(new JMXConnectionPoolListener()))
        .build()

명령 모니터링

운전자 는 명령 모니터링 사양을 구현하여 명령이 시작될 때와 성공 또는 실패할 때 애플리케이션 에 알림을 보낼 수 있습니다.

애플리케이션 은 CommandListener 인터페이스를 구현 하는 클래스의 인스턴스로 MongoClientSettings 인스턴스 를 구성하여 명령 리스너를 MongoClient 에 등록합니다. 다음 예시 는 CommandListener 인터페이스의 간단한 구현 입니다.

case class TestCommandListener() extends CommandListener {
  override def commandStarted(event: CommandStartedEvent): Unit = {
    println(s"""Sent command '${event.getCommandName}:${event.getCommand.get(event.getCommandName)}'
         | with id ${event.getRequestId} to database '${event.getDatabaseName}'
         | on connection '${event.getConnectionDescription.getConnectionId}' to server
         | '${event.getConnectionDescription.getServerAddress}'""".stripMargin)
  }
  override def commandSucceeded(event: CommandSucceededEvent): Unit = {
    println(s"""Successfully executed command '${event.getCommandName}}'
               | with id ${event.getRequestId}
               | on connection '${event.getConnectionDescription.getConnectionId}' to server
               | '${event.getConnectionDescription.getServerAddress}'""".stripMargin)
  }
  override def commandFailed(event: CommandFailedEvent): Unit = {
    println(s"""Failed execution of command '${event.getCommandName}}'
               | with id ${event.getRequestId}
               | on connection '${event.getConnectionDescription.getConnectionId}' to server
               | '${event.getConnectionDescription.getServerAddress}
               | with exception '${event.getThrowable}'""".stripMargin)
  }
}

다음 예시 에서는 TestCommandListener 인스턴스 로 구성된 MongoClientSettings 인스턴스 를 만듭니다.

val settings: MongoClientSettings = MongoClientSettings.builder()
        .addCommandListener(TestCommandListener())
        .build()
val client: MongoClient = MongoClient(settings)

이러한 옵션으로 구성된 MongoClient 는 각 명령을 MongoDB 서버 로 보내기 전에 System.out 에 메시지를 인쇄하고, 각 명령이 성공적인 완료되거나 실패하면 다른 메시지를 인쇄합니다.

클러스터 모니터링

운전자 는 SDAM 모니터링 사양을 구현하여 운전자 가 연결된 MongoDB cluster 의 토폴로지 변경을 감지하면 애플리케이션 에 알림을 보낼 수 있습니다.

애플리케이션은 ClusterListener, ServerListener 또는 ServerMonitorListener 인터페이스를 구현하는 클래스의 인스턴스로 MongoClientSettings 를 구성하여 MongoClient 에 리스너를 등록합니다.

다음 코드는 클러스터 리스너를 생성하는 방법을 보여줍니다.

case class TestClusterListener(readPreference: ReadPreference) extends ClusterListener {
  var isWritable: Boolean = false
  var isReadable: Boolean = false
  override def clusterOpening(event: ClusterOpeningEvent): Unit =
    println(s"Cluster with unique client identifier ${event.getClusterId} opening")
  override def clusterClosed(event: ClusterClosedEvent): Unit =
    println(s"Cluster with unique client identifier ${event.getClusterId} closed")
  override def clusterDescriptionChanged(event: ClusterDescriptionChangedEvent): Unit = {
    if (!isWritable) {
      if (event.getNewDescription.hasWritableServer) {
        isWritable = true
        println("Writable server available!")
      }
    } else {
      if (!event.getNewDescription.hasWritableServer) {
        isWritable = false
        println("No writable server available!")
      }
    }
    if (!isReadable) {
      if (event.getNewDescription.hasReadableServer(readPreference)) {
        isReadable = true
        println("Readable server available!")
      }
    } else {
      if (!event.getNewDescription.hasReadableServer(readPreference)) {
        isReadable = false
        println("No readable server available!")
      }
    }
  }
}

다음 예시 에서는 TestClusterListener 인스턴스 로 구성된 MongoClientSettings 인스턴스 를 만듭니다.

val settings: MongoClientSettings = MongoClientSettings.builder()
        .applyToClusterSettings((builder: ClusterSettings.Builder) =>
                builder.addClusterListener(TestClusterListener(ReadPreference.secondary())))
        .build()
val client: MongoClient = MongoClient(settings)

이러한 옵션으로 구성된 MongoClient 는 이러한 옵션으로 MongoClient 가 생성되고 해당 MongoClient 가 닫힐 때 System.out 에 메시지를 인쇄합니다. 또한 클라이언트 가 다음 상태 중 하나에 들어가면 메시지를 인쇄합니다.

쓰기를 허용하는 사용 가능한 서버가 있습니다.
쓰기를 허용할 가용 서버 가 없는 경우
구성된 ReadPreference
서버 ReadPreference

연결 풀 모니터링

이 드라이버는 연결 풀 관련 이벤트의 모니터링을 지원합니다.

애플리케이션은 ConnectionPoolListener 인터페이스를 구현하는 클래스의 인스턴스로 MongoClientSettings 를 구성하여 MongoClient 에 리스너를 등록합니다.

다음 코드는 연결 풀 리스너를 생성하는 방법을 보여줍니다.

case class TestConnectionPoolListener() extends ConnectionPoolListener {
  override def connectionPoolOpened(event: ConnectionPoolOpenedEvent): Unit = println(event)
  override def connectionPoolClosed(event: ConnectionPoolClosedEvent): Unit = println(event)
  override def connectionCheckedOut(event: ConnectionCheckedOutEvent): Unit = println(event)
  override def connectionCheckedIn(event: ConnectionCheckedInEvent): Unit = println(event)
  override def waitQueueEntered(event: ConnectionPoolWaitQueueEnteredEvent): Unit = println(event)
  override def waitQueueExited(event: ConnectionPoolWaitQueueExitedEvent): Unit = println(event)
  override def connectionAdded(event: ConnectionAddedEvent): Unit = println(event)
  override def connectionRemoved(event: ConnectionRemovedEvent): Unit = println(event)
}

다음 예시 에서는 TestConnectionPoolListener 인스턴스 로 구성된 MongoClientSettings 인스턴스 를 만듭니다.

val settings: MongoClientSettings = MongoClientSettings.builder()
        .applyToConnectionPoolSettings((builder: ConnectionPoolSettings.Builder) =>
                builder.addConnectionPoolListener(TestConnectionPoolListener()))
        .build()
val client: MongoClient = MongoClient(settings)

이러한 옵션으로 구성된 MongoClient 는 MongoClient가 연결된 각 MongoDB 서버 의 각 연결 풀 관련 이벤트 에 대해 System.out 에 메시지를 인쇄합니다.

돌아가기

로깅

Observables