关于intellij-idea:SpringClub04Hystrix-断路器

38次阅读

共计 8608 个字符，预计需要花费 22 分钟才能阅读完成。

零碎容错、限流工具

当一个服务调用一个后盾服务调用失败（异样、服务不存在、超时），能够执行以后服务中的一段“降级代码”，来返回降级后果
疾速失败：当调用后盾服务超时，为了不让用户长时间期待，能够间接返回降级后果

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

spring:
  application:
    name: hystrix
server:
  port: 3001
#连贯 eureka
eureka:
  client:
    service-url:
      defaultZone: http://eureka1:2001/eureka, http://eureka2:2002/eureka
ribbon:
  #单台重试次数
 MaxAutoRetries: 1
  #更换服务器次数
 MaxAutoRetriesNextServer: 2

1.1.4 主程序增加 `@EnableCircuitBreaker` 启用 hystrix 断路器

启动断路器，断路器提供两个外围性能：

降级，超时、出错、不可达到时，对服务降级，返回错误信息或者是缓存数据
熔断，当服务压力过大，谬误比例过多时，熔断所有申请，所有申请间接降级
能够应用 @SpringCloudApplication 注解代替三个注解

package cn.tedu.sp07;
import org.springframework.boot.SpringApplication;
import org.springframework.cloud.client.SpringCloudApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.web.client.RestTemplate;
//@EnableCircuitBreaker
//@EnableDiscoveryClient
//@SpringBootApplication
@SpringCloudApplication
public class Sp06RibbonApplication {
    @LoadBalanced
    @Bean
    public RestTemplate getRestTemplate() {SimpleClientHttpRequestFactory f = new SimpleClientHttpRequestFactory();
        f.setConnectTimeout(1000);
        f.setReadTimeout(1000);
        return new RestTemplate(f);
        //RestTemplate 中默认的 Factory 实例中，两个超时属性默认是 -1，// 未启用超时，也不会触发重试
        //return new RestTemplate();}
    public static void main(String[] args) {SpringApplication.run(Sp06RibbonApplication.class, args);
    }
}

为每个办法增加降级办法，例如 getItems() 增加降级办法 getItemsFB()
增加 @HystrixCommand 注解，指定降级办法名

package com.tedu.sp06.controller;
import cn.tedu.sp01.pojo.Item;
import cn.tedu.sp01.pojo.Order;
import cn.tedu.sp01.pojo.User;
import cn.tedu.web.util.JsonResult;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;
import java.util.List;
@RestController
@Slf4j
public class RibbonController {
    @Autowired
 private RestTemplate rt;
    @GetMapping("/item-service/{orderId}")
    @HystrixCommand(fallbackMethod = "getItemsFB")
    public JsonResult<List<Item>> getItems(@PathVariable String orderId) {
        /* 调用近程的商品服务，取得订单的商品列表
 {1} - RestTemplate 本人定义的一种站位符格局
 注册核心的注册表：item-service ---- localhost:8001,localhost:8002 从注册表失去 item-service 对应的多个地址，而后在多个地址之间来回调用
 */ return rt.getForObject("http://item-service/{1}", JsonResult.class, orderId); // 用 orderId 填充占位符 {1} }
    @PostMapping("/item-service/decreaseNumber")
    @HystrixCommand(fallbackMethod = "decreaseNumberFB")
    public JsonResult<?> decreaseNumber(@RequestBody List<Item> items) {return rt.postForObject("http://item-service/decreaseNumber", items, JsonResult.class);
    }
    @GetMapping("/user-service/{userId}")
    @HystrixCommand(fallbackMethod = "getUserFB")
    public JsonResult<User> getUser(@PathVariable Integer userId) {return rt.getForObject("http://user-service/{1}", JsonResult.class, userId);
    }
    @GetMapping("/user-service/{userId}/score") // ?score=1000
 @HystrixCommand(fallbackMethod = "addScoreFB")
    public JsonResult<?> addScore(@PathVariable Integer userId, @RequestParam Integer score) {return rt.getForObject("http://user-service/{1}/score?score={2}", JsonResult.class, userId, score);
    }
    @GetMapping("/order-service/{orderId}")
    @HystrixCommand(fallbackMethod = "getOrderFB")
    public JsonResult<Order> getOrder(@PathVariable String orderId) {return rt.getForObject("http://order-service/{1}", JsonResult.class, orderId);
    }
    @GetMapping("/order-service")
    @HystrixCommand(fallbackMethod = "addOrderFB")
    public JsonResult<?> addOrder() {return rt.getForObject("http://order-service", JsonResult.class);
    }
    //////////////////////////////////////////////////////////////
 public JsonResult<List<Item>> getItemsFB(String orderId) {return JsonResult.err().msg("获取订单商品列表失败");
    }
    public JsonResult<?> decreaseNumberFB(List<Item> items) {return JsonResult.err().msg("缩小商品库存失败");
    }
    public JsonResult<User> getUserFB(Integer userId) {return JsonResult.err().msg("获取用户失败");
    }
    public JsonResult<?> addScoreFB(Integer userId, @RequestParam Integer score) {return JsonResult.err().msg("减少用户积分失败");
    }
    public JsonResult<Order> getOrderFB (String orderId){return JsonResult.err().msg("获取订单失败");
    }
    public JsonResult<?> addOrderFB () {return JsonResult.err().msg("增加订单失败");
    }
}

hystrix 期待超时后, 会执行降级代码, 疾速向客户端返回降级后果, 默认超时工夫是 1000 毫秒
为了测试 hystrix 降级，咱们把 hystrix 期待超时设置得十分小（500 毫秒）
此设置个别应大于 ribbon 的重试超时时长，例如 10 秒

spring:
  application:
    name: hystrix
server:
  port: 3001
#连贯 eureka
eureka:
  client:
    service-url:
      defaultZone: http://eureka1:2001/eureka, http://eureka2:2002/eureka
ribbon:
  #单台重试次数
 MaxAutoRetries: 1
  #更换服务器次数
 MaxAutoRetriesNextServer: 2
#超时设置
hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 1000

通过 hystrix 服务，拜访可能超时失败的 item-service
http://localhost:3001/item-service/35
通过 hystrix 服务，拜访未启动的 user-service
http://localhost:3001/user-service/7
能够看到，如果 item-service 申请超时，hystrix 会立刻执行降级办法
拜访 user-service，因为该服务未启动，hystrix 也会立刻执行降级办法

服务过热，间接把后盾服务断开，限度服务的申请流量
在特定条件下回主动触发熔断：

10 秒 20 次申请（必须首选满足）
50% 失败，执行了降级代码

熔断后（断路器关上），所有申请间接执行降级代码，返回降级后果
半开状态：
断路器关上后几秒，会进入半开状态，会向后盾服务尝试发送一次用户申请，如果胜利则敞开断路器，恢复正常。如果失败，持续放弃短路器关上状态几秒。

Hystrix 仪表盘，故障监控

springboot 提供的我的项目监控信息工具，提供我的项目的各种监控日志数据

衰弱状态
spring 容器中所有的对象
spring mvc 所有的映射门路
env 环境变量
……

hystrix 利用 actuator 裸露了本人的监控日志，日志端点：hystrix.stream

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

1.2 调整 application.yml 配置，并裸露 `hystrix.stream` 监控端点

spring:
  application:
    name: ribbon   #hystrix
server:
  port: 3001
#连贯 eureka
eureka:
  client:
    service-url:
      defaultZone: http://eureka1:2001/eureka, http://eureka2:2002/eureka
ribbon:
  #单台重试次数
 MaxAutoRetries: 1
  #更换服务器次数
 MaxAutoRetriesNextServer: 2
#超时设置
hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 1000
management:
  endpoints:
    web:
      exposure:
        include: "*"

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.2.1.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>cn.tedu</groupId>
    <artifactId>sp08-hystrix-dashboard</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>sp08-hystrix-dashboard</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <spring-cloud.version>Hoxton.RELEASE</spring-cloud.version>
    </properties>

    <dependencies>
        <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>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

spring:
  application:
    name: hystrix-dashboard
server:
  port: 4001
#容许从这些服务器抓取日志
hystrix:
  dashboard:
    proxy-stream-allow-list: localhost

2.4 主程序增加 `@EnableHystrixDashboard` 注解

package com.tedu.sp08;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
@EnableHystrixDashboard
@SpringBootApplication
public class Sp08HystrixDashboardApplication {public static void main(String[] args) {SpringApplication.run(Sp08HystrixDashboardApplication.class, args);
   }
}

2.5.1 拜访 hystrix dashboard

http://localhost:4001/hystrix

2.5.2 填入 hystrix 的监控端点，开启监控

http://localhost:3001/actuator/hystrix.stream

通过 hystrix 拜访服务屡次，察看监控信息

http://localhost:3001/item-service/35
http://localhost:3001/user-service/7
http://localhost:3001/user-service/7/score?score=100
http://localhost:3001/order-service/123abc
http://localhost:3001/order-service/

正文完

intellij-idea

发表至： intellij-idea

2020-12-21

0

关于intellij-idea:SpringClub02注册中心eureka

关于intellij-idea:IDEA显示Cannot-resolve-symbol-XXX

关于intellij-idea:IDEA-的使用

关于intellij-idea:如何在mac上使用idea做大数据开发

关于tidb:TiDB-x-浙商银行-用数据驱动卓越高效的金融服务

关于intellij-idea:SpringClub04Hystrix-断路器

一、Hystrix

1. 降级

1.1 增加降级：

1.1.1 创立 sp07-hystrix 我的项目

1.1.2 增加 hystrix 依赖

1.1.3 批改 application.yml

1.1.4 主程序增加 `@EnableCircuitBreaker` 启用 hystrix 断路器

1.1.5 RibbonController 中增加降级办法

1.2 增加 hystrix 超时设置

1.1.6 启动我的项目进行测试

2. 熔断

二、Hystrix Dashboard

1. actuator

1.1 pom.xml 增加 actuator 依赖

1.2 调整 application.yml 配置，并裸露 `hystrix.stream` 监控端点

1.3 拜访 actuator 门路，查看监控端点

2. Hystrix dashboard 仪表盘

2.1 新建 sp08-hystrix-dashboard 我的项目

2.2 批改 pom.xml 文件

2.3 批改 application.yml 文件

2.4 主程序增加 `@EnableHystrixDashboard` 注解

2.5 启动，并拜访测试

2.5.1 拜访 hystrix dashboard

2.5.2 填入 hystrix 的监控端点，开启监控

Just My Socks（注册教程内含优惠码）

关于intellij-idea:SpringClub04Hystrix-断路器

一、Hystrix

1. 降级

1.1 增加降级：

1.1.1 创立 sp07-hystrix 我的项目

1.1.2 增加 hystrix 依赖

1.1.3 批改 application.yml

1.1.4 主程序增加 @EnableCircuitBreaker 启用 hystrix 断路器

1.1.5 RibbonController 中增加降级办法

1.2 增加 hystrix 超时设置

1.1.6 启动我的项目进行测试

2. 熔断

二、Hystrix Dashboard

1. actuator

1.1 pom.xml 增加 actuator 依赖

1.2 调整 application.yml 配置，并裸露 hystrix.stream 监控端点

1.3 拜访 actuator 门路，查看监控端点

2. Hystrix dashboard 仪表盘

2.1 新建 sp08-hystrix-dashboard 我的项目

2.2 批改 pom.xml 文件

2.3 批改 application.yml 文件

2.4 主程序增加 @EnableHystrixDashboard 注解

2.5 启动，并拜访测试

2.5.1 拜访 hystrix dashboard

2.5.2 填入 hystrix 的监控端点，开启监控

Just My Socks（注册教程 内含优惠码）

1.1.4 主程序增加 `@EnableCircuitBreaker` 启用 hystrix 断路器

1.2 调整 application.yml 配置，并裸露 `hystrix.stream` 监控端点

2.4 主程序增加 `@EnableHystrixDashboard` 注解

Just My Socks（注册教程内含优惠码）