Spring Cloud Eureka--Zuul API网关 Hystrix实践

转x33g5p2x  于2021-11-17 转载在 Spring  
字(14.2k)|赞(0)|评价(0)|浏览(396)

统一的入口

1.新建spring模块：sp06-zuul

2.添加依赖

eureka+zuul

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <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">
  3.     <modelVersion>4.0.0</modelVersion>
  4.     <parent>
  5.         <artifactId>springcloud1</artifactId>
  6.         <groupId>cn.tedu</groupId>
  7.         <version>1.0-SNAPSHOT</version>
  8.     </parent>
  9.     
  10.     <groupId>cn.tedu</groupId>
  11.     <artifactId>sp06-zuul</artifactId>
  12.     <version>0.0.1-SNAPSHOT</version>
  13.     <name>sp06-zuul</name>
  14.     <description>Demo project for Spring Boot</description>
  16.     <properties>
  17.         <java.version>1.8</java.version>
  18.     </properties>
  20.     <dependencies>
  21.         <dependency>
  22.             <groupId>org.springframework.cloud</groupId>
  23.             <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  24.         </dependency>
  26.         <dependency>
  27.             <groupId>org.springframework.boot</groupId>
  28.             <artifactId>spring-boot-starter-test</artifactId>
  29.             <scope>test</scope>
  30.         </dependency>
  32.         <dependency>
  33.             <groupId>org.springframework.cloud</groupId>
  34.             <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
  35.         </dependency>
  36.         <dependency>
  37.             <groupId>cn.tedu</groupId>
  38.             <artifactId>sp01-commons</artifactId>
  39.             <version>1.0-SNAPSHOT</version>
  41.         </dependency>
  42.     </dependencies>
  44.     <build>
  45.         <plugins>
  46.             <plugin>
  47.                 <groupId>org.springframework.boot</groupId>
  48.                 <artifactId>spring-boot-maven-plugin</artifactId>
  49.             </plugin>
  50.         </plugins>
  51.     </build>
  53. </project>

3.yml配置

  1. spring:
  2.   application:
  3.     name: zuul
  4. # eureka2001 3001 3001 4001 5001 6001
  5. server:
  6.   port: 3001
  7. eureka:
  8.   client:
  9.     service-url:
  10.       defaultZone: http://eureka1:2001/eureka,http://eureka2:2002/eureka
  11. zuul:
  12.   routes:
  13.     # **包含深层子路径
  14.     # *只包含一层路径
  15.     # service-id 作为访问子路径，是默认设置
  16.     # 根据注册表中的注册信息，zuul可以自动配置，防止注册表不全
  17.     # 最好自己手动配置
  18.     item-service: /item-service/**
  19.     user-service: /user-service/**
  20.     order-service: /order-service/**

4.启动类注解

@EnableZuulProxy

  1. package cn.tedu.sp06;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
  7. @SpringBootApplication
  8. @EnableZuulProxy
  9. public class Sp06ZuulApplication {
  11.     public static void main(String[] args) {
  12.         SpringApplication.run(Sp06ZuulApplication.class, args);
  13.     }
  14. }

5. rest.http测试

  1. ### 获取订单的商品列表
  2. GET http://localhost:8001/ty4g33t3
  4. ### 减少商品库存
  5. POST http://localhost:8001/decreaseNumber
  6. Accept: application/json
  7. Content-Type: application/json
  9. [{"id":1, "name":"abc", "number":23},{"id":2, "name":"def", "number":11}]
  11. ### 获取用户
  12. GET http://localhost:8101/7
  13. ###
  14. GET http://localhost:8101/8
  15. ###
  16. GET http://localhost:8101/9
  17. ###
  18. GET http://localhost:8101/10
  19. ### 增加积分
  20. GET http://localhost:8101/8/score?score=1000
  22. ### 获取订单
  23. GET http://localhost:8201/iujhygf435tg
  24. ### 添加订单
  25. GET http://localhost:8201/add
  27. # ---------------------------------------------------------------------------------
  29. ### 获取订单的商品列表
  30. GET http://localhost:3001/item-service/ty4g33t3
  32. ### 减少商品库存
  33. POST http://localhost:3001/item-service/decreaseNumber
  34. Accept: application/json
  35. Content-Type: application/json
  37. [{"id":1, "name":"abc", "number":23},{"id":2, "name":"def", "number":11}]
  39. ### 获取用户
  40. GET http://localhost:3001/user-service/7
  41. ###
  42. GET http://localhost:3001/user-service/8
  43. ###
  44. GET http://localhost:3001/user-service/9
  45. ###
  46. GET http://localhost:3001/user-service/10
  47. ### 增加积分
  48. GET http://localhost:3001/user-service/8/score?score=1000
  50. ### 获取订单
  51. GET http://localhost:3001/order-service/iujhygf435tg
  52. ### 添加订单
  53. GET http://localhost:3001/order-service/add

统一权限校验

  • zuul的过滤器XZuulProxy，可以过滤客户端请求，在过滤器中可以检查访问权限
    前置、路由、后置\、错误过滤器
    测试：http://localhost:3001/item-service/jsihfhj 没有登录不允许访问
    http://localhost:3001/item-service/jsihfhj?token=ndhfjdhsjfdjs bfjhdskj 有令牌，则一登陆允许访问 （真正项目token应放在协议头，很测试没有登录系统）

1.新建过滤器类

  • AccessFilter 按照Zull的规则实现 继承ZuulFilter

2.重写ZuulFilter接口的四个抽象方法

  • 设置过滤器的类型
  • 设置过滤器添加的顺序号
  • 针对当前请求判断是否要执行下面的过滤代码
  • 过滤代码
  • @Component 自动扫描自动创建实例
    实现代码
  1. package cn.tedu.sp06.filter;
  3. import cn.tedu.web.util.JsonResult;
  4. import com.netflix.zuul.ZuulFilter;
  5. import com.netflix.zuul.context.RequestContext;
  6. import com.netflix.zuul.exception.ZuulException;
  7. import org.apache.commons.lang.StringUtils;
  8. import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants;
  9. import org.springframework.stereotype.Component;
  11. import javax.servlet.http.HttpServletRequest;
  13. @Component
  14. public class AccessFilter extends ZuulFilter {
  15.     /*设置过滤器的类型 pre routing post error*/
  16.     @Override
  17.     public String filterType() {
  18. // return "pre";
  19.         return FilterConstants.PRE_TYPE;
  20.     }
  22.     /*设置过滤器添加的顺序号 前置过滤器中有五个默认过滤器 自定义过滤器放在末尾 位置为6*/
  23.     @Override
  24.     public int filterOrder() {
  25.         return 6;
  26.     }
  27.     /*针对当前请求判断是否要执行下面的过滤代码*/
  28.     @Override
  29.     public boolean shouldFilter() {
  30.         /*调用商品需要判断权限 * 调用用户/订单不检查权限（这里只演示实现，不考虑业务逻辑） * */
  31.         //1.获得一个请求上下文对象
  32.         RequestContext ctx=RequestContext.getCurrentContext();
  33.         //2.从上下文对象获得调用后台服务的 serviceid 类型要转成字符串类型
  34.         String serviceId = (String)ctx.get(FilterConstants.SERVICE_ID_KEY);//"serviceId"
  35.         //3.如果调用了item-service 返回true
  36.         return "item-service".equals(serviceId);
  37.     }
  38.     /*过滤代码，检查权限*/
  39.     @Override
  40.     public Object run() throws ZuulException {
  41.         //1.获得上下文对象
  42.         RequestContext ctx=RequestContext.getCurrentContext();
  43.         //2.获得Request对象
  44.         HttpServletRequest request = ctx.getRequest();
  45.         //3.接收token参数
  46.         String token = request.getParameter("token");
  47.         //4.如果token不存在: ①null ②"" ③" "
  48.         if(StringUtils.isBlank(token)){ //区别idEmpty()
  49.             //5.阻止继续调用
  50.             ctx.setSendZuulResponse(false);//发送zuul响应关闭
  51.             //6.直接返回响应 提示未登录
  52.             //JsonResult--{code:400,msg:未登录,data:null}
  53.             String json=JsonResult.build().code(400).msg("not log in").toString();
  54.             //响应协议头
  55.             ctx.addZuulResponseHeader("Content-Type", "application/json;charset=UTF-8");
  56.             //响应协议体
  57.             ctx.setResponseBody(json);
  58.         }
  59.         return null;//zuul当前版本这个返回值不起任何作用
  60.     }
  61. }

设置过滤器的类型

实现效果

  • 为什么顺序号为6？？？
  • 前置过滤器中有五个默认过滤器PreDecorationFilter 自定义过滤器放在末尾 位置为6
    在第五个过滤器放入了serviceid

Zuul集成Ribbon

  • 负载均衡默认启用
  • 重试默认禁用
  • 在最前面重试会造成后台服务器大面积出现故障
    也可以启用重试，一般不会启用
    设置：
  • 添加spring-retry依赖
    xml <dependency> <groupId>org.springframework.retry</groupId> <artifactId>spring-retry</artifactId> </dependency>
  • yml配置启用重试
  1. spring:
  2.   application:
  3.     name: zuul
  4. # eureka2001 3001 3001 4001 5001 6001
  5. server:
  6.   port: 3001
  7. eureka:
  8.   client:
  9.     service-url:
  10.       defaultZone: http://eureka1:2001/eureka,http://eureka2:2002/eureka
  11. zuul:
  12.   routes:
  13.     # **包含深层子路径
  14.     # *只包含一层路径
  15.     # service-id 作为访问子路径，是默认设置
  16.     # 根据注册表中的注册信息，zuul可以自动配置，防止注册表不全
  17.     # 最好自己手动配置
  18.     item-service: /item-service/**
  19.     user-service: /user-service/**
  20.     order-service: /order-service/**
  21.   retryable: true
  22. # 对所有服务都有效的通用配置
  23. ribbon:
  24.   MaxAutoRetries: 1
  25. # 对某一个单独配置
  26. item-service:
  27.   ribbon:
  28.     MaxAutoRetries: 0

Zuul集成Hystrix

  • Hystrix是容错和限流工具（与sentinel相似）
  • Hystrix容错：通过降级处理
  • Hystrix限流：熔断

1. Zuul网关使用Hystrix进行同错处理，执行降级

  • Zuul默认已经启用Hystrix，任何基础配置都不用做
  • 调用后台服务失败，执行前面模块中的降级代码，返回降级结果
    ①给出错误提示
    ②返回缓存数据
    ③根据业务逻辑返回任何结果都可以

1.新建降级类 ItemFB 实现FallbackProvider接口

  1. package cn.tedu.sp06.fb;
  3. import cn.tedu.web.util.JsonResult;
  4. import org.springframework.cloud.netflix.zuul.filters.route.FallbackProvider;
  5. import org.springframework.http.HttpHeaders;
  6. import org.springframework.http.HttpStatus;
  7. import org.springframework.http.client.ClientHttpResponse;
  8. import org.springframework.stereotype.Component;
  10. import java.io.ByteArrayInputStream;
  11. import java.io.IOException;
  12. import java.io.InputStream;
  13. import java.nio.charset.StandardCharsets;
  15. @Component
  16. public class itemFB implements FallbackProvider {
  17.     /*设置针对哪个后台服务进行降级 * -item-service只针对商品服务降级 * *：对所有服务都应用当前降级类 * null:对所有服务都应用当前降级类 * */
  18.     @Override
  19.     public String getRoute() {
  20.         return "item-service";
  21.     }
  23.     /*向客户端返回的响应数据*/
  24.     @Override
  25.     public ClientHttpResponse fallbackResponse(String route, Throwable cause) {
  26.         return new ClientHttpResponse() {
  27.             @Override/*返回状态码对象*/
  28.             public HttpStatus getStatusCode() throws IOException {
  29.                 return HttpStatus.INTERNAL_SERVER_ERROR;
  30.             }
  32.             @Override/*状态码的码*/
  33.             public int getRawStatusCode() throws IOException {
  34.                 return HttpStatus.INTERNAL_SERVER_ERROR.value();
  35.             }
  37.             @Override/*状态码的文本*/
  38.             public String getStatusText() throws IOException {
  39.                 return HttpStatus.INTERNAL_SERVER_ERROR.getReasonPhrase();
  40.             }
  42.             @Override
  43.             public void close() {
  44.                 //用来关闭流
  45.                 //BAIS不占用底层系统资源，不需要关闭
  47.             }
  49.             @Override/*协议体*/
  50.             public InputStream getBody() throws IOException {
  51.                 //JsonResult -{code msg data}
  52.                 String json = JsonResult.build().code(500).msg("后台服务出错请稍后重试").toString();
  54.                 return new ByteArrayInputStream(json.getBytes("UTF-8"));
  55.             }
  56.             @Override/*协议头*/
  57.             public HttpHeaders getHeaders() {
  58.                 HttpHeaders h = new HttpHeaders();
  59.                 h.add("Content-Type", "application/json;charset=UTF-8");
  60.                 return h;
  61.             }
  62.         };
  63.     }
  64. }

2.新建降级类 ItemFB 实现FallbackProvider接口

  1. package cn.tedu.sp06.fb;
  3. import cn.tedu.web.util.JsonResult;
  4. import org.springframework.cloud.netflix.zuul.filters.route.FallbackProvider;
  5. import org.springframework.http.HttpHeaders;
  6. import org.springframework.http.HttpStatus;
  7. import org.springframework.http.client.ClientHttpResponse;
  8. import org.springframework.stereotype.Component;
  10. import java.io.ByteArrayInputStream;
  11. import java.io.IOException;
  12. import java.io.InputStream;
  14. @Component
  15. public class orderFB implements FallbackProvider {
  16.     /*设置针对哪个后台服务进行降级 * -item-service只针对商品服务降级 * *：对所有服务都应用当前降级类 * null:对所有服务都应用当前降级类 * */
  17.     @Override
  18.     public String getRoute() {
  19.         return "order-service";
  20.     }
  22.     /*向客户端返回的响应数据*/
  23.     @Override
  24.     public ClientHttpResponse fallbackResponse(String route, Throwable cause) {
  25.         return new ClientHttpResponse() {
  26.             @Override/*返回状态码对象*/
  27.             public HttpStatus getStatusCode() throws IOException {
  28.                 return HttpStatus.INTERNAL_SERVER_ERROR;
  29.             }
  31.             @Override/*状态码的码*/
  32.             public int getRawStatusCode() throws IOException {
  33.                 return HttpStatus.INTERNAL_SERVER_ERROR.value();
  34.             }
  36.             @Override/*状态码的文本*/
  37.             public String getStatusText() throws IOException {
  38.                 return HttpStatus.INTERNAL_SERVER_ERROR.getReasonPhrase();
  39.             }
  41.             @Override
  42.             public void close() {
  43.                 //用来关闭流
  44.                 //BAIS不占用底层系统资源，不需要关闭
  46.             }
  48.             @Override/*协议体*/
  49.             public InputStream getBody() throws IOException {
  50.                 //JsonResult -{code msg data}
  51.                 String json = JsonResult.build().code(500).msg("后台服务出错请稍后重试").toString();
  53.                 return new ByteArrayInputStream(json.getBytes("UTF-8"));
  55.             }
  57.             @Override/*协议头*/
  58.             public HttpHeaders getHeaders() {
  59.                 HttpHeaders h = new HttpHeaders();
  60.                 h.add("Content-Type", "application/json;charset=UTF-8");
  61.                 return h;
  62.             }
  63.         };
  64.     }
  65. }

实现效果

2. Zuul集成Hystrix实现限流，熔断

  • 当流量 过大，后台服务出现故障，可以断开链路，限制后台故障服务
  • 在06添加断路器，断开连接后，直接执行06的降级代码（不会进行远程调用），返回降级结果（短路请求），执行效率很高
    断路器打开条件：
    ①20次/10s 请求，必须首先满足
    ②50%请求出错，执行了降级代码
    if(20){if(50%){}}
  • 断路器打开之后，会进入半开状态
    在半开状态下，会向服务器尝试发送一次客户端调用
    调用成功，自动关闭断路器恢复正常；
    调用失败，继续保持打开状态。再进入半开状态
    打开 半开 打开 半开…循环

Hystrix dashboard

  • 对降流和熔断的情况进行监控，可以通过监控快速定位故障模块
  • 调用02.03.04在06产生监控日志 使用Actuator工具
  • Actuator是spring提供的监控指标工具，可以暴露项目的各种监控指标
    ①健康状态
    ②spring容器中的所有对象
    ③spring mvc 映射的所有路径
    ④环境变量
    ⑤堆内存镜像（java虚拟机使用的堆内存）

暴露Actuator监控指标

1. Actuator依赖→06

  1. <dependency>
  2.             <groupId>org.springframework.cloud</groupId>
  3.             <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
  4.         </dependency>

actuator依赖于zuul

2. 06yml配置

  1. m.e.w.e.i="*"  # *:暴露所有监控指标
  2. m.e.w.e.i=health,beans,mappings  # *:暴露指定监控指标
  3. m.e.w.e.i=hystrix.stream
  5. ***********************************************************
  6. #暴露actuator的监控指标
  7. management:
  8.   endpoints:
  9.     web:
  10.       exposure:
  11.         include: "*"  #暴露所有监控

3.访问

http://localhost:3001/actuator

  1. ### actuator
  2. GET http://localhost:3001/actuator
  3. ###
  4. GET http://localhost:3001/actuator/health
  5. ###
  6. GET http://localhost:3001/actuator/info
  7. ###
  8. GET http://localhost:3001/actuator/beans
  9. ###
  10. GET http://localhost:3001/actuator/mappings
  11. ###
  12. GET http://localhost:3001/actuator/heapdump
  13. ###
  14. GET http://localhost:3001/actuator/hystrix.stream

搭建Hystrix-dashboard（仪表盘）

1. 新建spring模块： sp07-hystrix-dashboard

2. 调整pom.xml 添加hystrix dashboard依赖

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <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">
  3.     <modelVersion>4.0.0</modelVersion>
  4.     <parent>
  5.         <artifactId>springcloud1</artifactId>
  6.         <groupId>cn.tedu</groupId>
  7.         <version>1.0-SNAPSHOT</version>
  8.     </parent>
  9.     <groupId>cn.tedu</groupId>
  10.     <artifactId>sp07-hystrix-dashboard</artifactId>
  11.     <version>0.0.1-SNAPSHOT</version>
  12.     <name>sp07-hystrix-dashboard</name>
  13.     <description>Demo project for Spring Boot</description>
  15.     <properties>
  16.         <java.version>1.8</java.version>
  17.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  18.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  20.     </properties>
  22.     <dependencies>
  23.         <dependency>
  24.             <groupId>org.springframework.cloud</groupId>
  25.             <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
  26.         </dependency>
  28.         <dependency>
  29.             <groupId>org.springframework.boot</groupId>
  30.             <artifactId>spring-boot-starter-test</artifactId>
  31.             <scope>test</scope>
  32.         </dependency>
  33.     </dependencies>
  36.     <build>
  37.         <plugins>
  38.             <plugin>
  39.                 <groupId>org.apache.maven.plugins</groupId>
  40.                 <artifactId>maven-compiler-plugin</artifactId>
  41.                 <version>3.8.1</version>
  42.                 <configuration>
  43.                     <source>1.8</source>
  44.                     <target>1.8</target>
  45.                     <encoding>UTF-8</encoding>
  46.                 </configuration>
  47.             </plugin>
  48.             <plugin>
  49.                 <groupId>org.springframework.boot</groupId>
  50.                 <artifactId>spring-boot-maven-plugin</artifactId>
  51.                 <version>2.4.1</version>
  52.                 <configuration>
  53.                     <mainClass>cn.tedu.sp07.Sp07HystrixDashboardApplication</mainClass>
  54.                 </configuration>
  55.                 <executions>
  56.                     <execution>
  57.                         <id>repackage</id>
  58.                         <goals>
  59.                             <goal>repackage</goal>
  60.                         </goals>
  61.                     </execution>
  62.                 </executions>
  63.             </plugin>
  64.         </plugins>
  65.     </build>
  67. </project>

3. 配置yml

  1. server:
  2.   port: 4001
  3. #允许抓取日志的服务器列表
  4. hystrix:
  5.   dashboard:
  6.     proxy-stream-allow-list: localhost

4. 启动类添加注解

@EnableHystrixDashboard

  1. package cn.tedu.sp07;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
  7. @SpringBootApplication
  8. @EnableHystrixDashboard
  9. public class Sp07HystrixDashboardApplication {
  11.     public static void main(String[] args) {
  12.         SpringApplication.run(Sp07HystrixDashboardApplication.class, args);
  13.     }
  15. }

5. 启动访问

  1. http://localhost:4001/hystrix
  2. http://localhost:3001/actuator/hystrix.stream

版权说明 : 本文为转载文章, 版权归原作者所有 版权申明

原文链接 : https://blog.csdn.net/weixin_55740233/article/details/121370733

内容来源于网络，如有侵权，请联系作者删除！

JavaHystrix后端eureka开发语言

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com