1.1.统一配置管理

当微服务部署的实例越来越多#xff0c;达到数十、数百时#xff0c;逐个修改微服务配置就会让人抓狂#xff0c;而且很容易出错。

我…SpringCloud实用篇02

0.学习目标

当微服务部署的实例越来越多达到数十、数百时逐个修改微服务配置就会让人抓狂而且很容易出错。

我们需要一种统一配置管理方案可以集中管理所有实例的配置。

Nacos一方面可以将配置集中管理另一方可以在配置变更时及时通知微服务实现配置的热更新。

1.1.1.在nacos中添加配置文件

注意项目的核心配置需要热更新的配置才有放到nacos管理的必要。

基本不会变更的一些配置还是保存在微服务本地比较好。

1.1.2.从微服务拉取配置

微服务要拉取nacos中管理的配置并且与本地的application.yml配置合并才能完成项目启动。

但如果尚未读取application.yml又如何得知nacos地址呢

因此spring引入了一种新的配置文件bootstrap.yaml文件会在application.yml之前被读取流程如下

1引入nacos-config依赖

首先在user-service服务中引入nacos-config的客户端依赖

!--nacos配置管理依赖--

dependencygroupIdcom.alibaba.cloud/groupIdartifactIdspring-cloud-starter-alibaba-nacos-config/artifactId

然后在user-service中添加一个bootstrap.yaml文件内容如下

userservice

文件后缀名这里会根据spring.cloud.nacos.server-addr获取nacos地址再根据

${spring.application.name}-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}作为文件id来读取配置。

3读取nacos配置

在user-service中的UserController中添加业务逻辑读取pattern.dateformat配置

完整代码

cn.itcast.user.service.UserService;

import

org.springframework.beans.factory.annotation.Autowired;

import

org.springframework.beans.factory.annotation.Value;

import

org.springframework.web.bind.annotation.*;import

import

java.time.format.DateTimeFormatter;Slf4j

RestController

userService;Value(${pattern.dateformat})private

String

dateformat;GetMapping(now)public

String

LocalDateTime.now().format(DateTimeFormatter.ofPattern(dateformat));}//

...略

我们最终的目的是修改nacos中的配置后微服务中无需重启即可让配置生效也就是配置热更新。

1.2.1.方式一

在Value注入的变量所在类上添加注解RefreshScope

1.2.2.方式二

使用ConfigurationProperties注解代替Value注解。

在user-service服务中添加一个类读取patterrn.dateformat属性

package

org.springframework.boot.context.properties.ConfigurationProperties;

import

org.springframework.stereotype.Component;Component

Data

cn.itcast.user.config.PatternProperties;

import

cn.itcast.user.service.UserService;

import

org.springframework.beans.factory.annotation.Autowired;

import

org.springframework.web.bind.annotation.GetMapping;

import

org.springframework.web.bind.annotation.PathVariable;

import

org.springframework.web.bind.annotation.RequestMapping;

import

org.springframework.web.bind.annotation.RestController;import

import

java.time.format.DateTimeFormatter;Slf4j

RestController

patternProperties;GetMapping(now)public

String

LocalDateTime.now().format(DateTimeFormatter.ofPattern(patternProperties.getDateformat()));}//

}1.3.配置共享

[spring.application.name]-[spring.profiles.active].yaml例如userservice-dev.yaml

[spring.application.name].yaml例如userservice.yaml

而[spring.application.name].yaml不包含环境因此可以被多个环境共享。

1添加一个环境共享配置

我们在nacos中添加一个userservice.yaml文件

在user-service服务中修改PatternProperties类读取新添加的属性

在user-service服务中修改UserController添加一个方法

3运行两个UserApplication使用不同的profile

修改UserApplication2这个启动项改变其profile值

这样UserApplication(8081)使用的profile是devUserApplication2(8082)使用的profile是test。

启动UserApplication和UserApplication2

访问http://localhost:8081/user/prop结果

访问http://localhost:8082/user/prop结果

可以看出来不管是dev还是test环境都读取到了envSharedValue这个属性的值。

1.4.搭建Nacos集群

Nacos生产环境下一定要部署为集群状态部署方式参考课前资料中的文档

2.Feign远程调用

Feign是一个声明式的http客户端官方地址https://github.com/OpenFeign/feign

其作用就是帮助我们优雅的实现http请求的发送解决上面提到的问题。

1引入依赖

我们在order-service服务的pom文件中引入feign的依赖

dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-openfeign/artifactId

/dependency2添加注解

在order-service的启动类添加注解开启Feign的功能

package

org.springframework.cloud.openfeign.FeignClient;

import

org.springframework.web.bind.annotation.GetMapping;

import

org.springframework.web.bind.annotation.PathVariable;FeignClient(userservice)

public

}这个客户端主要是基于SpringMVC的注解来声明远程调用的信息比如

服务名称userservice请求方式GET请求路径/user/{id}请求参数Long

id返回值类型User

这样Feign就可以帮助我们发送http请求无需自己使用RestTemplate来发送了。

4测试

修改order-service中的OrderService类中的queryOrderById方法使用Feign客户端代替RestTemplate

5总结

使用FeignClient中定义的方法代替RestTemplate

2.2.自定义配置

类型作用说明feign.Logger.Level修改日志级别包含四种不同的级别NONE、BASIC、HEADERS、FULLfeign.codec.Decoder响应结果的解析器http远程调用的结果做解析例如解析json字符串为java对象feign.codec.Encoder请求参数编码将请求参数编码便于通过http请求发送feign.

Contract支持的注解格式默认是SpringMVC的注解feign.

Retryer失败重试机制请求失败的重试机制默认是没有不过会使用Ribbon的重试

一般情况下默认值就能满足我们使用如果要自定义时只需要创建自定义的Bean覆盖默认Bean即可。

2.2.1.配置文件方式

这里用default就是全局配置如果是写服务名称则是针对某个微服务的配置loggerLevel:

FULL

NONE不记录任何日志信息这是默认值。

BASIC仅记录请求的方法URL以及响应状态码和执行时间HEADERS在BASIC的基础上额外记录了请求和响应的头信息FULL记录所有请求和响应的明细包括头信息、请求体、元数据。

2.2.2.Java代码方式

也可以基于Java代码来修改日志级别先声明一个类然后声明一个Logger.Level的对象

public

}如果要全局生效将其放到启动类的EnableFeignClients这个注解中

EnableFeignClients(defaultConfiguration

.class)

如果是局部生效则把它放到对应的FeignClient这个注解中

FeignClient(value

Feign底层发起http请求依赖于其它的框架。

其底层客户端实现包括

•Apache

因此提高Feign的性能主要手段就是使用连接池代替默认的URLConnection。

1引入依赖

在order-service的pom文件中引入Apache的HttpClient依赖

dependencygroupIdio.github.openfeign/groupIdartifactIdfeign-httpclient/artifactId

/dependency2配置连接池

在order-service的application.yml中添加配置

BASIC

日志级别BASIC就是基本的请求和响应信息httpclient:enabled:

true

开启feign对HttpClient的支持max-connections:

200

最大的连接数max-connections-per-route:

每个路径的最大连接数接下来在FeignClientFactoryBean中的loadBalance方法中打断点

Debug方式启动order-service服务可以看到这里的client底层就是Apache

HttpClient

2.使用HttpClient或OKHttp代替URLConnection

引入feign-httpClient依赖

自习观察可以发现Feign的客户端与服务提供者的controller代码非常相似

feign客户端

1定义一个API接口利用定义方法并基于SpringMVC注解做声明。

服务提供方、服务消费方紧耦合

参数列表中的注解映射并不会继承因此Controller中必须再次声明方法、参数列表、注解

2.4.2.抽取方式

将Feign的Client抽取为独立模块并且把接口有关的POJO、默认的Feign配置都放到这个模块中提供给所有消费者使用。

例如将UserClient、User、Feign的默认配置都抽取到一个feign-api包中所有微服务引用该依赖包即可直接使用。

1抽取

dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-openfeign/artifactId

/dependency然后order-service中编写的UserClient、User、DefaultFeignConfiguration都复制到feign-api项目中

首先删除order-service中的UserClient、User、DefaultFeignConfiguration等类或接口。

在order-service的pom文件中中引入feign-api的依赖

dependencygroupIdcn.itcast.demo/groupIdartifactIdfeign-api/artifactIdversion1.0/version

/dependency修改order-service中的所有与上述三个组件有关的导包部分改成导入feign-api中的包

3重启测试

这是因为UserClient现在在cn.itcast.feign.clients包下

而order-service的EnableFeignClients注解是在cn.itcast.order包下不在同一个包无法扫描到UserClient。

4解决扫描包问题

EnableFeignClients(basePackages

{UserClient.class})3.Gateway服务网关

Spring

等响应式编程和事件流技术开发的网关它旨在为微服务架构提供一种简单有效的统一的

API

权限控制网关作为微服务入口需要校验用户是是否有请求资格如果没有则进行拦截。

路由和负载均衡一切请求都必须先经过gateway但网关不处理业务而是根据某种规则把请求转发到某个微服务这个过程叫做路由。

当然路由的目标服务有多个时还需要做负载均衡。

限流当请求流量过高时在网关中按照下流的微服务能够接受的速度来放行请求避免服务压力过大。

gatewayzuul

Zuul是基于Servlet的实现属于阻塞式编程。

而SpringCloudGateway则是基于Spring5中提供的WebFlux属于响应式编程的实现具备更好的性能。

3.2.gateway快速入门

创建SpringBoot工程gateway引入网关依赖编写启动类编写基础配置和路由规则启动网关服务进行测试

1创建gateway服务引入依赖

dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-gateway/artifactId

/dependency

dependencygroupIdcom.alibaba.cloud/groupIdartifactIdspring-cloud-starter-alibaba-nacos-discovery/artifactId

/dependency2编写启动类

org.springframework.boot.SpringApplication;

import

org.springframework.boot.autoconfigure.SpringBootApplication;SpringBootApplication

public

{SpringApplication.run(GatewayApplication.class,

args);}

这个是按照路径匹配只要以/user/开头就符合要求我们将符合Path

本例中我们将

/user/**开头的请求代理到lb://userservicelb是负载均衡根据服务名拉取服务列表实现负载均衡。

4重启测试

重启网关访问http://localhost:10010/user/1时符合/user/**规则请求转发到urihttp://userservice/user/1得到了结果

网关搭建步骤

配置application.yml包括服务基本信息、nacos地址、路由

路由配置包括

路由目标uri路由的目标地址http代表固定地址lb代表根据服务名负载均衡

3.3.断言工厂

我们在配置文件中写的断言规则只是字符串这些字符串会被Predicate

org.springframework.cloud.gateway.handler.predicate.PathRoutePredicateFactory类来

处理的像这样的断言工厂在SpringCloudGateway还有十几个:

After2037-01-20T17:42:47.789-07:00[America/Denver]Before是某个时间点之前的请求-

Before2031-04-13T15:14:47.43308:00[Asia/Shanghai]Between是某两个时间点之前的请求-

Between2037-01-20T17:42:47.789-07:00[America/Denver],

2037-01-21T17:42:47.789-07:00[America/Denver]Cookie请求必须包含某些cookie-

Cookiechocolate,

Host.somehost.org,.anotherhost.orgMethod请求方式必须是指定方式-

MethodGET,POSTPath请求路径必须符合指定规则-

Path/red/{segment},/blue/**Query请求参数必须包含指定参数-

Queryname,

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

RemoteAddr192.168.1.1/24Weight权重处理

GatewayFilter是网关中提供的一种过滤器可以对进入网关的请求和微服务返回的响应做处理

名称说明AddRequestHeader给当前请求添加一个请求头RemoveRequestHeader移除请求中的一个请求头AddResponseHeader给响应结果中添加一个响应头RemoveResponseHeader从响应结果中移除有一个响应头RequestRateLimiter限制请求的流量

需求给所有进入userservice的请求添加一个请求头Truthitcast

freaking

只需要修改gateway服务的application.yml文件添加路由过滤即可

id:

添加请求头当前过滤器写在userservice路由下因此仅仅对访问userservice的请求有效。

如果要对所有的路由都生效则可以将过滤器工厂写到default下。

格式如下

id:

上一节学习的过滤器网关提供了31种但每一种过滤器的作用都是固定的。

如果我们希望拦截请求做自己的业务逻辑则没办法实现。

全局过滤器的作用也是处理一切进入网关的请求和微服务响应与GatewayFilter的作用一样。

区别在于GatewayFilter通过配置定义处理逻辑是固定的而GlobalFilter的逻辑需要自己写代码实现。

public

GatewayFilterChain}将请求交给下一个过滤器处理**

param

请求上下文里面可以获取Request、Response等信息*

param

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

exchange.getRequest().getQueryParams();//

auth

params.getFirst(authorization);//

3.校验if

4.1.禁止访问设置状态码exchange.getResponse().setStatusCode(HttpStatus.FORBIDDEN);//

4.2.结束处理return

exchange.getResponse().setComplete();}

请求进入网关会碰到三类过滤器当前路由的过滤器、DefaultFilter、GlobalFilter

请求路由后会将当前路由过滤器和DefaultFilter、GlobalFilter合并到一个过滤器链集合中排序后依次执行每个过滤器

每一个过滤器都必须指定一个int类型的order值order值越小优先级越高执行顺序越靠前。

GlobalFilter通过实现Ordered接口或者添加Order注解来指定order值由我们自己指定路由过滤器和defaultFilter的order由Spring指定默认是按照声明顺序从1递增。

当过滤器的order值一样时会按照

defaultFilter

org.springframework.cloud.gateway.route.RouteDefinitionRouteLocator#getFilters()方法是先加载defaultFilters然后再加载某个route的filters然后合并。

org.springframework.cloud.gateway.handler.FilteringWebHandler#handle()方法会加载全局过滤器与前面的过滤器合并后根据order排序组织过滤器链

3.6.跨域问题

域名相同端口不同localhost:8080和localhost8081

跨域问题浏览器禁止请求的发起者与服务端发生跨域ajax请求请求被浏览器拦截的问题

解决方案CORS这个以前应该学习过这里不再赘述了。

不知道的小伙伴可以查看https://www.ruanyifeng.com/blog/2016/04/cors.html

3.6.2.模拟跨域问题

放入tomcat或者nginx这样的web服务器中启动并访问。

从localhost:8090访问localhost:10010端口不同显然是跨域的请求。

3.6.3.解决跨域问题

在gateway服务的application.yml文件中添加下面的配置

全局的跨域处理add-to-simple-url-handler-mapping:

true

解决options请求被拦截问题corsConfigurations:[/**]:allowedOrigins:

http://localhost:8090allowedMethods:

GET-

域名相同端口不同localhost:8080和localhost8081

跨域问题浏览器禁止请求的发起者与服务端发生跨域ajax请求请求被浏览器拦截的问题

解决方案CORS这个以前应该学习过这里不再赘述了。

不知道的小伙伴可以查看https://www.ruanyifeng.com/blog/2016/04/cors.html

3.6.2.模拟跨域问题

[外链图片转存中…(img-2VAcm9x4-1700399918824)]

放入tomcat或者nginx这样的web服务器中启动并访问。

[外链图片转存中…(img-YXFkluoe-1700399918824)]

从localhost:8090访问localhost:10010端口不同显然是跨域的请求。

3.6.3.解决跨域问题

在gateway服务的application.yml文件中添加下面的配置

全局的跨域处理add-to-simple-url-handler-mapping:

true

解决options请求被拦截问题corsConfigurations:[/**]:allowedOrigins:

http://localhost:8090allowedMethods:

GET-