无法在 Spring Boot 应用程序中设置 hystrix 仪表板

Question

我正在尝试为我的 java spring boot 应用程序设置一个 hystrix 仪表板。启动应用程序后，我在控制台中收到代理打开消息，但没有任何反应。

Proxy opening connection to: http://localhost:9083/actuator/hystrix.stream

在仪表板中显示正在加载...并且没有显示任何内容...请参阅底部附加的图片。

此外，当我在浏览器中点击此 url http://localhost:9083/actuator/hystrix.stream 时，不会显示任何数据，只是不断的空 ping。喜欢
平：
平：
平：
...

我所做的代码更改是

@RequestMapping(value = "/elasticsearch/{numberOfInstances}/{name}", method = RequestMethod.GET)
    public void ingestMip4DataToES(@PathVariable("numberOfInstances") int numberOfInstances,
            @PathVariable("name") String name) {

        if(numberOfInstances > 1) {
            List<IdentifiableType> identifiableTypes = generateMultipleInstancesOfMip4Data(numberOfInstances, name);
            if(!identifiableTypes.isEmpty()) {
                dumpBulkMip4DataToES(identifiableTypes);                
            }
        } else {
            IdentifiableType identifiableType = generateSingleInstanceOfMip4Data(name);
            if(identifiableType != null) {
                dumpMip4DataToES(identifiableType);             
            }
        }
    }
@HystrixCommand(fallbackMethod = "fallbackForMip4SingleDataGeneration")
    private IdentifiableType generateSingleInstanceOfMip4Data(String name) {
        String url = GENERATOR_URL + name;

        ResponseEntity<IdentifiableType> response = restTemplate.getForEntity(url, IdentifiableType.class);
        return response.getBody();
    }

private IdentifiableType fallbackForMip4SingleDataGeneration() {
        logger.info("Calling fallback method for mip4 data generation as request to service failed.");
        return null;
    }

在主类中包含必需的注释。

@SpringBootApplication
//@EnableDiscoveryClient
@EnableCircuitBreaker
@EnableHystrixDashboard
public class InsaneMip4ElasticSearchApplication {

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

资源文件包含以下条目

management.endpoints.web.exposure.include=*
management.endpoints.web.exposure.include=hystrix.stream
management.endpoints.jmx.exposure.include=*
management.endpoint.health.show-details=ALWAYS
management.endpoint.shutdown.enabled=true

并且为 pom 文件创建了以下条目

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
</dependency>

Hystrix 仪表板如下所示

Answer 1

由于我的配置错误，仪表板是空的。 HystrixCommand 应该附加到使用 RequestMapping 注释的方法上。这是因为 Hystrix 监控 api 端点。

因此，进行以下更改使事情对我有用。

@HystrixCommand(fallbackMethod = "fallbackForMip4DataGeneration")
    @RequestMapping(value = "/elasticsearch/{numberOfInstances}/{name}", method = RequestMethod.GET)
    public void ingestMip4DataToES(@PathVariable("numberOfInstances") int numberOfInstances,
            @PathVariable("name") String name) {

        if(numberOfInstances > 1) {
            List<IdentifiableType> identifiableTypes = generateMultipleInstancesOfMip4Data(numberOfInstances, name);
            if(!identifiableTypes.isEmpty()) {
                dumpBulkMip4DataToES(identifiableTypes);                
            }
        } else {
            IdentifiableType identifiableType = generateSingleInstanceOfMip4Data(name);
            if(identifiableType != null) {
                dumpMip4DataToES(identifiableType);             
            }
        }
    }

    private void fallbackForMip4DataGeneration(int numberOfInstances, String name) {
        logger.info("Calling fallback method for mip4 data generation as request to service failed.");
    }

如您所见，现在 @HystrixCommand 注释应用于 ingestMip4DataToES() 方法，因为该方法具有 @RequestMapping 注释。之前将@HystrixCommand 应用于 generateSingleInstanceOfMip4Data() 方法是不正确的。

现在，当我拨打 http://localhost:9083/mip4/elasticsearch/1/CUnitType 时，我可以在 hystrix 仪表板上看到该呼叫的实时监控。

如果使用 Springboot 2 (2.0.2.RELEASE) 进行监控，请记住通过http://host:port/hystrix 访问仪表板并在 url 中应用http://host:port/actuator/hystrix.stream。

Answer 2

请将@HystrixCommand(fallbackMethod = "fallbackForMip4SingleDataGeneration") 添加到您的@RequestMapping 并尝试多次访问@RequestMapping url。一旦你访问了你想要的@RequestMapping url，然后去 hystrix.stream，你会找到必要的信息。