Monitore seu sistema

Eventos de comando

Um evento de comando é um evento relacionado a um comando do banco de dados MongoDB. Alguns exemplos de comandos do banco de dados que produzem eventos de comando são find, insert, delete e count.

Para monitorar eventos de comando, crie uma classe que implemente a interface do CommandListener e registre uma instância dessa classe com sua instância do MongoClient .

Para obter mais informações sobre comandos do banco de dados MongoDB, consulte Comandos do banco de dados no manual do servidor MongoDB.

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();
}

Eventos de descoberta e monitoramento de servidores

Um evento de descoberta e monitoramento de servidor (SDAM) é um evento relacionado a uma alteração no estado da instância MongoDB ou cluster ao qual você conectou o driver.

O driver define nove eventos SDAM. O driver divide esses nove eventos entre três interfaces de ouvinte separadas, cada uma ouvindo três dos nove eventos. Aqui estão as três interfaces e os eventos que elas escutam:

• ClusterListener: topologiaeventos relacionados

• ServerListener: eventos relacionados a processos mongod ou mongos

• ServerMonitorListener: eventos relacionados ao batimento cardíaco

Para monitorar um tipo de evento SDAM, escreva uma classe que implemente uma das três interfaces anteriores e registre uma instância dessa classe com sua instância MongoClient.

Para obter uma descrição detalhada de cada evento SDAM no driver, consulte a Especificação de Monitoramento e Registro SDAM do MongoDB.

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();
}

Eventos do pool de conexões

Um evento do pool de conexões é um evento relacionado a um pool de conexões mantido pelo driver. Um pool de conexões é um conjunto de conexões TCP abertas que seu driver mantém com um sistema MongoDB. Os pools de conexão ajudam a reduzir o número de handshakes de rede que seu aplicativo precisa realizar com um sistema do MongoDB e podem ajudar seu aplicativo a ser executado mais rapidamente.

Para monitorar eventos do pool de conexões, escreva uma classe que implemente a interface ConnectionPoolListener e registre uma instância dessa classe com sua instância 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();
}

Suporte a JMX

Para habilitar o monitoramento do pool de conexões JMX, adicione uma instância da classe JMXConnectionPoolListener ao seu objeto MongoClient.

A classe JMXConnectionPoolListener executa as seguintes ações:

1. Cria instâncias de MXBean para cada processo do mongod ou mongos com o qual o driver mantém um pool de conexões

2. Registra estas instâncias MXBean com o servidor MBean da plataforma

Os MXBeans registrados no servidor MBean da plataforma têm as seguintes propriedades:

Todas as instâncias MXBean criadas pelo driver estão sob o domínio "org.mongodb.driver".

Para obter mais informações sobre os tópicos discutidos nesta subseção, consulte os seguintes recursos da Oracle:

• Documentação de Referência do Servidor MBean da Plataforma

• Documentação de MXBean

• Documentação do MBean

Exemplo de JMX e JConsole

O exemplo a seguir mostra como você pode monitorar os pools de conexão do driver usando JMX e JConsole. JConsole é uma ferramenta de monitoramento de GUI compatível com JMX que vem com a Java Platform.

O seguinte trecho de código adiciona um JMXConnectionPoolListener a uma instância do MongoClient. O código então pausa a execução para que você possa navegar até o JConsole e inspecionar seus pools de conexão.

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);
}

Após iniciar seu servidor, abra o JConsole executando o seguinte comando em seu terminal:

jconsole

Quando o JConsole estiver aberto, realize as seguintes ações na interface do usuário:

1. Selecione o processo Java que executa o código de exemplo anterior.

2. Clique em Insecure Connection na caixa de diálogo de aviso.

3. Clique na aba MBeans.

4. Inspecione os eventos do pool de conexões no domínio "org.mongodb.driver".

Quando você não quiser mais inspecionar seus pools de conexão no JConsole, execute as seguintes tarefas:

1. Sair do JConsole fechando a janela do JConsole.

2. Pare o programa Java executando o trecho de código anterior.

Para obter mais informações sobre JMX e JConsole, consulte os seguintes recursos da Oracle:

• Documentação do JConsole

• Guia de monitoramento e gerenciamento

Para mais informações sobre a JMXConnectionPoolListener classe , consulte a Documentação da API para JMXConnectionPoolListener.