@Timed не работает, несмотря на явную регистрацию TimedAspect - весенняя загрузка 2.1 - PullRequest
Новая
       16

@Timed не работает, несмотря на явную регистрацию TimedAspect - весенняя загрузка 2.1

0 голосов
/ 30 мая 2019

Мне нужно измерить метрики метода, используя микрометрическую аннотацию @Timed. Поскольку это не работает на произвольных методах; я добавил конфигурацию @TimedAspect явно в моей весенней конфигурации. Ссылались на этот пост для точной конфигурации Примечание: я попытался добавить отдельный класс конфигурации JUST для этого, а также включить компонент TimedAspect как часть моего существующего компонента конфигурации

Как измерить методы обслуживания с использованием пружинного чехла 2 и микрометра

Тем не менее, это, к сожалению, не работает. Bean регистрируется, и вызов из класса config проходит успешно при запуске. Нашел это во время отладки. Тем не менее, код в @Around никогда не выполняется. Ошибка не выдается; и я могу просматривать системные метрики по умолчанию в конечных точках / metrics и / prometheus.

Примечание. Это ПОСЛЕ ПОЛУЧЕНИЯ «метода», который несколько раз вызывается при выполнении бизнес-потока. Я знаю, что, вероятно, он не отображается в метриках, если метод вообще не вызывается

Версии: пружинный башмак 2.1.1, пружина 5.3, микрометр 1.1.4, исполнительный механизм 2.1

Перепробовал все, что происходит по следующим постам:

Как измерить методы обслуживания, используя пружинный чехол 2 и микрометр

https://github.com/izeye/sample-micrometer-spring-boot/tree/timed-annotation

https://github.com/micrometer-metrics/micrometer/issues/361

Обновление: Итак, проблема, похоже, возникает ТОЛЬКО, когда Timed находится в абстрактном методе, который вызывается через другой метод. Смог воспроизвести это на простом примере. Обратитесь к аннотации @Timed ("say_hello_example"). Он просто игнорируется и не появляется, когда я попадаю в конечную точку прометея.

Код: Абстрактный класс 

    public abstract class AbstractUtil {
    public abstract void sayhello();

    public void sayhellowithtimed(String passedVar) {
        System.out.println("Passed var =>"+passedVar);
        System.out.println("Calling abstract sayhello....");
        sayhello();

    }
}

Класс Impl 

    @Component
@Scope("prototype")
public class ExampleUtil extends AbstractUtil  {

    public static final String HELLO = "HELLO";

    @Timed("dirwatcher_handler")
    public void handleDirectoryWatcherChange(WatchEvent event){
        System.out.println("Event kind:" + event.kind() + ". File affected: " + event.context());
    }

    @Timed("say_hello_example")
    @Override
    public void sayhello() {
        System.out.println(HELLO);
        try {            Thread.sleep(1000);
        } catch (InterruptedException e) {              e.printStackTrace();
        }
    }
}

Простой класс реализации DirWatcher ... 

                package com.example;

            import org.springframework.beans.factory.annotation.Autowired;
            import org.springframework.beans.factory.annotation.Value;
            import org.springframework.boot.context.event.ApplicationStartedEvent;
            import org.springframework.context.ApplicationListener;
            import org.springframework.context.annotation.Scope;
            import org.springframework.context.event.ContextRefreshedEvent;
            import org.springframework.stereotype.Component;

            import java.io.IOException;
            import java.nio.file.*;

            @Component
            @Scope("prototype")
            public class StartDirWatcher implements ApplicationListener<ApplicationStartedEvent> {

                @Value("${directory.path:/apps}")
                public String directoryPath;

                @Autowired
                private ExampleUtil util;

                private void monitorDirectoryForChanges() throws IOException, InterruptedException {
                    WatchService watchService = FileSystems.getDefault().newWatchService();
                    Path path = Paths.get(directoryPath);
                    path.register(
                            watchService,
                            StandardWatchEventKinds.ENTRY_CREATE,
                            StandardWatchEventKinds.ENTRY_DELETE,
                            StandardWatchEventKinds.ENTRY_MODIFY);
                    WatchKey key;
                    while ((key = watchService.take()) != null) {
                        for (WatchEvent<?> event : key.pollEvents()) {
                            util.handleDirectoryWatcherChange(event);
                            util.sayhellowithtimed("GOD_OF_SMALL_THINGS_onAPPEvent");
                        }
                        key.reset();
                    }
                }

                @Override
                public void onApplicationEvent(ApplicationStartedEvent applicationStartedEvent) {
                    try {
                        monitorDirectoryForChanges();

                    } catch (Throwable e) {
                        System.err.println("ERROR!! "+e.getMessage());
                        e.printStackTrace();
                    }
                }
            }

Класс приложений Spring Boot 

package com.example;

import io.micrometer.core.aop.TimedAspect;
import io.micrometer.core.instrument.MeterRegistry;
import io.micrometer.prometheus.PrometheusMeterRegistry;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.actuate.autoconfigure.metrics.MeterRegistryCustomizer;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.EnableAspectJAutoProxy;

@EnableAspectJAutoProxy
@ComponentScan
@Configuration
@SpringBootApplication
public class ExampleStarter{

    @Bean
    MeterRegistryCustomizer<PrometheusMeterRegistry> metricsCommonTags() {
        return registry -> registry.config().commonTags("app.name", "example.app");
    }
    @Bean
    TimedAspect timedAspect(MeterRegistry reg) {
        return new TimedAspect(reg);
    }

    public static void main(String[] args) {
        SpringApplication.run(ExampleStarter.class, args);
    }

}

Основной файл pom.xml 

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<groupId>com.metrics.timed.example</groupId>
<artifactId>example-app</artifactId>
<version>1.0-SNAPSHOT</version>
<build>
    <plugins>
        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-compiler-plugin</artifactId>
            <configuration>
                <source>1.8</source>
                <target>1.8</target>
            </configuration>
        </plugin>
    </plugins>
</build>
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
        <version>2.1.1.RELEASE</version>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
        <version>2.1.1.RELEASE</version>
    </dependency>
    <dependency>
    <groupId>io.micrometer</groupId>
    <artifactId>micrometer-registry-prometheus</artifactId>
    <version>1.1.2</version>
</dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-aop</artifactId>
        <version>2.1.1.RELEASE</version>
    </dependency>
</dependencies>

...