博客
关于我
强烈建议你试试无所不能的chatGPT，快点击我
使用Hystrix守护应用（3）
阅读量：5983 次
发布时间：2019-06-20

本文共 6460 字，大约阅读时间需要 21 分钟。

hot3.png

使用Hystrix守护应用（3） 博客分类： 架构 spring 微服务

监控HystrixCommand 

除了隔离依赖服务的调用外，Hystrix还提供了近乎实时的监控，Hystrix会实时的，累加的记录所有关于HystrixCommand的执行信息，包括执行了每秒执行了多少请求，多少成功，多少失败等等，更多指标请查看： 
导出监控数据 
有了这些指标，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库添加到项目中： 

Gradle代码  
收藏代码
  1. dependencies {  
  2.     compile(  
  3.              ...  
  4.             'com.netflix.hystrix:hystrix-metrics-event-stream:1.3.9',  
  5.             ...  
  6.     )  
  7. }  

然后，在web.xml中配置一个Servlet来获取Hystrix提供的数据： 

Xml代码  
收藏代码
  1. <servlet>  
  2.         <description></description>  
  3.         <display-name>HystrixMetricsStreamServlet</display-name>  
  4.         <servlet-name>HystrixMetricsStreamServlet</servlet-name>  
  5.         <servlet-class>com.netflix.hystrix.contrib.metrics.eventstream.HystrixMetricsStreamServlet</servlet-class>  
  6.     </servlet>  
  7.   
  8.     <servlet-mapping>  
  9.         <servlet-name>HystrixMetricsStreamServlet</servlet-name>  
  10.         <url-pattern>/hystrix.stream</url-pattern>  
  11.     </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：）来可视化这些数据，帮助运维人员更直观的了解系统的当前状态，Dashboard使用起来非常方便，其就是一个Web项目，你只需要把war包（）下载下来，放到一个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（）来做配置文件的管理，其提供了非常强大的配置文件管理策略，有需要的同学可以深入研究（）。 
使用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信息。 如下： 

Java代码  
收藏代码
  1. public Customer getCustomerThroughDao(String customerId) {  
  2.         logger.info("Get Customer {}", customerId);  
  3.         try {  
  4.             Customer customer = new Customer(customerId, "xianlinbox");  
  5.             customer.setContact(contactDao.getContact(customerId));  
  6.             customer.setAddress(addressDao.getAddress(customerId));  
  7.             return customer;  
  8.         } catch (Exception e) {  
  9.             e.printStackTrace();  
  10.         }  
  11.         return null;  
  12.     }  
  13.   
  14. public class AddressDao {  
  15.     private Logger logger = LoggerFactory.getLogger(AddressDao.class);  
  16.   
  17.     public Address getAddress(String customerId) throws IOException {  
  18.         logger.info("Get address for customer {}", customerId);  
  19.         String response = Request.Get("http://localhost:9090/customer/" + customerId + "/address")  
  20.                 .connectTimeout(1000)  
  21.                 .socketTimeout(1000)  
  22.                 .execute()  
  23.                 .returnContent()  
  24.                 .asString();  
  25.   
  26.         return new ObjectMapper().readValue(response, Address.class);  
  27.     }  
  28. }  
  29.   
  30. public class ContactDao {  
  31.     private Logger logger = LoggerFactory.getLogger(ContactDao.class);  
  32.   
  33.     public Contact getContact(String customerId) throws IOException {  
  34.         logger.info("Get contact for customer {}", customerId);  
  35.         String response = Request.Get("http://localhost:9090/customer/" + customerId + "/contact")  
  36.                 .connectTimeout(1000)  
  37.                 .socketTimeout(1000)  
  38.                 .execute()  
  39.                 .returnContent()  
  40.                 .asString();  
  41.   
  42.         return new ObjectMapper().readValue(response, Contact.class);  
  43.     }  
  44. }  

下面就来看看如何在不改动已有代码的基础上把ContactDao和AddressDao封装到HystixCommand中，首先创建HystrixComnandAdvice，该类会为创建一个HystrixCommand, 然后把切面封装到该HystrixCommand中： 

Java代码  
收藏代码
  1. public class HystrixCommandAdvice {  
  2.     private String groupName;  
  3.     private String commandName;  
  4.   
  5.     public Object runCommand(final ProceedingJoinPoint pjp) {  
  6.         return wrapWithHystrixCommnad(pjp).execute();  
  7.     }  
  8.   
  9.     private HystrixCommand<Object> wrapWithHystrixCommnad(final ProceedingJoinPoint pjp) {  
  10.         return new HystrixCommand<Object>(setter()) {  
  11.                
  12.             protected Object run() throws Exception {  
  13.                 try {  
  14.                     return pjp.proceed();  
  15.                 } catch (Throwable throwable) {  
  16.                     throw (Exception) throwable;  
  17.                 }  
  18.             }  
  19.   
  20.                
  21.             protected Object getFallback() {  
  22.                 return null;  
  23.             }  
  24.         };  
  25.     }  
  26.   
  27.     private HystrixCommand.Setter setter() {  
  28.         return HystrixCommand.Setter  
  29.                 .withGroupKey(HystrixCommandGroupKey.Factory.asKey(groupName))  
  30.                 .andCommandKey(HystrixCommandKey.Factory.asKey(commandName));  
  31.     }  
  32.   
  33.     public void setGroupName(String groupName) {  
  34.         this.groupName = groupName;  
  35.     }  
  36.   
  37.     public void setCommandName(String commandName) {  
  38.         this.commandName = commandName;  
  39.     }  
  40. }  

然后，只需要再为ContactDao和AddressDao配置上该类示例就行了： 
  

Xml代码  
收藏代码
  1. <bean id="contactDaoCommand" class="com.xianlinbox.hystrix.dao.HystrixCommandAdvice">  
  2.        <property name="groupName" value="Contact"/>  
  3.        <property name="commandName" value="Contact"/>  
  4.    </bean>  
  5.    <bean id="addressDaoCommand" class="com.xianlinbox.hystrix.dao.HystrixCommandAdvice">  
  6.        <property name="groupName" value="Address"/>  
  7.        <property name="commandName" value="Address"/>  
  8.    </bean>  
  9.    <aop:config>  
  10.        <aop:aspect id="contactServiceAspect" ref="contactDaoCommand">  
  11.            <aop:pointcut id="contactServiceTarget"  
  12.                          expression="execution(* com.xianlinbox.hystrix.dao.ContactDao.getContact(..))"/>  
  13.            <aop:around method="runCommand" pointcut-ref="contactServiceTarget"/>  
  14.        </aop:aspect>  
  15.    </aop:config>  
  16.   
  17.    <aop:config>  
  18.        <aop:aspect id="addressServiceAspect" ref="addressDaoCommand">  
  19.            <aop:pointcut id="addressServiceTarget"  
  20.                          expression="execution(* com.xianlinbox.hystrix.dao.AddressDao.getAddress(..))"/>  
  21.            <aop:around method="runCommand" pointcut-ref="addressServiceTarget"/>  
  22.        </aop:aspect>  
  23.    </aop:config>  

该示例的系统行为和前面直接使用HystrixCommand构建的时完全一样的。 
总结 
从全文涉及的内容中，不难看出Netflix构建了一个完整的Hystrix生态系统，这个生态系统让Hystrix非常易于上手，同时又有非常多的配置选项和高级用法来满足不同系统的个性化需求。对于这样的工具，相信每个开发者都会喜欢。另外，对于Netflix这样把自己的经验变成工具造福整个社区的行为，不由得不赞赏。 

 

http://ningandjiao.iteye.com/blog/2171849

转载于:https://my.oschina.net/xiaominmin/blog/1599122

你可能感兴趣的文章
【Linux】Linux 在线安装yum
查看>>
Atom 编辑器系列视频课程
查看>>
[原][osgearth]osgearthviewer读取earth文件，代码解析（earth文件读取的一帧）
查看>>
通过IP判断登录地址
查看>>
深入浅出JavaScript （五） 详解Document.write()方法
查看>>
Beta冲刺——day6
查看>>
代码生成工具Database2Sharp中增加视图的代码生成以及主从表界面生成功能
查看>>
我的友情链接
查看>>
IDE---Python IDE之Eric5在window下的安装
查看>>
基本安装lnmp环境
查看>>
logstash消费阿里云kafka消息
查看>>
Oracle——条件控制语句
查看>>
day-6 and day-7：面向对象
查看>>
CSU Double Shortest Paths 湖南省第十届省赛
查看>>
webgl像机世界
查看>>
php正则怎么使用（最全最细致）
查看>>
javascript数学运算符
查看>>
LC.155. Min Stack(非优化，两个stack 同步 ＋ －)
查看>>
交互设计[3]--点石成金
查看>>
SCCM TP4部署Office2013
查看>>
喝酒易醉，品茶养心，人生如梦，品茶悟道，何以解忧？唯有杜康！-- 愿君每日到此一游！
当前时间: 2024-12-30 00:13:20   当前IP: 18.191.26.149   联系邮箱:javaeecc@qq.com     Copyright © 2020 - 2022 baihongyu.com 京ICP备2021015314号-2
强烈建议你试试无所不能的CHAT-GPT，快点击我
强烈建议你试试无所不能的CHAT-GPT，快点击我