Docs Menu
Docs Home
/
언어
/
Scala
/
Scala
/
참조

모니터링

이 페이지의 내용

  • 명령 모니터링
  • 클러스터 모니터링
  • 연결 풀 모니터링

드라이버는 JMX 를 사용합니다.MXBean 생성 드라이버의 다양한 측면을 모니터링할 수 있습니다.

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

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

  • clusterId: 클라이언트가 생성한 고유 식별자로, 애플리케이션에 동일한 MongoDB Server 배포에 연결된 여러 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 Server로 보내기 전에 System.out 에 메시지를 인쇄하고, 각 명령이 성공적으로 완료되거나 실패하면 다른 메시지를 인쇄합니다.

클러스터 모니터링

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

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

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

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 Server의 각 연결 풀 관련 이벤트에 대해 System.out 에 메시지를 인쇄합니다.

돌아가기

로깅