Nacos与Gateway微服务网关

2024-08-29 20:20
文章标签 服务 nacos 网关 gateway

本文主要是介绍Nacos与Gateway微服务网关,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

结合E:\Codes\Idea_java_works\apesource\springboot\微服务\springboot_gateway

简介

在此之前,我们调用服务需要记忆不同的端口号,非常麻烦,使用gateway网关就可以直接访问网关的端口号,

让网关在nacos中寻找服务,并且转发到相对应服务的端口号。

Gateway服务⽹关 Spring Cloud Gateway 是 Spring Cloud 的⼀个全新项⽬,该项⽬是基于 Spring 5.0,Spring Boot 2.0 和 Project Reactor 等响应式编程和事件流技术开发的⽹关,它旨在为微服务架构提供 ⼀种简单有效的统⼀的 API 路由管理⽅式。

操作流程

  1. 创建gateway服务,引⼊依赖 创建服务: 创建⼀个 api-gateway 的模块,导⼊相关依赖
<!--⽹关-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId><version>2.1.3.RELEASE</version>
</dependency>
<!--nacos服务发现依赖(gateway⾼级使⽤需要)-->
<dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId><version>2.1.3.RELEASE</version>
</dependency>
  1. 编写api-gateway的配置文件
#########################高级版本##################################
#启动类添加注解@EnabLeDiscoveryClient,项目添加坐标
server:port: 7000
spring:application:name: api-gatewaycloud:nacos:discovery:server-addr: localhost:8848gateway:discovery:locator:enabled: true                               # 让gateway可以发现nacos中的微服务routes:                                         # 路由数组[路由就是指定当请求满⾜什么条件的时候转到哪个微服务]- id: product_routeuri: lb://server-product                    # 指的是从nacos中按照名称获取微服务,并遵循负载均衡策略order: 1                                    # 路由优先级 数字越低优先级越高predicates:                                 # 断言- Path=/product/**                        # 当请求路径满⾜Path指定的规则时,才进⾏路由换发filters:- StripPrefix=1                           # 拼接好url之后去掉1层路径也就是product- AddRequestHeader=msg,abc- id: order_routeuri: lb://server-order                      # 指的是从nacos中按照名称获取微服务,并遵循负载均衡策略order: 1                                    # 路由优先级 数字越低优先级越高predicates:                                 # 断言- Path=/order/**                          # 当请求路径满⾜Path指定的规则时,才进⾏路由换发filters:- StripPrefix=1                           # 拼接好url之后去掉1层路径也就是product- AddRequestHeader=msg,abc
  1. 发送请求测试
  • 例如之前发的是localhost:8080/product/1
  • 现在就是 localhost:7000/product/product/1

断言工厂

例如Path=/user/**是按照路径匹配,这个规则是由org.springframework.cloud.gateway.handler.predicate.PathRoutePredicateFactory类来处理 的,像这样的断⾔⼯⼚在SpringCloudGateway还有⼗⼏个:

名称

说明

示例

After

是某个时间点后的请求

-After=2037-01-20T17:42:47.789-07:0o[America/Denver]

Before

是某个时间点之前的请求

- Before=2031-04-13T15:14:47.433+08:00[Asia/Shanghai]

Between

是某两个时间点之前的请求

-Between=2037-01-20T17:42:47.789-07:00[America/Denver], 2037-01-21T17:42:47.789-07:00[America/Denver]

Cookie

请求必须包含某些cookie

-Cookie=chocolate, ch.p

Header

请求必须包含某些header

-Header=X-Request-Id, \d+

Host

请求必须是访问某个host

(域名)

-Host=.somehost.org,.anotherhost.org

Method

请求方式必须是指定方式

-Method=GET,POST

Path

请求路径必须符合指定规则

-Path=/red/{segment},/blue/**

Query

请求参数必须包含指定参

-Query=name,Jack或者-Query=name

RemoteAddr

请求者的ip必须是指定范围

-RemoteAddr=192.168.1.1/25

Weight

权重处理

过滤器工厂

GatewayFilter是⽹关中提供的⼀种过滤器,可以对进⼊⽹关的请求和微服务返回的响应做处理:

名称

说明

AddRequestHeader

给当前请求添加一个请求头

RemoveRequestHeader

移除请求中的一个请求头

AddResponseHeader

给响应结果中添加一个响应头

RemoveResponseHeader

从响应结果中移除有一个响应头

RequestRateLimiter

限制请求的流量

路由过滤器(当前路由的过滤器)
routes:                                         # 路由数组[路由就是指定当请求满⾜什么条件的时候转到哪个微服务]- id: product_routeuri: lb://server-product                    # 指的是从nacos中按照名称获取微服务,并遵循负载均衡策略order: 1                                    # 路由优先级 数字越低优先级越高predicates:                                 # 断言- Path=/product/**                        # 当请求路径满⾜Path指定的规则时,才进⾏路由换发filters:- StripPrefix=1                           # 拼接好url之后去掉1层路径也就是product
@GetMapping("/{id}")
public Product selectById(@PathVariable int id) {Product product = service.getById(id);log.info(product.toString());return product;
}
默认过滤器(范围是所有路由,但是只能使用默认提供的过滤规则)

举例AddRequestHeader

配置文件

routes:                                         # 路由数组[路由就是指定当请求满⾜什么条件的时候转到哪个微服务]- id: product_routeuri: lb://server-product                    # 指的是从nacos中按照名称获取微服务,并遵循负载均衡策略order: 1                                    # 路由优先级 数字越低优先级越高predicates:                                 # 断言- Path=/product/**                        # 当请求路径满⾜Path指定的规则时,才进⾏路由换发filters:- StripPrefix=1                           # 拼接好url之后去掉1层路径也就是product
default-filters: 																# 默认过滤器 范围全局- AddRequestHeader=msg,abc 

Handler

@GetMapping("/{id}")
public Product selectById(@PathVariable int id,@RequestHeader(value = "msg") String msg) {Product product = service.getById(id);System.out.println(msg);System.out.println(msg);System.out.println(msg);System.out.println(msg);System.out.println(msg);log.info(product.toString());return product;
}
全局过滤器-登录校验(范围是所有路由,可以自定义过滤规则,拦截未登录用户)
  • 登录状态判断
  • 权限校验
  • 请求限流等

需求:定义全局过滤器,拦截请求,判断请求的参数是否满⾜下⾯条件:

● 参数中是否有authorization, authorization参数值是否为admin

●如果同时满⾜则放⾏,否则拦截 实现:在gateway中定义⼀个过滤器:

package com.ape.apigateway.filter;import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.annotation.Order;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;//导入IOC就可以生效
@Component
@Order(-1) // 用来控制优先级 数字越小优先级越高
public class AuthorizeFilter implements GlobalFilter {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {String token = exchange.getRequest().getHeaders().get("authorization").get(0);if (token.equals("admin")){//            放行return chain.filter(exchange);}//        拦截 禁止访问exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);return exchange.getResponse().setComplete();}
}
过滤器执行顺序

默认===》路由===》全局

跨域解决方案

跨域:域名不⼀致就是跨域,主要包括:

  • 域名不同: www.taobao.com 和 www.taobao.org 和 www.jd.com 和 miaosha.jd.com
  • 域名相同,端⼝不同:localhost:8080和localhost8081

跨域问题:浏览器禁⽌请求的发起者与服务端发⽣跨域ajax请求,请求被浏览器拦截的问题

CORS是跨源资源分享(Cross-Origin Resource Sharing)的缩写。它是W3C标准,是跨源AJAX请求 的根本解决⽅法。相⽐JSONP只能发GET请求,CORS允许任何类型的请求。 在gateway服务的application.yml⽂件中,添加下⾯的配置:

spring:cloud:gateway:globalcors: # 全局的跨域处理add-to-simple-url-handler-mapping: true # 解决options请求被拦截问题corsConfigurations:'[/**]':allowedOrigins: # 允许哪些⽹站的跨域请求- "http://localhost:8090"allowedMethods: # 允许的跨域ajax的请求⽅式- "GET"- "POST"- "DELETE"- "PUT"- "OPTIONS"allowedHeaders: "*" # 允许在请求中携带的头信息allowCredentials: true # 是否允许携带cookiemaxAge: 360000 # 这次跨域检测的有效期

这篇关于Nacos与Gateway微服务网关的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

Nacos客户端本地缓存和故障转移方式

《Nacos客户端本地缓存和故障转移方式》Nacos客户端在从Server获得服务时,若出现故障,会通过ServiceInfoHolder和FailoverReactor进行故障转移,ServiceI... 目录1. ServiceInfoHolder本地缓存目录2. FailoverReactorinit

Nacos集群数据同步方式

《Nacos集群数据同步方式》文章主要介绍了Nacos集群中服务注册信息的同步机制,涉及到负责节点和非负责节点之间的数据同步过程,以及DistroProtocol协议在同步中的应用... 目录引言负责节点(发起同步)DistroProtocolDistroSyncChangeTask获取同步数据getDis

【区块链 + 人才服务】可信教育区块链治理系统 | FISCO BCOS应用案例

伴随着区块链技术的不断完善,其在教育信息化中的应用也在持续发展。利用区块链数据共识、不可篡改的特性, 将与教育相关的数据要素在区块链上进行存证确权,在确保数据可信的前提下,促进教育的公平、透明、开放,为教育教学质量提升赋能,实现教育数据的安全共享、高等教育体系的智慧治理。 可信教育区块链治理系统的顶层治理架构由教育部、高校、企业、学生等多方角色共同参与建设、维护,支撑教育资源共享、教学质量评估、

【区块链 + 人才服务】区块链集成开发平台 | FISCO BCOS应用案例

随着区块链技术的快速发展,越来越多的企业开始将其应用于实际业务中。然而,区块链技术的专业性使得其集成开发成为一项挑战。针对此,广东中创智慧科技有限公司基于国产开源联盟链 FISCO BCOS 推出了区块链集成开发平台。该平台基于区块链技术,提供一套全面的区块链开发工具和开发环境,支持开发者快速开发和部署区块链应用。此外,该平台还可以提供一套全面的区块链开发教程和文档,帮助开发者快速上手区块链开发。

基于SpringBoot的宠物服务系统+uniapp小程序+LW参考示例

系列文章目录 1.基于SSM的洗衣房管理系统+原生微信小程序+LW参考示例 2.基于SpringBoot的宠物摄影网站管理系统+LW参考示例 3.基于SpringBoot+Vue的企业人事管理系统+LW参考示例 4.基于SSM的高校实验室管理系统+LW参考示例 5.基于SpringBoot的二手数码回收系统+原生微信小程序+LW参考示例 6.基于SSM的民宿预订管理系统+LW参考示例 7.基于

计算机网络基础概念 交换机、路由器、网关、TBOX

提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档 文章目录 前言一、VLAN是什么?二 、交换机三、路由器四、网关五、TBOXTelematics BOX,简称车载T-BOX,车联网系统包含四部分,主机、车载T-BOX、手机APP及后台系统。主机主要用于车内的影音娱乐,以及车辆信息显示;车载T-BOX主要用于和后台系统/手机APP通信,实现手机APP的车辆信息显示与控

Golang支持平滑升级的HTTP服务

前段时间用Golang在做一个HTTP的接口,因编译型语言的特性,修改了代码需要重新编译可执行文件,关闭正在运行的老程序,并启动新程序。对于访问量较大的面向用户的产品,关闭、重启的过程中势必会出现无法访问的情况,从而影响用户体验。 使用Golang的系统包开发HTTP服务,是无法支持平滑升级(优雅重启)的,本文将探讨如何解决该问题。 一、平滑升级(优雅重启)的一般思路 一般情况下,要实现平滑

Golang服务平滑重启

与重载配置相同的是我们也需要通过信号来通知server重启,但关键在于平滑重启,如果只是简单的重启,只需要kill掉,然后再拉起即可。平滑重启意味着server升级的时候可以不用停止业务。 我们先来看下Github上有没有相应的库解决这个问题,然后找到了如下三个库: facebookgo/grace - Graceful restart & zero downtime deploy for G

Java后端微服务架构下的API限流策略:Guava RateLimiter

Java后端微服务架构下的API限流策略:Guava RateLimiter 大家好,我是微赚淘客返利系统3.0的小编,是个冬天不穿秋裤,天冷也要风度的程序猿! 在微服务架构中,API限流是保护服务不受过度使用和拒绝服务攻击的重要手段。Guava RateLimiter是Google开源的Java库中的一个组件,提供了简单易用的限流功能。 API限流概述 API限流通过控制请求的速率来防止

【微服务】Ribbon(负载均衡,服务调用)+ OpenFeign(服务发现,远程调用)【详解】

文章目录 1.Ribbon(负载均衡,服务调用)1.1问题引出1.2 Ribbon负载均衡1.3 RestTemplate整合Ribbon1.4 指定Ribbon负载均衡策略1.4.1 配置文件1.4.2 配置类1.4.3 定义Ribbon客户端配置1.4.4 自定义负载均衡策略 2.OpenFeign面向接口的服务调用(服务发现,远程调用)2.1 OpenFeign的使用2.1 .1创建