SpringCloud文章系列

接入说明

目前采用最新的1.xRelease版本：1.5.15.RELEASE
SpringCloud项目可以在start.spring.io下载，不过更方便的应该是通过idea新建项目，建立Spring Initializr项目
我一般习惯将具体实现服务用具体的服务名，而公共组件用service-xxx来命名，当然还有一些比较固定名字的公共组件

断路监控大盘

1. 新建项目

新建artifactId为hystrix-dashboard的服务

2. 导入依赖

依赖说明

actuator用于暴露监控的接口
eureka-server是Eureka服务器的依赖
config是Config客户端，从配置中心拉取配置
netflix-hystrix-dashboard是hystrix监控大盘的依赖

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

3. 编写启动类

打开HystrixDashboardApplication，在class上加入@EnableHystrixDashboard注解

4. 修改配置

server.port=8030
spring.application.name=hystrix-dashboard
# public
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka,http://localhost:8762/eureka
spring.cloud.config.discovery.enabled=true
spring.cloud.config.discovery.service-id=service-config

5. 启动main

6. 验证

访问 http://localhost:8761/ 看到hystrix-dashboard已经注册了一台
访问 http://localhost:8030 可以看到hystrix监控的页面，上面需要配置一个xxx.stream的http地址，客户度集成后就有这个地址了

客户端使用

基于刚同步调用章节business-service服务调用account-service服务接口的例子

1. 添加依赖

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>

2. 开启注解

BusinessServiceApplication加入注解 @EnableCircuitBreaker 打开断路器功能

3. 修改代码

基于feign远程调用的降级非常简单

@RestController
class AccountController {
    @Autowired
    private AccountRead accountRead;
    public String fallback() {
        return "掛了";
    }
    @HystrixCommand(fallbackMethod = "fallback")
    @RequestMapping("/account-msg")
    public String read() {
        return accountRead.read();
    }
}

增加@HystrixCommand注解，注解种指定fallbackMethod对应同参数与返回值的方法即可

其他的方法也可以在方法上面标注@HystrixCommand(fallbackMethod = “xxx”)注解就实现降级了，比如用restTempldate请求的方法上加上

监控大盘集成

只需将客户的的http://localhost:8010/hystrix.stream填入hystrix-dashboard的url中点击下面按钮注册就可以看到监控数据
但是这样只能看到一台机器的，有时候我们想关注整个集群的情况，多个业务服务的链路情况，则需要使用数据聚合服务turbine-service

turbine服务

导入依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-turbine</artifactId>
</dependency>

添加bootstrap.properties

server.port=8001
spring.application.name=turbine-service
# private
turbine.app-config=api-gateway,business-service
turbine.aggregator.clusterConfig=default
turbine.cluster-name-expression="default"
turbine.combine-host-port=true
# public
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka,http://localhost:8762/eureka
spring.cloud.config.discovery.enabled=true
spring.cloud.config.discovery.service-id=service-config

turbine.app-config用于指定具体聚合哪些服务，这里聚合2个有调用请求的服务网关+business服务

在TurbineServiceApplication类上加入@EnableTurbine

将地址 http://localhost:8001/hystrix.stream 配置在hystrix-dashboard上就可以看到服务网关+business服务2个集群的调用情况了