网站开发主流,wordpress wp super cache,dedecms做视频网站,企业网站后台管理系统1、 使用Feign实现远程HTTP调用
1.1、常见HTTP客户端 HttpClient HttpClient 是 Apache Jakarta Common 下的子项目#xff0c;用来提供高效的、最新的、功能丰富的支持 Http 协 议的客户端编程工具包#xff0c;并且它支持 HTTP 协议最新版本和建议。HttpClient 相比传统 J…1、 使用Feign实现远程HTTP调用
1.1、常见HTTP客户端 HttpClient HttpClient 是 Apache Jakarta Common 下的子项目用来提供高效的、最新的、功能丰富的支持 Http 协 议的客户端编程工具包并且它支持 HTTP 协议最新版本和建议。HttpClient 相比传统 JDK 自带的 URLConnection提升了易用性和灵活性使客户端发送 HTTP 请求变得容易提高了开发的效率。 Okhttp 一个处理网络请求的开源项目是安卓端最火的轻量级框架由 Square 公司贡献用于替代 HttpUrlConnection 和 Apache HttpClient。OkHttp 拥有简洁的 API、高效的性能并支持多种协议 HTTP/2 和 SPDY。 HttpURLConnection HttpURLConnection 是 Java 的标准类它继承自 URLConnection可用于向指定网站发送 GET 请求、 POST 请求。HttpURLConnection 使用比较复杂不像 HttpClient 那样容易使用。 RestTemplate RestTemplate 是 Spring 提供的用于访问 Rest 服务的客户端RestTemplate 提供了多种便捷访问远程 HTTP 服务的方法能够大大提高客户端的编写效率。
1.2、什么是Fegin
Feign是Netflix开源的声明式HTTP客户端
1.3、优点
Feign可以做到使用 HTTP 请求远程服务时就像调用本地方法一样的体验开发者完全感知不到这是远程方 更感知不到这是个 HTTP 请求。
【Fegin和OpenFeign的区别Spring Cloud openfeign对Feign进行了 增强使其支持Spring MVC注解另外还整合了Ribbon和Eureka从而使得Feign的使用更加方便 】
1.4、重构以前的代码
三板斧 引入依赖 dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-openfeign/artifactId/dependency写启动注解 增加配置 暂时没有配置进行改造
增加一个feign他也是基于ribbon进行操作的所以以前我们学的ribbon在这里也适用
package com.msb.order.feignclient;
FeignClient(name yuyang-stock)
public interface StockFeignClient {GetMapping(/stock/reduce/{productId})String reduce(PathVariable Integer productId);
}
package com.msb.order.controller;
Slf4j
RestController
public class OrderController {Autowiredprivate StockFeignClient stockFeignClient;GetMapping(/order/create)public String createOrder(Integer productId,Integer userId){String reduce stockFeignClient.reduce(productId);log.info(减库存成功{},reduce);return 下单成功;}
}我们在这里看一下我们启动了两个微服务他们都发起了调用也就feign后台实现了负载均衡。我们可以看一下他的继承关系我们发现fegin里面有依赖了ribbon所以他除了增强了我们springmvc注解同时也整合我们的ribbon 2、Feign的组成
接口作用默认值Feign.BuilderFeign的入口Feign.BuilderClientFeign底层用什么去请求和Ribbon配合时LoadBalancerFeignClientbr /不和Ribbon配合时Feign.Client.DefaultContract契约注解支持SpringMVC ContractEncoder解码器用于将独享转换成HTTP请求消息体SpringEncoderDecoder编码器将相应消息体转成对象ResponseEntityDecoderLogger日志管理器Slf4jLoggerRequestInterceptor用于为每个请求添加通用逻辑拦截器例子比如想给每个请求都带上heared无
Feign.Client.Default 利用的是我们默认的HttpURLConnection他是没有连接池的。也没有资源管理这个概念性能不是很好 3、细粒度配置自定义
3.1、代码方式-指定日志级别
feign默认是不打印任何日志的但是我们希望打印一些日志信息。比如调用的时间。
Feign设置方式就不同的他有四个级别如下
级别打印日志内容NONE默认值)不记录任何日志BASIC仅记录请求方法、URL、响应状态代码以及执行时间HEADERS记录BASIC级别的基础上记录请求和响应的headerFULL记录请求和响应的header、body和元数据
1.1 指定springboot日志
Feign日志是基于Spring boot的日志所以先设置SpringBoot日志
logging:level:com.msb: debug1.2 创建配置类
BASIC使用于生产环境 FULL适用于开发环境
创建配置类UserFeignConfiguration 注意这里并没有增加Configuration
package com.msb.order.configuration;import feign.Logger;
import org.springframework.context.annotation.Bean;
//这里不能增加Configuration如果添加了就会变为全局配置文件。
public class StockFeignConfiguration {Beanpublic Logger.Level level(){return Logger.Level.FULL;}
}更改请求feign的配置文件。
1.3 将配置类引入 3.2、属性方式-指定日志级别
feign.client.config.feignName.loggerLevel:full
logging:level:com.msb: debug
feign:client:config:msb-stock:loggerLevel: full4、全局配置自定义
1、代码配置 方式一:让父子上下文ComponentScan重叠强烈不建议使用 Configuration
public class StockFeignConfiguration {/*** 日志级别* 通过源码可以看到日志等级有 4 种分别是* NONE不输出日志。* BASIC只输出请求方法的 URL 和响应的状态码以及接口执行的时间。* HEADERS将 BASIC 信息和请求头信息输出。* FULL输出完整的请求信息。*/Beanpublic Logger.Level level(){return Logger.Level.FULL;}
}方式二【唯一正确的途径】: EnableFeignClients(defaultConfigurationxxx.class) 2、属性配置
logging:level:com.msb: debug
feign:client:config:default:loggerLevel: full5、 支持的配置项
5.1、契约配置
Spring Cloud 在 Feign 的基础上做了扩展可以让 Feign 支持 Spring MVC 的注解来调用。原生的 Feign 是不支持 Spring MVC 注解的如果你想在 Spring Cloud 中使用原生的注解方式来定义客户端也是 可以的通过配置契约来改变这个配置Spring Cloud 中默认的是 SpringMvcContract。
1.1代码方式 /*** 修改契约配置这里仅仅支持Feign原生注解* 这里是一个扩展点如果我们想支持其他的注解可以更改Contract的实现类。* return*/Beanpublic Contract feignContract(){return new Contract.Default();}注意这里修改了契约配置之后我们就只能用Fegin的原生注解 1.2 属性方式 5.2、编解码
Feign 中提供了自定义的编码解码器设置同时也提供了多种编码器的实现比如 Gson、Jaxb、Jackson。 我们可以用不同的编码解码器来处理数据的传输。。
扩展点Encoder Decoder
默认我们使用SpringEncoder和SpringDecoder
package feign.codec;
public interface Encoder {void encode(Object object, Type bodyType, RequestTemplate template) throws EncodeException;
}package feign.codec;
public interface Decoder {Object decode(Response response, Type type) throws IOException, DecodeException, FeignException;
}2.1 代码方式
Bean
public Decoder decoder(){return new CustomDecoder();
}
Bean
public Encoder encoder(){return new CustomEncoder();
}2.2 属性方式
feign:client:config:#想要调用的微服务的名称msb-user:encoder: com.xxx.CustomDecoderdecoder: com.xxx..CustomEncoder5.3、拦截器
通常我们调用的接口都是有权限控制的很多时候可能认证的值是通过参数去传递的还有就是通过请求头 去传递认证信息比如 Basic 认证方式。
3.1 扩展点
package feign;public interface RequestInterceptor {void apply(RequestTemplate template);
}3.2 使用场景
统一添加 header 信息对 body 中的信息做修改或替换
3.3 自定义逻辑
package com.msb.order.interceptor;import feign.RequestInterceptor;
import feign.RequestTemplate;public class FeignAuthRequestInterceptor implements RequestInterceptor {private String tokenId;public FeignAuthRequestInterceptor(String tokenId) {this.tokenId tokenId;}Overridepublic void apply(RequestTemplate template) {template.header(Authorization,tokenId);}
}package com.msb.order.configuration;import com.msb.order.interceptor.FeignAuthRequestInterceptor;import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;Configuration
public class FeignConfig {Value(${feign.tokenId})private String tokenId;/*** 自定义拦截器* return*/Beanpublic FeignAuthRequestInterceptor feignAuthRequestInterceptor(){return new FeignAuthRequestInterceptor(tokenId);}
}feign:tokenId: d874528b-a9d9-46df-ad90-b92f87ccc557在msb-stock项目中增加springmvc中的拦截器
拦截器代码
package com.msb.stock.interceptor;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
Slf4j
public class AuthInterceptor implements HandlerInterceptor {Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {boolean flag true;// 逻辑认证String authorization request.getHeader(Authorization);log.info(获取的认证信息 Authorization{},authorization);if(StringUtils.hasText(authorization)){return true;}return false;}
}增加类配置:
package com.msb.user.interceptor;import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport;
Configuration
public class WebMvcConfig extends WebMvcConfigurationSupport {Overrideprotected void addInterceptors(InterceptorRegistry registry) {registry.addInterceptor(new AuthInterceptor());}
5.4、Client 设置
Feign 中默认使用 JDK 原生的 URLConnection 发送 HTTP 请求我们可以集成别的组件来替换掉 URLConnection比如 Apache HttpClientOkHttp。
4.1 扩展点
Feign发起调用真正执行逻辑feign.Client#execute 扩展点
public interface Client {Response execute(Request request, Options options) throws IOException;}4.2 配置Apache HttpClient 引入依赖 dependencygroupIdio.github.openfeign/groupIdartifactIdfeign-httpclient/artifactId
/dependency修改yml配置 开启feign ,这里可以不用配置可以参考源码分析 feign:httpclient:#使用apache httpclient做请求而不是jdk的HttpUrlConnectionenabled: true# feign最大链接数 默认200max-connections: 200#feign 单个路径的最大连接数 默认 50max-connections-per-route: 50源码分析 FeignAutoConfiguration
此时默认增加一个ApacheHttpCient实现类 4.3 设置OkHttp 引入依赖 dependencygroupIdio.github.openfeign/groupIdartifactIdfeign-okhttp/artifactId
/dependency增加配置 feign:okhttp:enabled: true#线程池可以使用httpclient的配置 httpclient:max-connections: 200max-connections-per-route: 503、源码分析 FeignAutoConfiguration 5.5、超时配置
通过 Options 可以配置连接超时时间和读取超时时间Options 的第一个参数是连接的超时时间ms 默认值是 10s第二个是请求处理的超时时间ms默认值是 60s。
Request.Options 5.1 代码配置
Bean
public Request.Options options(){return new Request.Options(2000,50000);
}msb-stock改造
GetMapping(query)
public User queryInfo(User user){try {Thread.sleep(10*1000);} catch (InterruptedException e) {e.printStackTrace();}return user;
}6、推荐配置方式
尽量使用属性配置属性方式实现不了的情况下再考虑用代码配置在同一个微服务内尽量保持单一性比如统一使用属性配置不要两种方式混用增加定位代码的复杂性
