构建cloud-provider-hystrix-payment8001

pom

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>cloud2020</artifactId>
  7.         <groupId>com.carve.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-provider-hystrix-payment8001</artifactId>
  14.     <dependencies>
  15.         <!--hystrix-->
  16.         <dependency>
  17.             <groupId>org.springframework.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
  19.         </dependency>
  20.         <!--eureka client-->
  21.         <dependency>
  22.             <groupId>org.springframework.cloud</groupId>
  23.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  24.         </dependency>
  25.         <dependency>
  26.             <groupId>com.carve.springcloud</groupId>
  27.             <artifactId>cloud-api-common</artifactId>
  28.             <version>${project.version}</version>
  29.         </dependency>
  30.         <dependency>
  31.             <groupId>org.springframework.boot</groupId>
  32.             <artifactId>spring-boot-starter-web</artifactId>
  33.         </dependency>
  34.         <!--监控-->
  35.         <dependency>
  36.             <groupId>org.springframework.boot</groupId>
  37.             <artifactId>spring-boot-starter-actuator</artifactId>
  38.         </dependency>
  39.         <!--热部署-->
  40.         <dependency>
  41.             <groupId>org.springframework.boot</groupId>
  42.             <artifactId>spring-boot-devtools</artifactId>
  43.             <scope>runtime</scope>
  44.             <optional>true</optional>
  45.         </dependency>
  46.         <dependency>
  47.             <groupId>org.projectlombok</groupId>
  48.             <artifactId>lombok</artifactId>
  49.             <optional>true</optional>
  50.         </dependency>
  51.         <dependency>
  52.             <groupId>org.springframework.boot</groupId>
  53.             <artifactId>spring-boot-starter-test</artifactId>
  54.             <scope>test</scope>
  55.         </dependency>
  56.     </dependencies>
  58. </project>

yml

  1. server:
  2.   port: 8001
  3. spring:
  4.   application:
  5.     name: cloud-provider-hystrix-payment
  6. eureka:
  7.   client:
  8.     register-with-eureka: true
  9.     fetch-registry: true
  10.     service-url:
  11.       defaultZone: http://eureka7001.com:7001/eureka
  12.     # defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka # 集群版

启动类

  1. @SpringBootApplication
  2. @EnableEurekaClient
  3. public class PaymentHystrixMain8001 {
  4.     public static void main(String[] args) {
  5.         SpringApplication.run(PaymentHystrixMain8001.class, args);
  6.     }
  7. }

service

  1. @Service
  2. public class PaymentService {
  4.     // 正常访问
  5.     public String paymentInfo_OK(Integer id) {
  6.         return "线程池:" + Thread.currentThread().getName() + " paymentInfo_OK(),id:" + id;
  7.     }
  9.     // 超时访问
  11.     public String paymentInfo_TimeOut(Integer id) {
  12.         int timeNumber = 3;
  13.         try {
  14.             TimeUnit.SECONDS.sleep(timeNumber);
  15.         } catch (InterruptedException e) {
  16.             e.printStackTrace();
  17.         }
  18.         return "线程池:" + Thread.currentThread().getName() + " paymentInfo_TimeOut(),id:" + id + " 耗时(秒)" + timeNumber;
  19.     }
  20. }

controller

  1. @RestController
  2. @Slf4j
  3. public class PaymentController {
  4.     @Resource
  5.     private PaymentService paymentService;
  7.     // 正常访问
  8.     @GetMapping("/payment/hystrix/ok/{id}")
  9.     public String paymentInfo_OK(@PathVariable("id") Integer id) {
  10.         String result = paymentService.paymentInfo_OK(id);
  11.         log.info("*****result:" + result);
  12.         return result;
  13.     }
  15.     // 超时访问
  16.     @GetMapping("/payment/hystrix/timeout/{id}")
  17.     public String paymentInfo_TimeOut(@PathVariable("id") Integer id) {
  18.         String result = paymentService.paymentInfo_TimeOut(id);
  19.         log.info("*****result:" + result);
  20.         return result;
  21.     }
  22. }

正常测试

启动eureka7001
启动eureka-provider-hystrix-payment8001
访问 http://localhost:8001/payment/hystrix/ok/31
访问 http://localhost:8001/payment/hystrix/timeout/31 每次调用耗时3秒

接下来，以上述为根基平台,从正确->错误->降级熔断->恢复

高并发测试

Jmeter压测测试

https://jmeter.apache.org/download_jmeter.cgi

开启Jmeter,来2w个并发压死8001, 2w个请求都去访问paymentInfo_TimeOut服务
然后访问 http://localhost:8001/payment/hystrix/timeout/31
搜狗截图20200824210718.png
搜狗截图20200824211224.png

Jmeter压测结论

卡死原因: tomcat的默认工作线程数被打满了,没有多余的线程来分解压力和处理
搜狗截图20200824211245.png
上面还只是服务提供者8001自己测试,假如此时外部的消费者80也来访问,那消费者只能干等,最终导致消费端80不满意,服务端8001直接被拖死

加入cloud-consumer-feign-hystrix-order80

pom

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>cloud2020</artifactId>
  7.         <groupId>com.carve.springcloud</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>cloud-consumer-feign-hystrix-order80</artifactId>
  14.     <dependencies>
  15.         <!--openfeign-->
  16.         <dependency>
  17.             <groupId>org.springframework.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  19.         </dependency>
  20.         <!--eureka client-->
  21.         <dependency>
  22.             <groupId>org.springframework.cloud</groupId>
  23.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  24.         </dependency>
  25.         <dependency>
  26.             <groupId>com.carve.springcloud</groupId>
  27.             <artifactId>cloud-api-common</artifactId>
  28.             <version>${project.version}</version>
  29.         </dependency>
  30.         <dependency>
  31.             <groupId>org.springframework.boot</groupId>
  32.             <artifactId>spring-boot-starter-web</artifactId>
  33.         </dependency>
  34.         <!--监控-->
  35.         <dependency>
  36.             <groupId>org.springframework.boot</groupId>
  37.             <artifactId>spring-boot-starter-actuator</artifactId>
  38.         </dependency>
  39.         <!--热部署-->
  40.         <dependency>
  41.             <groupId>org.springframework.boot</groupId>
  42.             <artifactId>spring-boot-devtools</artifactId>
  43.             <scope>runtime</scope>
  44.             <optional>true</optional>
  45.         </dependency>
  46.         <dependency>
  47.             <groupId>org.projectlombok</groupId>
  48.             <artifactId>lombok</artifactId>
  49.             <optional>true</optional>
  50.         </dependency>
  51.         <dependency>
  52.             <groupId>org.springframework.boot</groupId>
  53.             <artifactId>spring-boot-starter-test</artifactId>
  54.             <scope>test</scope>
  55.         </dependency>
  56.     </dependencies>
  58. </project>

yml

  1. server:
  2.   port: 80
  3. eureka:
  4.   client:
  5.     register-with-eureka: false
  6.     fetch-registry: true
  7.     service-url:
  8.       defaultZone: http://eureka7001.com:7001/eureka
  9. #      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka

启动类

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
public class OrderHystrixMain80 {
    public static void main(String[] args) {
        SpringApplication.run(OrderHystrixMain80.class, args);
    }
}

service

@Component
@FeignClient(value = "CLOUD-PROVIDER-HYSTRIX-PAYMENT")
public interface PaymentHystrixService {

    // 正常访问
    @GetMapping("/payment/hystrix/ok/{id}")
    String paymentInfo_OK(@PathVariable("id") Integer id);

    // 超时访问
    @GetMapping("/payment/hystrix/timeout/{id}")
    String paymentInfo_TimeOut(@PathVariable("id") Integer id);

}

controller

@RestController
@Slf4j
public class OrderHyrixController {
    @Autowired
    private PaymentHystrixService paymentHystrixService;

    // 正常访问
    @GetMapping("/consumer/payment/hystrix/ok/{id}")
    public String paymentInfo_OK(@PathVariable("id") Integer id) {
        String result = paymentHystrixService.paymentInfo_OK(id);
        log.info("*****result:" + result);
        return result;
    }

    // 超时访问
    @GetMapping("/consumer/payment/hystrix/timeout/{id}")
    public String paymentInfo_TimeOut(@PathVariable("id") Integer id) {
        String result = paymentHystrixService.paymentInfo_TimeOut(id);
        log.info("*****result:" + result);
        return result;
    }
}

测试

正常访问 http://localhost/consumer/payment/hystrix/ok/32

开启Jmeter，来2w个并发压死8001
http://localhost/consumer/payment/hystrix/ok/32
消费者80, 要么转圈圈, 要么消费端报超时错误
1542615-20200823152857145-1578071214.png

如何解决?解决的要求

超时导致服务器变慢(转圈) -> 超时不再等待
出错(宕机或程序运行出错) -> 出错要有兜底

解决

  • 对方服务(8001)超时了,调用者(80)不能一直卡死等待,必须有服务降级
  • 对方服务(8001)down机了,调用者(80)不能一直卡死等待,必须有服务降级
  • 对方服务(8001)ok,调用者(80)自己有故障或有自我要求(自己的等待时间小于服务提供者)