1.Nacos配置管理
1.1.將配置交給Nacos管理的步驟
1.在Nacos中添加配置Data Id
=服務(wù)名稱-環(huán)境名稱.yaml
eg:userservice-dev.yaml
2.引入nacos-config依賴
在user-service服務(wù)中,引入nacos-config的客戶端依賴
<!--nacos配置管理依賴-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
3.添加bootstrap.yaml
,我們這里以顯示一個(gè)日期時(shí)間為例
在user-service中添加一個(gè)bootstrap.yaml文件
spring:
application:
name: userservice # 服務(wù)名稱
profiles:
active: dev #開發(fā)環(huán)境,這里是dev
cloud:
nacos:
server-addr: localhost:8848 # Nacos地址
config:
file-extension: yaml # 文件后綴名
4.編寫controller
@Value("${pattern.dateformat}")
private String dateformat;
@GetMapping("/now")
public String now(){
return LocalDateTime.now().format(DateTimeFormatter.ofPattern(dateformat));
}
1.2.配置自動(dòng)刷新
方式一
給@Value
注入的變量所在類上添加注解@RefreshScope
@Slf4j
@RestController
@RequestMapping("/user")
@RefreshScope
public class UserController {
}
方式二
使用@ConfigurationProperties注解代替@Value注解。
在user-service服務(wù)中,添加一個(gè)類,讀取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è)類代替@Value:
@Autowired
private PatternProperties properties;
@GetMapping("/now")
public String now(){
return LocalDateTime.now().format(DateTimeFormatter.ofPattern(properties.getDateformat()));
}
1.3.配置共享
服務(wù)名.yml,沒有環(huán)境,比如:userservice.yml
這個(gè)里面配置的就是多環(huán)境共享配置
優(yōu)先級:服務(wù)名+環(huán)境名.yml > 服務(wù)名.yml > 本地配置
1.4.配置Nacos集群
下載資源nacos集群搭建
2.Feign
2.1.配置FEign遠(yuǎn)程調(diào)用,替代RestTemplate
代替RestTemplate,實(shí)現(xiàn)http的優(yōu)雅請求
1.在消費(fèi)者的pom文件中引入依賴
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
2.在消費(fèi)者啟動(dòng)類上加上@EnableFeignClients
3.編寫Feign客戶端
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);
}
4.調(diào)用
@Autowired
private OrderMapper orderMapper;
User user = userClient.findById(order.getUserId());
2.2.自定義配置Feign,覆蓋springboot自動(dòng)裝配的配置
類型 | 作用 | 說明 |
---|---|---|
feign.Logger.Level | 修改日志級別 | 包含四種不同的級別:NONE、BASIC、HEADERS、FULL |
feign.codec.Decoder | 響應(yīng)結(jié)果的解析器 | http遠(yuǎn)程調(diào)用的結(jié)果做解析,例如解析json字符串為java對象 |
feign.codec.Encoder | 請求參數(shù)編碼 | 將請求參數(shù)編碼,便于通過http請求發(fā)送 |
feign. Contract | 支持的注解格式 | 默認(rèn)是SpringMVC的注解 |
feign. Retryer | 失敗重試機(jī)制 | 請求失敗的重試機(jī)制,默認(rèn)是沒有,不過會使用Ribbon的重試 |
日志的級別分為四種:
- NONE:不記錄任何日志信息,這是默認(rèn)值。
- BASIC:僅記錄請求的方法,URL以及響應(yīng)狀態(tài)碼和執(zhí)行時(shí)間
- HEADERS:在BASIC的基礎(chǔ)上,額外記錄了請求和響應(yīng)的頭信息
- FULL:記錄所有請求和響應(yīng)的明細(xì),包括頭信息、請求體、元數(shù)據(jù)。
2.2.1.配置文件配置
基于配置文件修改feign的日志級別可以針對單個(gè)服務(wù):
feign:
client:
config:
userservice: # 針對某個(gè)微服務(wù)的配置
loggerLevel: FULL # 日志級別
也可以針對所有服務(wù):
feign:
client:
config:
default: # 這里用default就是全局配置,如果是寫服務(wù)名稱,則是針對某個(gè)微服務(wù)的配置
loggerLevel: FULL # 日志級別
2.2.2.Java代碼配置
基于Java代碼來修改日志級別,先聲明一個(gè)類,然后聲明一個(gè)Logger.Level的對象:
public class DefaultFeignConfiguration {
@Bean
public Logger.Level feignLogLevel(){
return Logger.Level.BASIC; // 日志級別為BASIC
}
}
如果要全局生效,將其放到啟動(dòng)類的@EnableFeignClients這個(gè)注解中:
@EnableFeignClients(defaultConfiguration = DefaultFeignConfiguration .class)
如果是局部生效,則把它放到對應(yīng)的@FeignClient這個(gè)注解中:
@FeignClient(value = "userservice", configuration = DefaultFeignConfiguration .class)
2.3.Feign的性能優(yōu)化
1.日志級別盡量使用basic
2.使用HttpClient
或OKHttp
代替URLConnection
(默認(rèn)使用的是URLConnection,沒有連接池)
2.3.1.使用HttpClient
1.消費(fèi)者pom文件引入依賴
<!--httpClient的依賴 -->
<dependency>
<groupId>io.github.openfeign</groupId>
<artifactId>feign-httpclient</artifactId>
</dependency>
2.在消費(fèi)者的yml文件中配置連接池
feign:
client:
config:
default: # default全局的配置
loggerLevel: BASIC # 日志級別,BASIC就是基本的請求和響應(yīng)信息
httpclient:
enabled: true # 開啟feign對HttpClient的支持
max-connections: 200 # 最大的連接數(shù)
max-connections-per-route: 50 # 每個(gè)路徑的最大連接數(shù)
2.4.Feign最佳實(shí)踐(一個(gè)相對來說比較好的實(shí)現(xiàn)方案)
2.4.1.繼承方式
一樣的代碼可以通過繼承來共享:
1)定義一個(gè)API接口,利用定義方法,并基于SpringMVC注解做聲明。
2)Feign客戶端和Controller都集成改接口
缺點(diǎn):
-
服務(wù)提供方、服務(wù)消費(fèi)方緊耦合
-
參數(shù)列表中的注解映射并不會繼承,因此Controller中必須再次聲明方法、參數(shù)列表、注解
2.4.1.抽取方式
將Feign的Client抽取為獨(dú)立模塊,并且把接口有關(guān)的POJO、默認(rèn)的Feign配置都放到這個(gè)模塊中,提供給所有消費(fèi)者使用。
例如,將UserClient、User、Feign的默認(rèn)配置都抽取到一個(gè)feign-api包中,所有微服務(wù)引用該依賴包,即可直接使用。
1.創(chuàng)建feign-api
model,在feign-api
中引入feign
的starter依賴
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
2.order-service中編寫的UserClient、User、DefaultFeignConfiguration都復(fù)制到feign-api項(xiàng)目中
3.在order-service中使用feign-api
首先,刪除order-service中的UserClient、User、DefaultFeignConfiguration等類或接口。
在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中的包
4.解決包掃描問題
4.1.指定Feign應(yīng)該掃描的包
@EnableFeignClients(basePackages = "cn.itcast.feign.clients")
4.2.指定需要加載的FeignClient接口
@EnableFeignClients(clients = {UserClient.class})
3.統(tǒng)一網(wǎng)關(guān)Gateway
3.1.網(wǎng)關(guān)介紹
網(wǎng)關(guān)作用:
- 身份認(rèn)證、權(quán)限校驗(yàn)、
- 請求路由到微服務(wù),負(fù)載均衡
- 請求限流
在SpringCloud中網(wǎng)關(guān)的實(shí)現(xiàn)包括兩種: - Gateway:基于Spring5中的WebFlux,屬于響應(yīng)式編程的實(shí)現(xiàn),具備更好的性能。
- zuul:基于Servlet的實(shí)現(xiàn),屬于阻塞式編程。
3.2.gateway快速入門
1.引入nacos的發(fā)現(xiàn)依賴和gateway網(wǎng)關(guān)依賴
<!--網(wǎng)關(guān)-->
<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>
2.編寫啟動(dòng)類
3.編寫基礎(chǔ)配置和路由服務(wù)
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: # 路由斷言,也就是判斷請求是否符合路由規(guī)則的條件
- Path=/user/** # 這個(gè)是按照路徑匹配,只要以/user/開頭就符合要求
路由配置包括:
- 路由id:路由的唯一標(biāo)示
- 路由目標(biāo)(uri):路由的目標(biāo)地址,http代表固定地址,lb代表根據(jù)服務(wù)名負(fù)載均衡
- 路由斷言(predicates):判斷路由的規(guī)則,
- 路由過濾器(filters):對請求或響應(yīng)做處理
4.測試
訪問http://localhost:10010/user/1,復(fù)合/user/**
規(guī)則,請求轉(zhuǎn)發(fā)到http://userservice/user/1
3.3.斷言工廠
predicates的配置會被Predicate Factory讀取并處理,轉(zhuǎn)變?yōu)槁酚膳袛嗟臈l件
例如Path=/user/**是按照路徑匹配,這個(gè)規(guī)則是由
org.springframework.cloud.gateway.handler.predicate.PathRoutePredicateFactory
類來
處理的,像這樣的斷言工廠在SpringCloudGateway還有十幾個(gè):
名稱 | 說明 | 示例 |
---|---|---|
After | 是某個(gè)時(shí)間點(diǎn)后的請求 | - After=2037-01-20T17:42:47.789-07:00[America/Denver] |
Before | 是某個(gè)時(shí)間點(diǎn)之前的請求 | - Before=2031-04-13T15:14:47.433+08:00[Asia/Shanghai] |
Between | 是某兩個(gè)時(shí)間點(diǎn)之前的請求 | - 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 | 請求必須是訪問某個(gè)host(域名) | - Host=.somehost.org,.anotherhost.org |
Method | 請求方式必須是指定方式 | - Method=GET,POST |
Path | 請求路徑必須符合指定規(guī)則 | - Path=/red/{segment},/blue/** |
Query | 請求參數(shù)必須包含指定參數(shù) | - Query=name, Jack或者- Query=name |
RemoteAddr | 請求者的ip必須是指定范圍 | - RemoteAddr=192.168.1.1/24 |
Weight | 權(quán)重處理 |
我們只需要掌握Path這種路由工程就可以了。
3.4.過濾器工廠
可以對進(jìn)入網(wǎng)關(guān)的請求和響應(yīng)進(jìn)行處理
3.4.1.路由過濾器的種類
Spring提供了31種不同的路由過濾器工廠。例如:
名稱 | 說明 |
---|---|
AddRequestHeader | 給當(dāng)前請求添加一個(gè)請求頭 |
RemoveRequestHeader | 移除請求中的一個(gè)請求頭 |
AddResponseHeader | 給響應(yīng)結(jié)果中添加一個(gè)響應(yīng)頭 |
RemoveResponseHeader | 從響應(yīng)結(jié)果中移除有一個(gè)響應(yīng)頭 |
RequestRateLimiter | 限制請求的流量 |
3.4.2.請求頭過濾器
下面我們以AddRequestHeader 為例來講解。
需求:給所有進(jìn)入userservice的請求添加一個(gè)請求頭:Truth=itcast is freaking awesome!
只需要修改gateway服務(wù)的application.yml文件,添加路由過濾即可:
spring:
cloud:
gateway:
routes:
- id: user-service
uri: lb://userservice
predicates:
- Path=/user/**
filters: # 過濾器
- AddRequestHeader=Truth, Itcast is freaking awesome! # 添加請求頭
當(dāng)前過濾器寫在userservice路由下,因此僅僅對訪問userservice的請求有效。
3.4.3.默認(rèn)過濾器
如果要對所有的路由都生效,則可以將過濾器工廠寫到default下。格式如下:
spring:
cloud:
gateway:
routes:
- id: user-service
uri: lb://userservice
predicates:
- Path=/user/**
default-filters: # 默認(rèn)過濾項(xiàng)
- AddRequestHeader=Truth, Itcast is freaking awesome!
3.4.4.總結(jié)
過濾器的作用是什么?
① 對路由的請求或響應(yīng)做加工處理,比如添加請求頭
② 配置在路由下的過濾器只對當(dāng)前路由的請求生效
default-filters的作用是全局生效
3.5.全局過濾器(GlobalFilter)
過濾器工廠,網(wǎng)關(guān)提供了31種,但是每一種過濾器的作用都是固定的。全局過濾器就可以實(shí)現(xiàn)自己的業(yè)務(wù)邏輯,自己寫代碼實(shí)現(xiàn)。
3.5.1.全局過濾器的使用
定義方式是實(shí)現(xiàn)GlobalFilter接口。
public interface GlobalFilter {
/**
* 處理當(dāng)前請求,有必要的話通過{@link GatewayFilterChain}將請求交給下一個(gè)過濾器處理
*
* @param exchange 請求上下文,里面可以獲取Request、Response等信息
* @param chain 用來把請求委托給下一個(gè)過濾器
* @return {@code Mono<Void>} 返回標(biāo)示當(dāng)前過濾器業(yè)務(wù)結(jié)束
*/
Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain);
}
下面的例子實(shí)現(xiàn)了判斷請求頭中是否有參數(shù)是否有authorization=admin
通過兩種方式定義過濾器鏈的順序,數(shù)字越小優(yōu)先級越高,
-
@Order(-1)
注解,代碼中注釋起來了 - 實(shí)現(xiàn)
Ordered
接口,代碼中使用的方法
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.stereotype.Component;
import org.springframework.util.MultiValueMap;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
@Component
//@Order(-1)//順序注解,定義過濾器的順序,也可以實(shí)現(xiàn)Ordered接口
public class AuthorizeFilter implements GlobalFilter , Ordered {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
//獲取請求參數(shù)
ServerHttpRequest request = exchange.getRequest();
MultiValueMap<String, String> params = request.getQueryParams();
//獲取參數(shù)中的authorization參數(shù)
String auth = params.getFirst("authorization");
//判斷參數(shù)值是否等于admin
if ("admin".equals(auth)) {
//是,放行
return chain.filter(exchange);
}
//否,攔截,設(shè)置狀態(tài)碼
exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
//結(jié)束處理
return exchange.getResponse().setComplete();
}
@Override
public int getOrder() {
return -1;
}
}
3.5.2.過濾器鏈的執(zhí)行順序
- 每一個(gè)過濾器都必須指定一個(gè)int類型的order值,order值越小,優(yōu)先級越高,執(zhí)行順序越靠前。
- GlobalFilter通過實(shí)現(xiàn)Ordered接口,或者添加@Order注解來指定order值,由我們自己指定
- 路由過濾器和defaultFilter的order由Spring指定,默認(rèn)是按照聲明順序從1遞增。
- 當(dāng)過濾器的order值一樣時(shí),會按照 defaultFilter > 路由過濾器 > GlobalFilter的順序執(zhí)行。
3.6.跨域問題
3.6.1.什么是跨域問題
跨域:域名不一致就是跨域,主要包括:
-
域名不同: www.taobao.com 和 www.taobao.org 和 www.jd.com 和 miaosha.jd.com
-
域名相同,端口不同:localhost:8080和localhost8081
跨域問題:瀏覽器禁止請求的發(fā)起者與服務(wù)端發(fā)生跨域ajax請求,請求被瀏覽器攔截的問題文章來源:http://www.zghlxwxcb.cn/news/detail-663189.html
解決方案:CORS,這個(gè)以前應(yīng)該學(xué)習(xí)過,這里不再贅述了。不知道的小伙伴可以查看https://www.ruanyifeng.com/blog/2016/04/cors.html文章來源地址http://www.zghlxwxcb.cn/news/detail-663189.html
3.6.2.解決gateway的跨域問題
spring:
cloud:
gateway:
# 。。。
globalcors: # 全局的跨域處理
add-to-simple-url-handler-mapping: true # 解決options請求被攔截問題
corsConfigurations:
'[/**]':
allowedOrigins: # 允許哪些網(wǎng)站的跨域請求
- "http://localhost:8090"
allowedMethods: # 允許的跨域ajax的請求方式
- "GET"
- "POST"
- "DELETE"
- "PUT"
- "OPTIONS"
allowedHeaders: "*" # 允許在請求中攜帶的頭信息
allowCredentials: true # 是否允許攜帶cookie
maxAge: 360000 # 這次跨域檢測的有效期
到了這里,關(guān)于Nacos配置管理、Feign遠(yuǎn)程調(diào)用、Gateway服務(wù)網(wǎng)關(guān)的文章就介紹完了。如果您還想了解更多內(nèi)容,請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!