`

使用Hystrix守护应用(3)

阅读更多
监控HystrixCommand
除了隔离依赖服务的调用外,Hystrix还提供了近乎实时的监控,Hystrix会实时的,累加的记录所有关于HystrixCommand的执行信息,包括执行了每秒执行了多少请求,多少成功,多少失败等等,更多指标请查看:https://github.com/Netflix/Hystrix/wiki/Metrics-and-Monitoring
导出监控数据
有了这些指标,Netflix还提供了一个类库(hystrix-metrics-event-stream:https://github.com/Netflix/Hystrix/tree/master/hystrix-contrib/hystrix-metrics-event-stream)把这些指标信息以‘text/event-stream’的格式开放给外部使用,用法非常简单,首先,把hystrix-metrics-event-stream库添加到项目中:
dependencies {
    compile(
    		 ...
            'com.netflix.hystrix:hystrix-metrics-event-stream:1.3.9',
            ...
    )
}

然后,在web.xml中配置一个Servlet来获取Hystrix提供的数据:
<servlet>
        <description></description>
        <display-name>HystrixMetricsStreamServlet</display-name>
        <servlet-name>HystrixMetricsStreamServlet</servlet-name>
        <servlet-class>com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet</servlet-class>
    </servlet>

    <servlet-mapping>
        <servlet-name>HystrixMetricsStreamServlet</servlet-name>
        <url-pattern>/hystrix.stream</url-pattern>
    </servlet-mapping>
配置好,重新启动应用。访问http://hostname:port/appname/hystrix.stream, 可以看到如下的输出:
data: {"type":"HystrixCommand","name":"Address","group":"Address","currentTime":1393154954462,"isCircuitBreakerOpen":false,"errorPercentage":0,"errorCount":0,"requestCount":0,"rollingCountCollapsedRequests"......
系统会不断刷新以获取实时的数据。
Dashboard
从上面的输出可以看到,这样的纯字符输出可读性实在太差,运维人员很难从中就看出系统的当前状态,于是Netflix又开发了一个开源项目(Dashboard:https://github.com/Netflix/Hystrix/wiki/Dashboard)来可视化这些数据,帮助运维人员更直观的了解系统的当前状态,Dashboard使用起来非常方便,其就是一个Web项目,你只需要把war包(http://search.maven.org/#browse%7C1045347652)下载下来,放到一个Web容器(Tomcat,Jetty等)中即可。

启动WebContainer访问Dashboard主页,可以看到如下的界面:

填入上面获取hystrix.stream的URL,点击Monitor,即可看到实时的监控画面:

Dashboard主要展示了2类信息,一是HystrixCommand的执行情况,Hystrix Wiki上详细说明了图上的每个指标代表的含义:

二是线程池的状态,包括线程池名,大小,当前活跃线程说,最大活跃线程数,排队队列大小等。


Turbine
在复杂的分布式系统中,相同服务的结点经常需要部署上百甚至上千个,很多时候,运维人员希望能够把相同服务的节点状态以一个整体集群的形式展现出来,这样可以更好的把握整个系统的状态。 为此,Netflix又提供了一个开源项目(Turbine)来提供把多个hystrix.stream的内容聚合为一个数据源供Dashboard展示。

Turbine有2种用法,其一是内嵌Turbine到你的项目中;另外一个是把Turbine当做一个独立的Module。不管哪种用法,配置文件都是一致的。 Turbine默认会在classpath下查找配置文件:config.properties, 该文件中会配置:
1. Turbine在监控哪些集群:turbine.aggregator.clusterConfig=cluster-1,cluster-2
2. Turbine怎样获取到节点的监控信息(hystrix.stream):turbine.instanceUrlSuffix.<cluster-name> = :/HystrixDemo/hystrix.stream
3. 集群下有哪些节点:turbine.ConfigPropertyBasedDiscovery.cluster-1.instances=localhost:8080,localhost:8081
上面这些都是最简单的配置方法 Turbine使用了Netflix的另一个开源项目Archaius(https://github.com/Netflix/archaius)来做配置文件的管理,其提供了非常强大的配置文件管理策略,有需要的同学可以深入研究(https://github.com/Netflix/Turbine/wiki/Configuration)。

使用Turbine的步骤一般如下:
1. 下载Turbine.war(https://github.com/downloads/Netflix/Turbine/turbine-web-1.0.0.war),并把其置于Web容器中。
2. 在Turbine项目的WEB-INF/classes目录下创建配置文件config.properties:
3. 启动Turbine服务
4. 在Dashboard项目中填入Tubine项目提供的stream: http://hostname:port/turbine/turbine.stream也可添加?cluster=<cluster-name>参数只监控某一个Cluster. Dashboard上展示的指标和之前是一样的,只是数据是已经聚合的数据了。
为遗留系统添加Hystrix
最后,来看看如何在不改动已有代码的前提下为应用添加Hystrix支持,在Spring的世界,以不改变已有代码的前提添加功能的最好解决方案就是aop,还是使用上面的示例,假设已有一个Customer Service, Customer Service会调用ContactDao和AddressDao去获取Contact和Address信息。 如下:
public Customer getCustomerThroughDao(String customerId) {
        logger.info("Get Customer {}", customerId);
        try {
            Customer customer = new Customer(customerId, "xianlinbox");
            customer.setContact(contactDao.getContact(customerId));
            customer.setAddress(addressDao.getAddress(customerId));
            return customer;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

public class AddressDao {
    private Logger logger = LoggerFactory.getLogger(AddressDao.class);

    public Address getAddress(String customerId) throws IOException {
        logger.info("Get address for customer {}", customerId);
        String response = Request.Get("http://localhost:9090/customer/" + customerId + "/address")
                .connectTimeout(1000)
                .socketTimeout(1000)
                .execute()
                .returnContent()
                .asString();

        return new ObjectMapper().readValue(response, Address.class);
    }
}

public class ContactDao {
    private Logger logger = LoggerFactory.getLogger(ContactDao.class);

    public Contact getContact(String customerId) throws IOException {
        logger.info("Get contact for customer {}", customerId);
        String response = Request.Get("http://localhost:9090/customer/" + customerId + "/contact")
                .connectTimeout(1000)
                .socketTimeout(1000)
                .execute()
                .returnContent()
                .asString();

        return new ObjectMapper().readValue(response, Contact.class);
    }
}

下面就来看看如何在不改动已有代码的基础上把ContactDao和AddressDao封装到HystixCommand中,首先创建HystrixComnandAdvice,该类会为创建一个HystrixCommand, 然后把切面封装到该HystrixCommand中:
public class HystrixCommandAdvice {
    private String groupName;
    private String commandName;

    public Object runCommand(final ProceedingJoinPoint pjp) {
        return wrapWithHystrixCommnad(pjp).execute();
    }

    private HystrixCommand<Object> wrapWithHystrixCommnad(final ProceedingJoinPoint pjp) {
        return new HystrixCommand<Object>(setter()) {
            @Override
            protected Object run() throws Exception {
                try {
                    return pjp.proceed();
                } catch (Throwable throwable) {
                    throw (Exception) throwable;
                }
            }

            @Override
            protected Object getFallback() {
                return null;
            }
        };
    }

    private HystrixCommand.Setter setter() {
        return HystrixCommand.Setter
                .withGroupKey(HystrixCommandGroupKey.Factory.asKey(groupName))
                .andCommandKey(HystrixCommandKey.Factory.asKey(commandName));
    }

    public void setGroupName(String groupName) {
        this.groupName = groupName;
    }

    public void setCommandName(String commandName) {
        this.commandName = commandName;
    }
}


然后,只需要再为ContactDao和AddressDao配置上该类示例就行了:
  
 <bean id="contactDaoCommand" class="com.xianlinbox.hystrix.dao.HystrixCommandAdvice">
        <property name="groupName" value="Contact"/>
        <property name="commandName" value="Contact"/>
    </bean>
    <bean id="addressDaoCommand" class="com.xianlinbox.hystrix.dao.HystrixCommandAdvice">
        <property name="groupName" value="Address"/>
        <property name="commandName" value="Address"/>
    </bean>
    <aop:config>
        <aop:aspect id="contactServiceAspect" ref="contactDaoCommand">
            <aop:pointcut id="contactServiceTarget"
                          expression="execution(* com.xianlinbox.hystrix.dao.ContactDao.getContact(..))"/>
            <aop:around method="runCommand" pointcut-ref="contactServiceTarget"/>
        </aop:aspect>
    </aop:config>

    <aop:config>
        <aop:aspect id="addressServiceAspect" ref="addressDaoCommand">
            <aop:pointcut id="addressServiceTarget"
                          expression="execution(* com.xianlinbox.hystrix.dao.AddressDao.getAddress(..))"/>
            <aop:around method="runCommand" pointcut-ref="addressServiceTarget"/>
        </aop:aspect>
    </aop:config>


该示例的系统行为和前面直接使用HystrixCommand构建的时完全一样的。
总结
从全文涉及的内容中,不难看出Netflix构建了一个完整的Hystrix生态系统,这个生态系统让Hystrix非常易于上手,同时又有非常多的配置选项和高级用法来满足不同系统的个性化需求。对于这样的工具,相信每个开发者都会喜欢。另外,对于Netflix这样把自己的经验变成工具造福整个社区的行为,不由得不赞赏。
  • 大小: 335.8 KB
  • 大小: 87.9 KB
  • 大小: 98 KB
  • 大小: 50.1 KB
1
0
分享到:
评论
2 楼 krystal_zyy 2015-11-05  
现在dashboard数据是从hystrix.stream里面过来的,hystrix.stream里面的数据是怎么产生的,求解释
1 楼 yangchao228 2015-10-25  
楼主的分享非常赞,这些东西一般都会有坑,不知道楼主是否有遇到过

相关推荐

    15.Spring Cloud中使用Hystrix

    本文将深入探讨如何在Spring Cloud项目中集成并使用Hystrix,以及如何将其与Feign客户端结合。 首先,我们需要了解Hystrix的基本原理。Hystrix通过隔离请求,防止单个服务的故障蔓延至整个系统,避免雪崩效应。断路...

    spring-cloud-netflix-hystrix应用

    4. **使用HystrixCommand**:在服务调用处使用HystrixCommand,确保服务调用被正确地封装和隔离。 5. **实现降级逻辑**:编写降级方法,当服务不可用时自动执行。 6. **集成监控**:集成Hystrix Dashboard和Turbine...

    spring cloud hystrix原理介绍及使用

    3. 降级处理:当依赖的服务不可用或响应时间过长时,Hystrix允许系统执行备选的降级逻辑,比如返回缓存数据、返回默认值或者快速失败提示用户。这有助于保持系统的整体可用性。 Hystrix工作原理具体包括以下几个...

    springcloud hystrix 断路由

    在 `SpringCloudDemo-Hystrix` 压缩包中,通常包含了示例代码,演示了如何在 Spring Boot 应用中配置和使用 Hystrix。开发者可以通过阅读这些代码,学习如何将断路器集成到自己的服务中。 总的来说,Spring Cloud ...

    Hystrix Dashboard的使用-代码部分.zip

    3. **监控数据**: Hystrix Dashboard 通过 WebSocket 实时获取 Hystrix 组件发送的指标数据,包括请求计数、成功率、错误率、线程池利用率等。 4. **集成 Hystrix Dashboard**: 需要在服务中引入 Hystrix Dashboard ...

    hystrix-dashboar1.5.12

    3. **部署与使用**: - 将 `hystrix-dashboar1.5.12.war` 文件部署到支持Servlet 3.0以上的Web服务器(如Tomcat)的webapps目录下,服务器会自动解压并启动。 - 配置Hystrix Stream,使监控数据流式传输到 ...

    断路器hystrix实现.rar

    Hystrix是Netflix开源的一款强大的断路器库,它适用于Java环境,并且广泛应用于Spring Cloud框架中。本教程将深入探讨如何使用Hystrix在微服务中实现断路器功能。 首先,让我们理解断路器的工作原理。断路器在正常...

    微服务断路器hystrix应用实例java工程源码.zip

    本压缩包“微服务断路器hystrix应用实例java工程源码.zip”包含了一个基于Java实现的Hystrix应用实例,这个实例旨在帮助开发者理解和掌握如何在实际项目中集成和使用Hystrix。通过分析源码,我们可以深入学习以下几...

    hystrix公司内部分享ppt

    Hystrix是一个由Netflix开源的延迟和容错库,旨在隔离远程系统、服务和第三方库的访问点,停止级联失败,提供后备选项,并实现优雅降级。...这说明了使用Hystrix进行服务调用时,资源隔离与限流的重要性。

    SpringCloud -Hystrix监控面板及数据聚合(Turbine)介绍与使用示例

    3. **配置文件**:配置应用名称、端口以及 Turbine 的集群配置。 4. **暴露监控端点**:在所有需要监控的服务中引入 `spring-boot-starter-actuator` 依赖,并开启 `hystrix.stream` 端点。 5. **配置 Turbine**:...

    hystrix简介

    3. **回退策略**:当依赖服务不可用时,Hystrix 可以提供预先定义好的回退逻辑,返回一个默认值或执行替代逻辑,从而减少错误和提高用户体验。 #### 使用 Hystrix 的方法 Hystrix 提供了两种主要的命令类型:`...

    hystrix-dashboard.zip

    【描述】提到的内容表明,这个压缩包可能包含了一个完整的示例项目,用于演示如何在Spring Cloud应用中集成和使用Hystrix Dashboard。在文章《Spring Cloud Hystrix Dashboard实战》...

    Hystrix-dashboard+turbine-web+说明文档

    3. **降级策略**:在熔断后,Hystrix 允许应用提供降级策略,如返回缓存数据或显示备用界面,确保应用的基本功能不受影响。 4. **命令模式**:Hystrix 使用命令模式将业务逻辑封装在命令对象中,便于管理和监控。 *...

    Hystrix 熔断、降级实例

    "HystrixComma"可能是压缩包中的一个示例文件,它可能包含了一些Hystrix的使用代码或者配置示例。通过分析和学习这些代码,我们可以更好地理解Hystrix的用法和配置。 总结,Hystrix通过HystrixCommand实现了服务...

    熔断器Hystrix的使用与原理.pdf

    • 1. 服务雪崩效应 • 2. 服务雪崩应对策略 ... 使用Hystrix预防服务雪崩 • 4. 预售中Hystrix的运用 • 5. Hystrix的实现 • 6. Hystrix的运维 • 7. 题外话: Netflix的技术栈 • 8. 题外话: 响应式编程

    Hystrix是如何保护应用验证1

    3. **熔断机制**:在压力测试中,通过Hystrix安全方式发起请求,虽然理论上接口请求次数多于实际处理次数,但这是因为Hystrix进行了熔断处理。当服务无法及时响应时,Hystrix会快速返回一个默认值或错误信息,避免...

    springcloud hystrix的使用

    3. **创建Hystrix命令**:通过实现`HystrixCommand`接口或使用注解`@HystrixCommand`,我们可以为每个服务调用创建一个Hystrix命令。命令中定义了执行业务逻辑的方法(`run()`)以及在失败时回退的方法(`fallBack()...

    微服务springcloud之feign和hystrix使用demo

    feign中包含了hystrix以及ribbon,即feign在不导入hystrix和ribbon的依赖下也能完成他们所能实现的功能,当然,如果想使用hystrix和ribbon自带的注解以及配置,必须导入依赖才可以,feign结合hystrix实现熔断+降级,...

    APM之hystrix的使用

    APM之hystrix的使用,改造老的项目,没有使用spring cloud全家桶的情况下如何使用

    Hystrix源码_可以跑起来

    在源代码中找到示例应用,理解其工作流程,通过调试器设置断点,逐步跟踪命令的执行过程。 在源码中,你会看到如`HystrixCommand.execute()`或`HystrixCommand.queue().get()`这样的方法调用,它们是发起服务请求的...

Global site tag (gtag.js) - Google Analytics