使用OpenFeign依赖
openfeign用于远程服务调用，通常与负载均衡插件loadbalancer一起使用
连接池
Feign底层发起http请求，依赖于其它的框架。其底层支持的http客户端实现包括：
- HttpURLConnection：默认实现，不支持连接池
- Apache HttpClient ：支持连接池
- OKHttp：支持连接池
通常使用带连接池的客户端来替代默认的客户端
以OKHttp为例：
- 引入pom依赖
<!--OK http 的依赖 -->
<dependency>
<groupId>io.github.openfeign</groupId>
<artifactId>feign-okhttp</artifactId>
</dependency>
- 在yaml文件配置开启连接池，默认关闭
feign:
okhttp:
enabled: true # 开启OKHttp功能
- 重启服务，连接池生效
配置openfeign的日志输出
OpenFeign只会在FeignClient所在包的日志级别为DEBUG时，才会输出日志。而且其日志级别有4级：
- NONE：不记录任何日志信息，这是默认值。
- BASIC：仅记录请求的方法，URL以及响应状态码和执行时间
- HEADERS：在BASIC的基础上，额外记录了请求和响应的头信息
- FULL：记录所有请求和响应的明细，包括头信息、请求体、元数据。
Feign默认的日志级别就是NONE，所以默认我们看不到请求日志。
- 定义日志级别
新建一个配置类，添加
@Bean方法，返回值为openfeign日志级别的枚举变量package com.hmall.api.config; import feign.Logger; import org.springframework.context.annotation.Bean; public class DefaultFeignConfig { @Bean public Logger.Level feignLogLevel(){ return Logger.Level.BASIC; } }
- 配置日志生效
有两种方式：
- 局部生效：在某个
FeignClient中配置，只对当前FeignClient生效@FeignClient(value = "item-service", configuration = DefaultFeignConfig.class)
- 全局生效：在
@EnableFeignClients中配置，针对所有FeignClient生效。@EnableFeignClients(basePackages = "com.hmall.api.client", defaultConfiguration = DefaultFeignConfig.class)
网关
利用网关，可以用于用户请求的转发和负载均衡，比如用户所有请求均通过
8080发出，经过网关路由转发到对应的微服务的对应节点创建一个网关分为以下步骤：
- 创建网关微服务
- 引入SpringCloudGateway、NacosDiscovery依赖
- 编写启动类
- 配置网关路由
创建网关
-
创建网关微服务模块
-
引入SpringCloudGateway、NacosDiscovery依赖
<dependencies>
<!--网关-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>
<!--nacos discovery-->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!--负载均衡-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-loadbalancer</artifactId>
</dependency>
</dependencies>
- 创建启动类
@SpringBootApplication
public class GatewayApplication {
public static void main(String[] args) {
SpringApplication.run(GatewayApplication.class);
}
}
- 编写路由配置
server:
port: 8080
spring:
application:
name: gateway-server
cloud:
nacos:
server-addr: 192.168.48.100:8848
gateway:
routes:
- id: item-service # 路由名称：item-service
uri: lb://item-service # 负载均衡转发到指定服务
predicates: # 路由断言，配置路由-服务命中的条件
- Path=/items/**,/search/** # 这里通过请求路径前缀判断
filters: # 局部路由过滤器，可设置多个过滤器
- filter1=xxx
- id: item-service # 路由名称：user-service
uri: lb://user-service
predicates:
- Path=/users/**,/addresses/**
default-filters: # 全局路由过滤器，与routes同级
自定义过滤器
- 网关请求处理流程
网关过滤器链中的过滤器有两种：
GatewayFilter：路由过滤器，作用范围比较灵活，可以是任意指定的路由Route.GlobalFilter：全局过滤器，作用范围是所有路由，不可配置。
- 自定义GlobalFilter
自定义GlobalFilter需要实现GlobalFilter, Ordered(用于指定过滤器优先级)接口
@Component
public class PrintAnyGlobalFilter implements GlobalFilter, Ordered {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
// 编写过滤器逻辑
}
@Override
public int getOrder() {
// 过滤器执行顺序，值越小，优先级越高
return 0;
}
}
- 传递信息：网关->微服务
网关传递信息给微服务很简单：
- 在网关过滤器中将信息添加到请求头
//在网关过滤器中修改请求头的方法 ServerWebExchange newEx = exchange.mutate() .request(b -> b.header("user-info", user_info)) .build(); return chain.filter(newEx);
- 接着在SpringMVC的拦截器中获取信息并存入ThreadLocal中
这里有一个可能会碰到的错误，如果把该拦截器配置到
spring.foctories文件中实现自动装配，那么如果网关引入了该拦截器所在的模块，那么会导致网关缺失MVC依赖错误，因为拦截器是SpringMVC层的，解决方法就是使用条件装配@ConditionalOnClass(DispatcherServlet.class)，只在拥有SpringMVC的环境中装配该Bean
- 传递信息：微服务->微服务
微服务之间调用是基于OpenFeign来实现的,发起的也是http请求，因此也可以通过
请求头携带的方式来传递信息，openfeign提供了一个拦截器接口feign.RequestInterceptor，只需要实现该接口并实现apply方法，然后利用RequestTemplate对象来修改请求头。这样一来，每次OpenFeign发起请求的时候都会调用该方法，传递用户信息。
- 实现RequestInterceptor以及apply方法
@Bean public RequestInterceptor userInfoRequestInterceptor(){ return new RequestInterceptor() { @Override public void apply(RequestTemplate requestTemplate) { Long id = UserContext.getUser(); if (id != null){ requestTemplate.header("user-info",id.toString()); //添加请求头 } } }; }
微服务消息传递流程：
配置管理
配置共享
将多个微服务中共同的配置信息抽取到nacos配置文件，由nacos统一管理
实现步骤:
- 添加相关依赖
<!--nacos配置管理--> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId> </dependency> <!--读取bootstrap文件--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-bootstrap</artifactId> </dependency>
- 抽取微服务中共同的配置信息到nacos中
- 添加
bootstrap.yaml文件由于读取Nacos配置是SpringCloud上下文（
ApplicationContext）初始化时处理的，发生在项目的引导阶段。然后才会初始化SpringBoot上下文，去读取application.yaml，所以目前无法读取到nacos地址，也就不能拉去配置信息。但springcloud上下文在初始化时会读取一个bootstrap.yaml文件，可以在其中配置nacos的信息
- 添加
bootstrap.yaml文件- 编写配置信息
spring: application: name: cart-service profiles: active: dev cloud: nacos: server-addr: 192.168.48.100:8848 config: file-extension: yaml shared-configs: - dataId: shared-jdbc.yaml - dataId: shared-log.yaml - dataId: shared-swagger.yaml
- 修改
application.yaml配置内容，添加相关配置键值对，删除重复配置
配置热启动
nacos支持配置热启动，可无需重启便能修改配置信息
- 在nacos中添加配置文件（命名格式有限制），编写配置信息
dataId: [微服务名]-[spring.active.profile].[后缀名] //配置文件内容 hm: cart: maxAmount: 1 # 购物车商品数量上限
- 在微服务中使用
@ConfigurationProperties注解读取配置信息
Nacos动态路由
标签：网关,day02,配置,nacos,路由,public,cloud From： https://www.cnblogs.com/six-years/p/18323325Nacos可以配置动态路由，将路由信息保存在nacos配置管理中，动态的
添加/删除路由信息，不用重启路由服务使用的依赖：
<!--统一配置管理--> <dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId> </dependency> <!--加载bootstrap--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-bootstrap</artifactId> </dependency>通过注入
RouteDefinitionWriter（用于更新内存中的路由配置信息）和NacosConfigManager（用于拉取nacos路由配置信息和监听配置信息变化）的bean对象
- 拉取并监听nacos路由配置信息
String configInfo = nacosConfigManager.getConfigService() .getConfigAndSignListener(dataId, group, 5000, new Listener() { @Override public Executor getExecutor() { return null; } @Override public void receiveConfigInfo(String configInfo) { updateConfigInfo(configInfo); } });
- 更新内存路由配置
writer.delete(Mono.just(routeId)).subscribe(); //routeId为String类型 writer.save(Mono.just(routeDefinition)).subscribe();