Spring Cloud（九）：Hystrix案例-Jmeter测试高并发访问

清疚 2022-11-11 13:06 93阅读 0赞

## 1. Hystrix 案例 ##

注册中心使用单机版。

### 1.1 新建模块 ###

新建 cloud-provider-hystrix-payment8001 模块

### 1.2 POM ###

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>spring-cloud-demo</artifactId>
            <groupId>com.lele.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>cloud-provider-hystrix-payment8001</artifactId>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            <dependency>
                <groupId>com.lele.springcloud</groupId>
                <artifactId>cloud-api-commons</artifactId>
                <version>${project.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
    </project>

### 1.3 YML ###

server:
      port: 8001
    
    spring:
      application:
        name: cloud-provider-hystrix-payment
    
    eureka:
      client:
        register-with-eureka: true
        fetch-registry: true
        service-url:
          #defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
          defaultZone: http://eureka7001.com:7001/eureka

### 1.4 主启动类 ###

package com.lele.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    /**
     * @author: lele
     * @date: 2021/3/20 13:50
     * @description:
     */
    @SpringBootApplication
    @EnableEurekaClient
    public class PaymentHystrixMain8001 {
        
        public static void main(String[] args) {
        
            SpringApplication.run(PaymentHystrixMain8001.class, args);
        }
    }

### 1.5 业务类 ###

package com.lele.springcloud.service;
    
    import org.springframework.stereotype.Service;
    
    import java.util.concurrent.TimeUnit;
    
    /**
     * @author: lele
     * @date: 2021/3/20 13:53
     * @description:
     */
    @Service
    public class PaymentService {
        
    
        /**
         * 正常访问：肯定OK
         * @param id
         * @return
         */
        public String paymentInfo_OK(Integer id) {
        
            return "线程池：" + Thread.currentThread().getName()+"  paymentInfo_OK,id:" + id+"\t"+"哈哈~";
        }
    
        public String paymentInfo_TimeOut(Integer id) {
        
            int timeNumber = 3;
            try {
        
                TimeUnit.SECONDS.sleep(timeNumber);
            } catch(InterruptedException e) {
        
                e.printStackTrace();
            }
            return "线程池："+ Thread.currentThread().getName()+"  paymentInfo_OK,id" + id+"\t"+"~~"+"耗时（秒）"+timeNumber;
        }
    }

*  controller

package com.lele.springcloud.controller;
    
    import com.lele.springcloud.service.PaymentService;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    
    import javax.annotation.Resource;
    
    /**
     * @author: lele
     * @date: 2021/3/20 14:06
     * @description:
     */
    @RestController
    @Slf4j
    public class PaymentController {
        
    
        @Resource
        private PaymentService paymentService;
    
        @Value("${server.port}")
        private String serverPort;
    
        @GetMapping("/payment/hystrix/ok/{id}")
        public String paymentInfo_OK(@PathVariable("id") Integer id) {
        
            String result = paymentService.paymentInfo_OK(id);
            log.info("******result:" + result);
            return result;
        }
    
        @GetMapping("/payment/hystrix/timeout/{id}")
        public String paymentInfo_TimeOut(@PathVariable("id") Integer id) {
        
            String result = paymentService.paymentInfo_TimeOut(id);
            log.info("******result:" + result);
            return result;
        }
    }

**正常测试**  
启动eureka7001：

启动cloud-provider-hystrix-payment8001

访问：http://localhost:8001/payment/hystrix/ok/1  
![在这里插入图片描述][20210320142227976.png]

访问：http://localhost:8001/payment/hystrix/timeout/1  
![在这里插入图片描述][20210320142415877.png]

上述module均OK  
以上述为根基平台，从正确->错误->降级熔断->恢复

**高并发测试**  
开启Jmeter，来10000个并发压死8001，10000个请求都去访问paymentInfo\_TimeOut服务。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70]

两个都在自己转圈圈

为什么会被卡死：  
tomcat的默认的工作线程数被打满了，没有多余的线程来分解压力和处理。

**Jmeter压测结论**  
上面还是服务提供者8001自己测试，假如此时外部的消费者80也来访问，那消费者只能干等，最终导致消费端80不满意，服务端8001直接被拖死。

## 2. 加入80客户端 ##

新建：cloud-consumer-feign-hystrix-order80

### 2.1 POM ###

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>spring-cloud-demo</artifactId>
            <groupId>com.lele.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>cloud-consumer-feign-hystrix-order80</artifactId>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
            <dependency>
                <groupId>com.lele.springcloud</groupId>
                <artifactId>cloud-api-commons</artifactId>
                <version>${project.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    </project>

### 2.2 yml ###

server:
      port: 80
    
    eureka:
      client:
        register-with-eureka: false
        service-url:
          defaultZone: http://eureka7001.com:7001/eureka/

### 2.3 主启动类 ###

package com.lele.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.openfeign.EnableFeignClients;
    
    /**
     * @author: lele
     * @date: 2021/3/20 17:35
     * @description:
     */
    @SpringBootApplication
    @EnableFeignClients
    public class OrderHystrixMain80 {
        
    
        public static void main(String[] args) {
        
            SpringApplication.run(OrderHystrixMain80.class,args);
        }
    }

### 2.4 业务类 ###

*  PaymentHystrixService

package com.lele.springcloud.service;
    
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.stereotype.Component;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    
    import java.nio.file.Path;
    
    /**
     * @author: lele
     * @date: 2021/3/20 17:39
     * @description:
     */
    @Component
    @FeignClient(value = "CLOUD-PROVIDER-HYSTRIX-PAYMENT")
    public interface PaymentHystrixService {
        
    
        @GetMapping("/payment/hystrix/ok/{id}")
        public String paymentInfo_OK(@PathVariable("id") Integer id);
    
        @GetMapping("/payment/hystrix/timeout/{id}")
        public String paymentInfo_TimeOut(@PathVariable("id") Integer id);
    }

*  controller

package com.lele.springcloud.controller;
    
    import com.lele.springcloud.service.PaymentHystrixService;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RestController;
    
    import javax.annotation.Resource;
    
    /**
     * @author: lele
     * @date: 2021/3/20 17:45
     * @description:
     */
    @RestController
    @Slf4j
    public class OrderHystrixController {
        
    
        @Resource
        private PaymentHystrixService paymentHystrixService;
    
        @GetMapping("/consumer/payment/hystrix/ok/{id}")
        public String paymentInfo_OK(@PathVariable("id") Integer id) {
        
            String result = paymentHystrixService.paymentInfo_OK(id);
            return result;
        }
    
        @GetMapping("/consumer/payment/hystrix/timeout/{id}")
        public String paymentInfo_TimeOut(@PathVariable("id") Integer id) {
        
            String result = paymentHystrixService.paymentInfo_TimeOut(id);
            return result;
        }
    }

访问：http://localhost/consumer/payment/hystrix/ok/1  
![在这里插入图片描述][20210320180140256.png]

**高并发测试**  
5W个线程压8001

消费端80微服务再去访问正常的OK微服务8001地址  
http://localhost/consumer/payment/hystrix/timeout/31

消费者80:  
要么转圈圈等待  
要么消费端报超时错误

**故障现象和导致原因**  
8001同一层次的其他接口服务被困死，因为tomcat线程里面的工作线程已经被挤占完毕

80此时调用8001，客户端访问响应缓慢，转圈圈

**如何解决？解决的要求**  
超时导致服务器变慢（转圈）:超时不再等待  
出错（宕机或程序运行出错）:出错要有兜底

**解决:**

*  对方服务（8001）超时了，调用者（80）不能一直卡死等待，必须有服务降级。
 *  对方服务（8001）down机了，调用者（80）不能一直卡死等待，必须有服务降级。
 *  对方服务（8001）OK，调用者（80）自己出故障或有自我要求（自己的等待时间小于服务提供者），自己处理降级。

[20210320142227976.png]: /images/20221022/fd16120608f34540a0502011cf6bc535.png
[20210320142415877.png]: https://img-blog.csdnimg.cn/20210320142415877.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20210320162258424.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl,size_16,color_FFFFFF,t_70
[20210320180140256.png]: https://img-blog.csdnimg.cn/20210320180140256.png