Spring Cloud系列教程(十六):下一代网关服务Gateway-入门篇(Finchley版本)

本文主要是介绍Spring Cloud系列教程(十六):下一代网关服务Gateway-入门篇(Finchley版本),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

官网文档: https://cloud.spring.io/spring-cloud-static/spring-cloud-gateway/2.2.1.RELEASE/reference/html/

一.什么是Spring Cloud Gateway

来自官方文档的一句话: Spring Cloud Gateway提供了一个在Spring生态系统之上构建的API网关,包括:Spring 5,Spring Boot 2和Project Reactor。Spring Cloud Gateway旨在提供一种简单而有效的方法来路由到API,并为它们提供跨领域的关注,例如:安全性,监视/指标和弹性。并且从引入的spring-cloud-starter-gateway依赖信息可见,Spring Cloud Gateway底层是基于SpringBoot2.x、Project Reactor和Spring5 WebFlux响应式驱动编程构建,而Spring5底层又是基于netty异步实现,可谓性能不一般啊。

由于响应式编程的特性,Spring WebFlux和Reactor底层需要支持异步的运行环境,比如Netty和Undertow;也可以运行在支持异步I/O的Servlet 3.1的容器之上,比如Tomcat(8.0.23及以上)和Jetty(9.0.4及以上)。而且Spring Cloud Gateway底层默认通过netty启动,所以在使用Gateway网关组件时,无需引入Tomcat容器组件;

二. Spring Cloud Gateway能解决什么问题

在这里插入图片描述
网关具有身份认证与安全、审查与监控、动态路由、负载均衡、缓存、请求分片与管理、静态响应处理等功能。当然最主要的职责还是与“外界联系”,起到一个门户的作用。

总结一下,网关应当具备以下功能:

性能: API 高可用,负载均衡,容错机制。
安全: 权限身份认证、脱敏,流量清洗,后端签名(保证全链路可信调用),黑名单(非法调用的限制)。
日志: 日志记录,一旦涉及分布式,全链路跟踪必不可少。
缓存: 数据缓存。
监控: 记录请求响应数据,API 耗时分析,性能监控。
限流: 流量控制,错峰流控,可以定义多种限流规则。
灰度: 线上灰度部署,可以减小风险。
路由: 动态路由规则。

三. 生产上网关和Nginx搭配部署

1、前端页面调用接口请求Nginx服务器,如果是静态资源,则返回Nginx上缓存的资源

2、Nginx负载均衡调用后端的网关(网关服务多台部署,高可用)

3、网关做身份验证,服务路由,日志记录等等操作,

4、网关调用业务接口后,返回业务数据到页面。

四. 开始实践

在这里插入图片描述

五. 网关服务springcloud-api-gateway

5.1 创建maven工程,pom.xml文件

 <!--SpringBoot依赖版本--><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.3.RELEASE</version><relativePath/></parent><!--项目编码、jdk版本、SpringCloud版本定义--><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version><spring-cloud.version>Finchley.RELEASE</spring-cloud.version></properties><!--声明管理SpringCloud版本依赖信息--><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><dependencies><!-- SpringBoot整合Gateway --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency></dependencies>

5.2 配置网关路由

Spring Cloud Gateway 网关路由有两种配置方式:

  • 在配置文件yml 中配置
  • 通过@Bean自定义 RouteLocator,在启动主类 Application中配置

这两种方式是等价的,建议使用 yml方式进配置。

1. application.yml形式

#端口号
server:port: 8015
#定义服务名称
spring:application:name: api-gateway   # 应用名称cloud:gateway:# 路由规则routes:#通过Path匹配路由- id: product-service        # 路由 ID,唯一uri: http://127.0.0.1:8016  # 目标 URI,路由到接口http://127.0.0.1:8016/product/getProductInfopredicates:                # 断言(判断条件)- Path=/product/**       # 匹配对应 URL 的请求,将匹配到的请求追加在目标 URI 之后#Gateway日志级别
logging:level:org.springframework.cloud.gateway: debug

对上述字段含义解释一下:

  • id: 我们自定义的路由 ID,保持唯一
  • uri: 目标服务地址
  • predicates: 路由条件,Predicate 接受一个输入参数,返回一个布尔值结果。该接口包含多种默认方法来将 Predicate 组合成其他复杂的逻辑(比如:与,或,非)。
  • filters: 过滤规则,本示例暂时没用。

上述配置是当请求:http://127.0.0.1:8015/product/getProductInfo时,会通过product匹配到路由,通过IP+Port,自动转发到http://127.0.0.1:8016 所在的服务机器,然后拼接http://127.0.0.1:8016 +/product/getProductInfo,组成一个完整的请求地址,请求到Product服务接口: http://127.0.0.1:8015/product/getProductInfo,因此网关暴露的接口地址并非真实的API接口地址,在网关层会进行过滤转发。

2. 通过@Bean自定义RouteLocator形式

package com.thinkingcao.gateway.route;import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** @desc:  java写法路由配置* @author: cao_wencao* @date: 2020-06-30 14:28*/
@Slf4j
@Configuration
public class ProductRouteLocator{@Beanpublic RouteLocator customRouteLocator(RouteLocatorBuilder builder) {return builder.routes().route("product-service", r -> r.path("/product/**").uri("http://127.0.0.1:8016")).build();}
}

上面配置类等同于yml形式配置,解释如下

id: 定义一个idproduct-service
path: 定义一个path匹配/product/**
uri: 转发的urihttp://127.0.0.1:8016

5.3 启动类

package com.thinkingcao.gateway;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;/*** @desc:  Api Gateway网关* @author: cao_wencao* @date: 2020-06-23 13:07*/
@SpringBootApplication
public class AppGateway {public static void main(String[] args) {SpringApplication.run(AppGateway.class, args);}
}

六. 商品服务springcloud-product-service

6.1 创建maven项目,pom依赖如下

 <!--SpringBoot依赖版本--><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.3.RELEASE</version><relativePath/></parent><!--项目编码、jdk版本、SpringCloud版本定义--><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version><spring-cloud.version>Finchley.RELEASE</spring-cloud.version></properties><!--声明管理SpringCloud版本依赖信息--><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><!--依赖信息--><dependencies><!-- SpringBoot整合Web组件 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--Lombok简化代码插件--><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency></dependencies><!--maven插件--><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>

6.2 application.yml

server:port: 8016
#定义服务名称
spring:application:name: product-service

6.3 商品服务接口

/*** @desc:   商品服务* @author: cao_wencao* @date: 2020-06-28 10:34*/
@RestController
@RequestMapping("/product")
public class ProductController {@RequestMapping("/getProductInfo")public Map<String,String> getProductInfo(){Map<String,String> productsMap = new HashMap<>();productsMap.put("productNo","111");productsMap.put("productName","荔枝");productsMap.put("productDesc","一骑红尘妃子笑,无人知是荔枝来");productsMap.put("productPrice","11.0");productsMap.put("productWeight","10.0");return productsMap;}
}

6.4 启动类

/*** @desc:   商品服务* @author: cao_wencao* @date: 2020-06-23 13:17*/
@SpringBootApplication
public class AppProduct{public static void main(String[] args) {SpringApplication.run(AppProduct.class,args);}
}

七. 运行测试

访问http://127.0.0.1:8015/product/getProductInfo,路由转发到http://127.0.0.1:8016/product/getProductInfo
在这里插入图片描述

八. 源码

源码:https://github.com/Thinkingcao/SpringCloudLearning/tree/master/springcloud-first-gateway
下一篇: Spring Cloud系列教程(十七):下一代网关服务Gateway-谓词篇(Finchley版本)

这篇关于Spring Cloud系列教程(十六):下一代网关服务Gateway-入门篇(Finchley版本)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/863414

相关文章

springboot集成easypoi导出word换行处理过程

《springboot集成easypoi导出word换行处理过程》SpringBoot集成Easypoi导出Word时,换行符n失效显示为空格,解决方法包括生成段落或替换模板中n为回车,同时需确... 目录项目场景问题描述解决方案第一种:生成段落的方式第二种:替换模板的情况,换行符替换成回车总结项目场景s

SpringBoot集成redisson实现延时队列教程

《SpringBoot集成redisson实现延时队列教程》文章介绍了使用Redisson实现延迟队列的完整步骤,包括依赖导入、Redis配置、工具类封装、业务枚举定义、执行器实现、Bean创建、消费... 目录1、先给项目导入Redisson依赖2、配置redis3、创建 RedissonConfig 配

SpringBoot中@Value注入静态变量方式

《SpringBoot中@Value注入静态变量方式》SpringBoot中静态变量无法直接用@Value注入,需通过setter方法,@Value(${})从属性文件获取值,@Value(#{})用... 目录项目场景解决方案注解说明1、@Value("${}")使用示例2、@Value("#{}"php

SpringBoot分段处理List集合多线程批量插入数据方式

《SpringBoot分段处理List集合多线程批量插入数据方式》文章介绍如何处理大数据量List批量插入数据库的优化方案:通过拆分List并分配独立线程处理,结合Spring线程池与异步方法提升效率... 目录项目场景解决方案1.实体类2.Mapper3.spring容器注入线程池bejsan对象4.创建

线上Java OOM问题定位与解决方案超详细解析

《线上JavaOOM问题定位与解决方案超详细解析》OOM是JVM抛出的错误,表示内存分配失败,:本文主要介绍线上JavaOOM问题定位与解决方案的相关资料,文中通过代码介绍的非常详细,需要的朋... 目录一、OOM问题核心认知1.1 OOM定义与技术定位1.2 OOM常见类型及技术特征二、OOM问题定位工具

基于 Cursor 开发 Spring Boot 项目详细攻略

《基于Cursor开发SpringBoot项目详细攻略》Cursor是集成GPT4、Claude3.5等LLM的VSCode类AI编程工具,支持SpringBoot项目开发全流程,涵盖环境配... 目录cursor是什么?基于 Cursor 开发 Spring Boot 项目完整指南1. 环境准备2. 创建

Python一次性将指定版本所有包上传PyPI镜像解决方案

《Python一次性将指定版本所有包上传PyPI镜像解决方案》本文主要介绍了一个安全、完整、可离线部署的解决方案,用于一次性准备指定Python版本的所有包,然后导出到内网环境,感兴趣的小伙伴可以跟随... 目录为什么需要这个方案完整解决方案1. 项目目录结构2. 创建智能下载脚本3. 创建包清单生成脚本4

Spring Security简介、使用与最佳实践

《SpringSecurity简介、使用与最佳实践》SpringSecurity是一个能够为基于Spring的企业应用系统提供声明式的安全访问控制解决方案的安全框架,本文给大家介绍SpringSec... 目录一、如何理解 Spring Security?—— 核心思想二、如何在 Java 项目中使用?——

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot?二、环境准备与部署2.1 安装 RustF

springboot中使用okhttp3的小结

《springboot中使用okhttp3的小结》OkHttp3是一个JavaHTTP客户端,可以处理各种请求类型,比如GET、POST、PUT等,并且支持高效的HTTP连接池、请求和响应缓存、以及异... 在 Spring Boot 项目中使用 OkHttp3 进行 HTTP 请求是一个高效且流行的方式。