50-51_Hystrix 支付微服务构建，JMeter 高并发压测后卡顿

2022年02月25日 14:32 · 阅读(210) ·

Hystrix 支付微服务构建

新建 cloud-provider-hystrix-payment8001

1.pom.xml

  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>msclound</artifactId>
  7.         <groupId>com.atguigu.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.         <!--web-->
  26.         <dependency>
  27.             <groupId>org.springframework.boot</groupId>
  28.             <artifactId>spring-boot-starter-web</artifactId>
  29.         </dependency>
  30.         <dependency>
  31.             <groupId>org.springframework.boot</groupId>
  32.             <artifactId>spring-boot-starter-actuator</artifactId>
  33.         </dependency>
  34.         <dependency><!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  35.             <groupId>com.atguigu.springcloud</groupId>
  36.             <artifactId>cloud-api-commons</artifactId>
  37.             <version>${project.version}</version>
  38.         </dependency>
  39.         <dependency>
  40.             <groupId>org.springframework.boot</groupId>
  41.             <artifactId>spring-boot-devtools</artifactId>
  42.             <scope>runtime</scope>
  43.             <optional>true</optional>
  44.         </dependency>
  45.         <dependency>
  46.             <groupId>org.projectlombok</groupId>
  47.             <artifactId>lombok</artifactId>
  48.             <optional>true</optional>
  49.         </dependency>
  50.         <dependency>
  51.             <groupId>org.springframework.boot</groupId>
  52.             <artifactId>spring-boot-starter-test</artifactId>
  53.             <scope>test</scope>
  54.         </dependency>
  55.     </dependencies>
  57.     <properties>
  58.         <maven.compiler.source>8</maven.compiler.source>
  59.         <maven.compiler.target>8</maven.compiler.target>
  60.     </properties>
  62. </project>

2.application.yml

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

3.主启动类

  1. package com.atguigu.springcloud;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  7. @EnableEurekaClient
  8. @SpringBootApplication
  9. public class PaymentHystrixMain8001 {
  10.     public static void main(String[] args) {
  11.         SpringApplication.run(PaymentHystrixMain8001.class,args);
  12.     }
  13. }

4.业务类

(1)PaymentService

  1. package com.atguigu.springcloud.service;
  3. import org.springframework.stereotype.Service;
  5. import java.util.concurrent.TimeUnit;
  7. @Service
  8. public class PaymentService {
  9.     /**
  10.      * 正常访问，一切 OK
  11.      * @param id
  12.      * @return
  13.      */
  14.     public String paymentInfo_OK(Integer id){
  15.         return "线程池："+Thread.currentThread().getName()+"paymentInfo_OK，id："+id+"\t"+":-)";
  16.     }
  18.     /**
  19.      * 超时访问，演示降级
  20.      * @param id
  21.      * @return
  22.      */
  23.     public String paymentInfo_TimeOut(Integer id){
  24.         try {
  25.             TimeUnit.SECONDS.sleep(3);
  26.         } catch (InterruptedException e) {
  27.             e.printStackTrace();
  28.         }
  30.         return "线程池："+Thread.currentThread().getName()+"paymentInfo_TimeOut，id："+id+"\t"+":-(，耗费 3 秒";
  31.     }
  32. }

(2)PaymentController

  1. package com.atguigu.springcloud.controller;
  3. import com.atguigu.springcloud.service.PaymentService;
  4. import lombok.extern.slf4j.Slf4j;
  5. import org.springframework.beans.factory.annotation.Value;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.PathVariable;
  8. import org.springframework.web.bind.annotation.RestController;
  10. import javax.annotation.Resource;
  12. @Slf4j
  13. @RestController
  14. public class PaymentController {
  15.     @Resource
  16.     private PaymentService paymentService;
  18.     @Value("${server.port}")
  19.     private String serverPort;
  21.     @GetMapping("/payment/hystrix/ok/{id}")
  22.     public String paymentInfo_OK(@PathVariable("id") Integer id){
  23.         String result = paymentService.paymentInfo_OK(id);
  24.         log.info("*******result："+result);
  25.         return result;
  26.     }
  28.     @GetMapping("/payment/hystrix/timeout/{id}")
  29.     public String paymentInfo_TimeOut(@PathVariable("id") Integer id){
  30.         String result = paymentService.paymentInfo_TimeOut(id);
  31.         log.info("*******result："+result);
  32.         return result;
  33.     }
  34. }

测试

● 启动 cloud-eureka-server7001
● 启动 cloud-provider-hystrix-payment8001

浏览器访问：http://localhost:8003/payment/hystrix/ok/31
返回结果： 

  1. 线程池：http-nio-8003-exec-1paymentInfo_OK，id：31 :-)

浏览器访问：http://localhost:8003/payment/hystrix/timeout/31
返回结果： 

  1. 线程池：http-nio-8003-exec-3paymentInfo_TimeOut，id：31 :-(，耗费 3 秒

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

JMeter 高并发压测后卡顿

上述在非高并发情形下，还能勉强满足

下面使用 Jmeter 压测测试

开启 Jmeter，来 20000 个并发压死 8001，20000 个请求都去访问 paymentInfo_TimeOut 服务

1.测试计划中右键添加 - 线程 - 线程组（线程组 payment2020，线程数：200，线程数：100，其他参数默认）

2.刚刚新建线程组 payment2020，右键它 - 添加 - 取样器 - Http请求 - 路径，输入 http://localhost:8003/payment/hystrix/timeout/31

3.点击绿色三角形图标启动。

启动后，可以看到后端控制台开始疯狂打印日志

  1. *******result：线程池：http-nio-8003-exec-33paymentInfo_TimeOut，id：31    :-(，耗费 3 秒
  2. *******result：线程池：http-nio-8003-exec-99paymentInfo_TimeOut，id：31    :-(，耗费 3 秒
  3. *******result：线程池：http-nio-8003-exec-83paymentInfo_TimeOut，id：31    :-(，耗费 3 秒
  4. *******result：线程池：http-nio-8003-exec-35paymentInfo_TimeOut，id：31    :-(，耗费 3 秒
  5. *******result：线程池：http-nio-8003-exec-81paymentInfo_TimeOut，id：31    :-(，耗费 3 秒

这个时候，浏览器输入 http://localhost:8003/payment/hystrix/ok/31

本来秒出的结果也需要几秒才出来

原因：tomcat 的默认的工作线程数被打满了，没有多余的线程来分解压力和处理。

Jmeter 压测结论

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