1.Nacos配置管理
Nacos除了可以做注冊(cè)中心,同樣可以做配置管理來(lái)使用。
1.1.統(tǒng)一配置管理
當(dāng)微服務(wù)部署的實(shí)例越來(lái)越多,達(dá)到數(shù)十、數(shù)百時(shí),逐個(gè)修改微服務(wù)配置就會(huì)讓人抓狂,而且很容易出錯(cuò)。我們需要一種統(tǒng)一配置管理方案,可以集中管理所有實(shí)例的配置。
Nacos一方面可以將配置集中管理,另一方可以在配置變更時(shí),及時(shí)通知微服務(wù),實(shí)現(xiàn)配置的熱更新。
1.1.1.在nacos中添加配置文件
注意:項(xiàng)目的核心配置,需要熱更新的配置才有放到nacos管理的必要?;静粫?huì)變更的一些配置還是保存在微服務(wù)本地比較好。
1.1.2.從微服務(wù)拉取配置
微服務(wù)要拉取nacos中管理的配置,并且與本地的application.yml配置合并,才能完成項(xiàng)目啟動(dòng)。
但如果尚未讀取application.yml,又如何得知nacos地址呢?
因此spring引入了一種新的配置文件:bootstrap.yaml文件,會(huì)在application.yml之前被讀取,流程如下:
1)引入nacos-config依賴
首先,在user-service服務(wù)中,引入nacos-config的客戶端依賴:
<!--nacos配置管理依賴-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
2)添加bootstrap.yaml
然后,在user-service中添加一個(gè)bootstrap.yaml文件,內(nèi)容如下:
spring:
application:
name: userservice # 服務(wù)名稱
profiles:
active: dev #開(kāi)發(fā)環(huán)境,這里是dev
cloud:
nacos:
server-addr: localhost:8848 # Nacos地址
config:
file-extension: yaml # 文件后綴名
這里會(huì)根據(jù)spring.cloud.nacos.server-addr獲取nacos地址,再根據(jù)
${spring.application.name}-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
作為文件id,來(lái)讀取配置。
本例中,就是去讀取userservice-dev.yaml
:
3)讀取nacos配置
在user-service中的UserController中添加業(yè)務(wù)邏輯,讀取pattern.dateformat配置:
在頁(yè)面訪問(wèn),可以看到效果:
如果是在其他namespace進(jìn)行配置的話
就需要在bootstrap配置namespace
1.2配置熱更新
我們最終的目的,是修改nacos中的配置后,微服務(wù)中無(wú)需重啟即可讓配置生效,也就是配置熱更新。
要實(shí)現(xiàn)配置熱更新,可以使用兩種方式:
1.2.1.方式一
在@Value注入的變量所在類(lèi)上添加注解@RefreshScope:
1.2.2.方式二
使用@ConfigurationProperties注解代替@Value注解。
在user-service服務(wù)中,添加一個(gè)類(lèi),讀取patterrn.dateformat屬性:
package cn.itcast.user.config;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;
@Component
@Data
@ConfigurationProperties(prefix = "pattern")
public class PatternProperties {
private String dateformat;
}
在UserController中使用這個(gè)類(lèi)代替@Value:
1.3.配置共享
其實(shí)微服務(wù)啟動(dòng)時(shí),會(huì)去nacos讀取多個(gè)配置文件,例如:
-
[spring.application.name]-[spring.profiles.active].yaml
,例如:userservice-dev.yaml -
[spring.application.name].yaml
,例如:userservice.yaml
而[spring.application.name].yaml
不包含環(huán)境,因此可以被多個(gè)環(huán)境共享。
下面我們通過(guò)案例來(lái)測(cè)試配置共享
1)添加一個(gè)環(huán)境共享配置
我們?cè)趎acos中添加一個(gè)userservice.yaml文件:
2)在user-service中讀取共享配置
在user-service服務(wù)中,修改PatternProperties類(lèi),讀取新添加的屬性:
修改userController的now方法
@GetMapping("/now")
public String now(){
String result =LocalDateTime.now().format(DateTimeFormatter.ofPattern(properties.getDateformat()))
+ properties.getEnvSharedValue();
return result;
}
測(cè)試結(jié)果
2.Feign遠(yuǎn)程調(diào)用
先來(lái)看我們以前利用RestTemplate發(fā)起遠(yuǎn)程調(diào)用的代碼:
存在下面的問(wèn)題:
?代碼可讀性差,編程體驗(yàn)不統(tǒng)一
?參數(shù)復(fù)雜URL難以維護(hù)
Feign是一個(gè)聲明式的http客戶端,官方地址:https://github.com/OpenFeign/feign
其作用就是幫助我們優(yōu)雅的實(shí)現(xiàn)http請(qǐng)求的發(fā)送,解決上面提到的問(wèn)題。
2.1.Feign替代RestTemplate
這里是引用使用Feign的步驟:
① 引入依賴
② 添加@EnableFeignClients注解
③ 編寫(xiě)FeignClient接口
④ 使用FeignClient中定義的方法代替RestTemplate
1)引入依賴
我們?cè)趏rder-service服務(wù)的pom文件中引入feign的依賴:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
2)添加注解
在order-service的啟動(dòng)類(lèi)添加注解開(kāi)啟Feign的功能:
3)編寫(xiě)Feign的客戶端
在order-service中新建一個(gè)接口,內(nèi)容如下:
package cn.itcast.order.client;
import cn.itcast.order.pojo.User;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
@FeignClient("userservice")
public interface UserClient {
@GetMapping("/user/{id}")
User findById(@PathVariable("id") Long id);
}
這個(gè)客戶端主要是基于SpringMVC的注解來(lái)聲明遠(yuǎn)程調(diào)用的信息,比如:
- 服務(wù)名稱:userservice
- 請(qǐng)求方式:GET
- 請(qǐng)求路徑:/user/{id}
- 請(qǐng)求參數(shù):Long id
- 返回值類(lèi)型:User
這樣,F(xiàn)eign就可以幫助我們發(fā)送http請(qǐng)求,無(wú)需自己使用RestTemplate來(lái)發(fā)送了。
4)測(cè)試
修改order-service中的OrderService類(lèi)中的queryOrderById方法,使用Feign客戶端代替RestTemplate:
2.2.自定義配置
Feign可以支持很多的自定義配置,如下表所示:
類(lèi)型 | 作用 | 說(shuō)明 |
---|---|---|
feign.Logger.Level | 修改日志級(jí)別 | 包含四種不同的級(jí)別:NONE、BASIC、HEADERS、FULL |
feign.codec.Decoder | 響應(yīng)結(jié)果的解析器 | http遠(yuǎn)程調(diào)用的結(jié)果做解析,例如解析json字符串為java對(duì)象 |
feign.codec.Encoder | 請(qǐng)求參數(shù)編碼 | 將請(qǐng)求參數(shù)編碼,便于通過(guò)http請(qǐng)求發(fā)送 |
feign. Contract | 支持的注解格式 | 默認(rèn)是SpringMVC的注解 |
feign. Retryer | 失敗重試機(jī)制 | 請(qǐng)求失敗的重試機(jī)制,默認(rèn)是沒(méi)有,不過(guò)會(huì)使用Ribbon的重試 |
一般情況下,默認(rèn)值就能滿足我們使用,如果要自定義時(shí),只需要?jiǎng)?chuàng)建自定義的@Bean覆蓋默認(rèn)Bean即可。
下面以日志為例來(lái)演示如何自定義配置。
2.2.1.配置文件方式
基于配置文件修改feign的日志級(jí)別可以針對(duì)單個(gè)服務(wù):
feign:
client:
config:
userservice: # 針對(duì)某個(gè)微服務(wù)的配置
loggerLevel: FULL # 日志級(jí)別
也可以針對(duì)所有服務(wù):
feign:
client:
config:
default: # 這里用default就是全局配置,如果是寫(xiě)服務(wù)名稱,則是針對(duì)某個(gè)微服務(wù)的配置
loggerLevel: FULL # 日志級(jí)別
而日志的級(jí)別分為四種:
- NONE:不記錄任何日志信息,這是默認(rèn)值。
- BASIC:僅記錄請(qǐng)求的方法,URL以及響應(yīng)狀態(tài)碼和執(zhí)行時(shí)間
- HEADERS:在BASIC的基礎(chǔ)上,額外記錄了請(qǐng)求和響應(yīng)的頭信息
- FULL:記錄所有請(qǐng)求和響應(yīng)的明細(xì),包括頭信息、請(qǐng)求體、元數(shù)據(jù)。
2.2.2.Java代碼方式
也可以基于Java代碼來(lái)修改日志級(jí)別,先聲明一個(gè)類(lèi),然后聲明一個(gè)Logger.Level的對(duì)象:
public class DefaultFeignConfiguration {
@Bean
public Logger.Level feignLogLevel(){
return Logger.Level.BASIC; // 日志級(jí)別為BASIC
}
}
如果要全局生效,將其放到啟動(dòng)類(lèi)的@EnableFeignClients這個(gè)注解中:
@EnableFeignClients(defaultConfiguration = DefaultFeignConfiguration .class)
如果是局部生效,則把它放到對(duì)應(yīng)的@FeignClient這個(gè)注解中:
@FeignClient(value = "userservice", configuration = DefaultFeignConfiguration .class)
2.3.Feign使用優(yōu)化
Feign底層發(fā)起http請(qǐng)求,依賴于其它的框架。其底層客戶端實(shí)現(xiàn)包括:
?URLConnection:默認(rèn)實(shí)現(xiàn),不支持連接池
?Apache HttpClient :支持連接池
?OKHttp:支持連接池
因此提高Feign的性能主要手段就是使用連接池代替默認(rèn)的URLConnection。
這里是引用Feign的優(yōu)化:
1.日志級(jí)別盡量用basic
2.使用HttpClient或OKHttp代替URLConnection
① 引入feign-httpClient依賴
② 配置文件開(kāi)啟httpClient功能,設(shè)置連接池參數(shù)
這里我們用Apache的HttpClient來(lái)演示。
1)引入依賴
在order-service的pom文件中引入Apache的HttpClient依賴:
<!--httpClient的依賴 -->
<dependency>
<groupId>io.github.openfeign</groupId>
<artifactId>feign-httpclient</artifactId>
</dependency>
2)配置連接池
在order-service的application.yml中添加配置:
feign:
client:
config:
default: # default全局的配置
loggerLevel: BASIC # 日志級(jí)別,BASIC就是基本的請(qǐng)求和響應(yīng)信息
httpclient:
enabled: true # 開(kāi)啟feign對(duì)HttpClient的支持
max-connections: 200 # 最大的連接數(shù)
max-connections-per-route: 50 # 每個(gè)路徑的最大連接數(shù)
2.4Feign的實(shí)際使用
將Feign的Client抽取為獨(dú)立模塊,并且把接口有關(guān)的POJO、默認(rèn)的Feign配置都放到這個(gè)模塊中,提供給所有消費(fèi)者使用。
例如,將UserClient、User、Feign的默認(rèn)配置都抽取到一個(gè)feign-api包中,所有微服務(wù)引用該依賴包,即可直接使用。
1)抽取
首先創(chuàng)建一個(gè)module,命名為feign-api:
在feign-api中然后引入feign的starter依賴
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
然后,order-service中編寫(xiě)的UserClient、User、DefaultFeignConfiguration都復(fù)制到feign-api項(xiàng)目中
2)在order-service中使用feign-api
首先,刪除order-service中的UserClient、User、DefaultFeignConfiguration等類(lèi)或接口。
在order-service的pom文件中中引入feign-api的依賴:
<dependency>
<groupId>cn.itcast.demo</groupId>
<artifactId>feign-api</artifactId>
<version>1.0</version>
</dependency>
修改order-service中的所有與上述三個(gè)組件有關(guān)的導(dǎo)包部分,改成導(dǎo)入feign-api中的包
3)掃描
方式一:
指定Feign應(yīng)該掃描的包:
@EnableFeignClients(basePackages = "cn.itcast.feign.clients")
方式二:
指定需要加載的Client接口:
@EnableFeignClients(clients = {UserClient.class})
Gateway服務(wù)網(wǎng)關(guān)
Gateway網(wǎng)關(guān)是我們服務(wù)的守門(mén)神,所有微服務(wù)的統(tǒng)一入口。
網(wǎng)關(guān)的核心功能特性:
- 請(qǐng)求路由
- 權(quán)限控制
- 限流
![]()
權(quán)限控制:網(wǎng)關(guān)作為微服務(wù)入口,需要校驗(yàn)用戶是是否有請(qǐng)求資格,如果沒(méi)有則進(jìn)行攔截。
路由和負(fù)載均衡:一切請(qǐng)求都必須先經(jīng)過(guò)gateway,但網(wǎng)關(guān)不處理業(yè)務(wù),而是根據(jù)某種規(guī)則,把請(qǐng)求轉(zhuǎn)發(fā)到某個(gè)微服務(wù),這個(gè)過(guò)程叫做路由。當(dāng)然路由的目標(biāo)服務(wù)有多個(gè)時(shí),還需要做負(fù)載均衡。
限流:當(dāng)請(qǐng)求流量過(guò)高時(shí),在網(wǎng)關(guān)中按照下流的微服務(wù)能夠接受的速度來(lái)放行請(qǐng)求,避免服務(wù)壓力過(guò)大。
在SpringCloud中網(wǎng)關(guān)的實(shí)現(xiàn)包括兩種:
- gateway
- zuul
Zuul是基于Servlet的實(shí)現(xiàn),屬于阻塞式編程。而SpringCloudGateway則是基于Spring5中提供的WebFlux,屬于響應(yīng)式編程的實(shí)現(xiàn),具備更好的性能。
3.1gateway快速入門(mén)
1)創(chuàng)建gateway服務(wù),引入依賴
創(chuàng)建服務(wù):
引入依賴
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<!--nacos服務(wù)發(fā)現(xiàn)依賴-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
注意:在網(wǎng)關(guān)微服務(wù)中不可以直接或者是間接依賴spring-boot-starter-web
2)編寫(xiě)啟動(dòng)類(lèi)
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class GatewayApplication {
public static void main(String[] args) {
SpringApplication.run(GatewayApplication.class, args);
}
}
3)編寫(xiě)基礎(chǔ)配置和路由規(guī)則
創(chuàng)建application.yml文件,內(nèi)容如下:
server:
port: 10010 # 網(wǎng)關(guān)端口
spring:
application:
name: gateway # 服務(wù)名稱
cloud:
nacos:
server-addr: localhost:8848 # nacos地址
gateway:
routes: # 網(wǎng)關(guān)路由配置
- id: user-service # 路由id,自定義,只要唯一即可
# uri: http://127.0.0.1:8081 # 路由的目標(biāo)地址 http就是固定地址
uri: lb://userservice # 路由的目標(biāo)地址 lb就是負(fù)載均衡,后面跟服務(wù)名稱
predicates: # 路由斷言,也就是判斷請(qǐng)求是否符合路由規(guī)則的條件
- Path=/user/** # 這個(gè)是按照路徑匹配,只要以/user/開(kāi)頭就符合要求
我們將符合Path
規(guī)則的一切請(qǐng)求,都代理到 uri
參數(shù)指定的地址。
本例中,我們將 /user/**
開(kāi)頭的請(qǐng)求,代理到lb://userservice
,lb是負(fù)載均衡,根據(jù)服務(wù)名拉取服務(wù)列表,實(shí)現(xiàn)負(fù)載均衡。
4)重啟測(cè)試
重啟網(wǎng)關(guān),訪問(wèn)http://localhost:10010/user/1時(shí),符合/user/**
規(guī)則,請(qǐng)求轉(zhuǎn)發(fā)到uri:http://userservice/user/1,得到了結(jié)果:
3.2網(wǎng)關(guān)路由的流程圖
總結(jié):
網(wǎng)關(guān)搭建步驟:
-
創(chuàng)建項(xiàng)目,引入nacos服務(wù)發(fā)現(xiàn)和gateway依賴
-
配置application.yml,包括服務(wù)基本信息、nacos地址、路由
路由配置包括:
-
路由id:路由的唯一標(biāo)示
-
路由目標(biāo)(uri):路由的目標(biāo)地址,http代表固定地址,lb代表根據(jù)服務(wù)名負(fù)載均衡
-
路由斷言(predicates):判斷路由的規(guī)則,
-
路由過(guò)濾器(filters):對(duì)請(qǐng)求或響應(yīng)做處理
3.3斷言工廠
我們?cè)谂渲梦募袑?xiě)的斷言規(guī)則只是字符串,這些字符串會(huì)被Predicate Factory讀取并處理,轉(zhuǎn)變?yōu)槁酚膳袛嗟臈l件
例如Path=/user/**是按照路徑匹配,這個(gè)規(guī)則是由
org.springframework.cloud.gateway.handler.predicate.PathRoutePredicateFactory
類(lèi)來(lái)
處理的,像這樣的斷言工廠在SpringCloudGateway還有十幾個(gè):
名稱 | 說(shuō)明 | 示例 |
---|---|---|
After | 是某個(gè)時(shí)間點(diǎn)后的請(qǐng)求 | - After=2037-01-20T17:42:47.789-07:00[America/Denver] |
Before | 是某個(gè)時(shí)間點(diǎn)之前的請(qǐng)求 | - Before=2031-04-13T15:14:47.433+08:00[Asia/Shanghai] |
Between | 是某兩個(gè)時(shí)間點(diǎn)之前的請(qǐng)求 | - Between=2037-01-20T17:42:47.789-07:00[America/Denver], 2037-01-21T17:42:47.789-07:00[America/Denver] |
Cookie | 請(qǐng)求必須包含某些cookie | - Cookie=chocolate, ch.p |
Header | 請(qǐng)求必須包含某些header | - Header=X-Request-Id, \d+ |
Host | 請(qǐng)求必須是訪問(wèn)某個(gè)host(域名) | - Host=.somehost.org,.anotherhost.org |
Method | 請(qǐng)求方式必須是指定方式 | - Method=GET,POST |
Path | 請(qǐng)求路徑必須符合指定規(guī)則 | - Path=/red/{segment},/blue/** |
Query | 請(qǐng)求參數(shù)必須包含指定參數(shù) | - Query=name, Jack或者- Query=name |
RemoteAddr | 請(qǐng)求者的ip必須是指定范圍 | - RemoteAddr=192.168.1.1/24 |
Weight | 權(quán)重處理 |
我們只需要掌握Path這種路由工程就可以了。
3.4.過(guò)濾器工廠
GatewayFilter是網(wǎng)關(guān)中提供的一種過(guò)濾器,可以對(duì)進(jìn)入網(wǎng)關(guān)的請(qǐng)求和微服務(wù)返回的響應(yīng)做處理:
3.4.1.路由過(guò)濾器的種類(lèi)
Spring提供了31種不同的路由過(guò)濾器工廠。例如:
名稱 | 說(shuō)明 |
---|---|
AddRequestHeader | 給當(dāng)前請(qǐng)求添加一個(gè)請(qǐng)求頭 |
RemoveRequestHeader | 移除請(qǐng)求中的一個(gè)請(qǐng)求頭 |
AddResponseHeader | 給響應(yīng)結(jié)果中添加一個(gè)響應(yīng)頭 |
RemoveResponseHeader | 從響應(yīng)結(jié)果中移除有一個(gè)響應(yīng)頭 |
RequestRateLimiter | 限制請(qǐng)求的流量 |
3.4.2.請(qǐng)求頭過(guò)濾器
下面我們以AddRequestHeader 為例來(lái)講解。
需求:給所有進(jìn)入userservice的請(qǐng)求添加一個(gè)請(qǐng)求頭:Truth=itcast is freaking awesome!
第一步,只需要修改gateway服務(wù)的application.yml文件,添加路由過(guò)濾即可:
spring:
cloud:
gateway:
routes:
- id: user-service
uri: lb://userservice
predicates:
- Path=/user/**
filters: # 過(guò)濾器
- AddRequestHeader=Truth, Itcast is freaking awesome! # 添加請(qǐng)求頭
當(dāng)前過(guò)濾器寫(xiě)在userservice路由下,因此僅僅對(duì)訪問(wèn)userservice的請(qǐng)求有效。
第二步,在userController中修改方法
/**
* 路徑: /user/110
*
* @param id 用戶id
* @return 用戶
*/
@GetMapping("/{id}")
public User queryById(@PathVariable("id") Long id,
@RequestHeader("Truth") String truth) {
System.out.println(truth);
return userService.queryById(id);
}
第三步,重啟網(wǎng)關(guān)服務(wù)和user服務(wù),并通過(guò)網(wǎng)關(guān)訪問(wèn)user用戶信息 http://localhost:10010/user/3
查看控制臺(tái)信息,發(fā)現(xiàn)可以得到請(qǐng)求頭中的信息的
3.4.3.默認(rèn)過(guò)濾器
如果要對(duì)所有的路由都生效,則可以將過(guò)濾器工廠寫(xiě)到default下。格式如下:
spring:
cloud:
gateway:
routes:
- id: user-service
uri: lb://userservice
predicates:
- Path=/user/**
default-filters: # 默認(rèn)過(guò)濾項(xiàng)
- AddRequestHeader=Truth, Itcast is freaking awesome!
3.4.4.總結(jié)
過(guò)濾器的作用是什么?
① 對(duì)路由的請(qǐng)求或響應(yīng)做加工處理,比如添加請(qǐng)求頭
② 配置在路由下的過(guò)濾器只對(duì)當(dāng)前路由的請(qǐng)求生效
defaultFilters的作用是什么?
① 對(duì)所有路由都生效的過(guò)濾器
3.5.全局過(guò)濾器
上一節(jié)學(xué)習(xí)的過(guò)濾器,網(wǎng)關(guān)提供了31種,但每一種過(guò)濾器的作用都是固定的。如果我們希望攔截請(qǐng)求,做自己的業(yè)務(wù)邏輯則沒(méi)辦法實(shí)現(xiàn)。
3.5.1.全局過(guò)濾器作用
全局過(guò)濾器的作用也是處理一切進(jìn)入網(wǎng)關(guān)的請(qǐng)求和微服務(wù)響應(yīng),與GatewayFilter的作用一樣。區(qū)別在于GatewayFilter通過(guò)配置定義,處理邏輯是固定的;而GlobalFilter的邏輯需要自己寫(xiě)代碼實(shí)現(xiàn)。
定義方式是實(shí)現(xiàn)GlobalFilter接口。
public interface GlobalFilter {
/**
* 處理當(dāng)前請(qǐng)求,有必要的話通過(guò){@link GatewayFilterChain}將請(qǐng)求交給下一個(gè)過(guò)濾器處理
*
* @param exchange 請(qǐng)求上下文,里面可以獲取Request、Response等信息
* @param chain 用來(lái)把請(qǐng)求委托給下一個(gè)過(guò)濾器
* @return {@code Mono<Void>} 返回標(biāo)示當(dāng)前過(guò)濾器業(yè)務(wù)結(jié)束
*/
Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain);
}
在filter中編寫(xiě)自定義邏輯,可以實(shí)現(xiàn)下列功能:
- 登錄狀態(tài)判斷
- 權(quán)限校驗(yàn)
- 請(qǐng)求限流等
3.5.2.自定義全局過(guò)濾器
需求:定義全局過(guò)濾器,攔截請(qǐng)求,判斷請(qǐng)求的參數(shù)是否滿足下面條件:
-
參數(shù)中是否有authorization,
-
authorization參數(shù)值是否為admin
如果同時(shí)滿足則放行,否則攔截
實(shí)現(xiàn):
在gateway中定義一個(gè)過(guò)濾器:
package cn.itcast.gateway.filters;
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;
@Order(-1)
@Component
public class AuthorizeFilter implements GlobalFilter {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
// 1.獲取請(qǐng)求參數(shù)
MultiValueMap<String, String> params = exchange.getRequest().getQueryParams();
// 2.獲取authorization參數(shù)
String auth = params.getFirst("authorization");
// 3.校驗(yàn)
if ("admin".equals(auth)) {
// 放行
return chain.filter(exchange);
}
// 4.攔截
// 4.1.禁止訪問(wèn),設(shè)置狀態(tài)碼
exchange.getResponse().setStatusCode(HttpStatus.FORBIDDEN);
// 4.2.結(jié)束處理
return exchange.getResponse().setComplete();
}
}
3.5.3.過(guò)濾器執(zhí)行順序
請(qǐng)求進(jìn)入網(wǎng)關(guān)會(huì)碰到三類(lèi)過(guò)濾器:當(dāng)前路由的過(guò)濾器、DefaultFilter、GlobalFilter
請(qǐng)求路由后,會(huì)將當(dāng)前路由過(guò)濾器和DefaultFilter、GlobalFilter,合并到一個(gè)過(guò)濾器鏈(集合)中,排序后依次執(zhí)行每個(gè)過(guò)濾器:
排序的規(guī)則是什么呢?
- 每一個(gè)過(guò)濾器都必須指定一個(gè)int類(lèi)型的order值,order值越小,優(yōu)先級(jí)越高,執(zhí)行順序越靠前。
- GlobalFilter通過(guò)實(shí)現(xiàn)Ordered接口,或者添加@Order注解來(lái)指定order值,由我們自己指定
- 路由過(guò)濾器和defaultFilter的order由Spring指定,默認(rèn)是按照聲明順序從1遞增。
- 當(dāng)過(guò)濾器的order值一樣時(shí),會(huì)按照 defaultFilter > 路由過(guò)濾器 > GlobalFilter的順序執(zhí)行。
詳細(xì)內(nèi)容,可以查看源碼:
org.springframework.cloud.gateway.route.RouteDefinitionRouteLocator#getFilters()
方法是先加載defaultFilters,然后再加載某個(gè)route的filters,然后合并。
org.springframework.cloud.gateway.handler.FilteringWebHandler#handle()
方法會(huì)加載全局過(guò)濾器,與前面的過(guò)濾器合并后根據(jù)order排序,組織過(guò)濾器鏈文章來(lái)源:http://www.zghlxwxcb.cn/news/detail-435673.html
3.6跨域問(wèn)題
3.6.1.解決跨域問(wèn)題
在gateway服務(wù)的application.yml文件中,添加下面的配置:文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-435673.html
spring:
cloud:
gateway:
# 。。。
globalcors: # 全局的跨域處理
add-to-simple-url-handler-mapping: true # 解決options請(qǐng)求被攔截問(wèn)題
corsConfigurations:
'[/**]':
allowedOrigins: # 允許哪些網(wǎng)站的跨域請(qǐng)求
- "http://localhost:63342"
allowedMethods: # 允許的跨域ajax的請(qǐng)求方式
- "GET"
- "POST"
- "DELETE"
- "PUT"
- "OPTIONS"
allowedHeaders: "*" # 允許在請(qǐng)求中攜帶的頭信息
allowCredentials: true # 是否允許攜帶cookie
maxAge: 360000 # 這次跨域檢測(cè)的有效期
到了這里,關(guān)于Nacos配置管理、Fegin遠(yuǎn)程調(diào)用、Gateway服務(wù)網(wǎng)關(guān)的文章就介紹完了。如果您還想了解更多內(nèi)容,請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!