闷棍暴打面试官 SpringCloud源码系列 : (一) SpringCloud的前世今生

RestTemplate (场景: 简化 HTTP 通信方式，统一了RESTful的标准并为 执行复杂任务提供了一种具有默认行为的简化方法, 可以理解为 GOF中的 模板模式)

• HttpMessageConverter: 对象转换器
• ClientHttpRequestFactory: 提供了多种便捷访问远程Http服务的方法,能够大大提高客户端的编写效率。
• ResponseErrorHandler: 异常处理
• ClientHttpRequestInterceptor: 请求拦截器

Spring 核心 HTTP 消息转换器 HttpMessageConverter

Rest自描述信息: 媒体类型 (MediaType) : text/html; text/xml; application/json

HTTP 协议特点: 纯文本协议 ,需要自我描述

• REST 客户端
• REST 服务端

反序列化 : 文本(通信) ---> 对象(程序使用)

序列化: 对象(程序) ----> 文本(通信)

分析 HttpMessageConverter

// 策略接口，它指定了一个转换器，可以将请求和响应转换为HTTP请求和响应。 
public interface HttpMessageConverter {
  // 判断当前 泛型是否可以反序列化
    boolean canRead(Class clazz, @Nullable MediaType mediaType);
    // 判断当前 泛型是否可以序列化
  boolean canWrite(Class clazz, @Nullable MediaType mediaType);
    // 当前支持的媒体类型
      List getSupportedMediaTypes();
    // 反序列化对象
    T read(Class clazz, HttpInputMessage inputMessage)   throws IOException, HttpMessageNotReadableException;
}

特别提醒: SpringWebMVC 依赖于 Servlet, Spring 在设计早期时, 它就考虑到了去 Servlet 化.

HttpInputMessage 类似于 HttpServletRequest

RestTemplate 利用 HttpMessageConverter 对一些媒体类型进行通用的序列化和反序列化

• JSON
• XML
• TEXT
• ByteArrays

它不依赖于 Servlet 它自定义实现, 对于 服务端而言. 将 ServletAPI 适配或 HttpInputMessage 以及 HttpOutputMessage .

---

RestTemplate 对应多个 HttpMessageConverter 那么如何决策正确的媒体类型

将各种常用 HttpMessageConverter 支持的MediaType 和 JavaType 以及对应关系总结在此处：

类名	支持的JavaType	支持的MediaType
ByteArrayHttpMessageConverter	byte[]	application/octet-stream, /
StringHttpMessageConverter	String	text/plain, /
MappingJackson2HttpMessageConverter	Object	application/json, application @Bean feign.Logger.Level feignLoggerLevel() { return feign.Logger.Level.BASIC; } } SpringCloudOpenFeign客户端代码 import feign.hystrix.FallbackFactory; import lombok.extern.slf4j.Slf4j; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.http.MediaType; import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.*; // 如要运行 demo 请对 TODO 进行替换 @FeignClient(value = "TODO 你要调用微服务的 spring.application.name", fallbackFactory = UserServiceFallbackFactory.class) public interface DemoServiceClient { @PutMapping(value = "/demo/keys/{key}", produces = MediaType.APPLICATION_JSON_VALUE) public Boolean setKey(@PathVariable(value = "key") String key, @RequestParam("value") String value); @GetMapping(value = "/demo/keys/{key}", produces = MediaType.APPLICATION_JSON_VALUE) public String getKey(@PathVariable(value = "key") String key); } @Component @Slf4j class UserServiceFallbackFactory implements FallbackFactory { @Override public DemoServiceClient create(final Throwable throwable) { return new DemoServiceClient() { @Override public Boolean setKey(String key, String value) { log.warn("Fallback reason={}", throwable.getMessage()); return false; } @Override public String getKey(String key) { log.warn("Fallback reason={}", throwable.getMessage()); return null; } }; } } 客户端web接口代码 import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @RestController @RequestMapping("/openfeign-demo") @Slf4j public class DemoResource { @Autowired private DemoServiceClient demoServiceClient; @ApiOperation(value = "根据 K 查看 V值", notes="根据 K 查看 V值 notes") @ApiImplicitParams({ @ApiImplicitParam(name = "key" , value = "key", required = true, dataType = "string", paramType = "path"), }) @GetMapping(value = "/{key}", produces = "application/json;charset=UTF-8") public String getValue(@PathVariable String key) { return demoServiceClient.getKey(key); } @ApiOperation(value = "设置 K/V", notes="设置 K/V notes") @ApiImplicitParams({ @ApiImplicitParam(name = "key", value = "key", required = true, dataType = "string", paramType = "path"), @ApiImplicitParam(name = "value", value = "value", required = true, dataType = "string", paramType = "query") }) @PutMapping(value = "/{key}", produces = "application/json;charset=UTF-8") public Boolean setValue(@PathVariable String key, @RequestParam("value") String value) { return demoServiceClient.setKey(key,value); } } SpringCloudOpenFeign服务端代码 spring: application: name: TODO 服务端Web接口代码 import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; import org.springframework.web.bind.annotation.*; import java.util.concurrent.ConcurrentHashMap; @RestController @RequestMapping("/demo") public class DemoController { private static volatile ConcurrentHashMap kv = new ConcurrentHashMap(20); static { kv.put("1024","hello OpenFeign"); } @ApiOperation(value = "根据 K 查看 V值", notes="根据 K 查看 V值 notes") @ApiImplicitParams({ @ApiImplicitParam(name = "key" , value = "key", required = true, dataType = "string", paramType = "path"), }) @GetMapping(value = "/keys/{key}", produces = "application/json;charset=UTF-8") public String getValue(@PathVariable String key) { return String.valueOf(kv.get(key)); } @ApiOperation(value = "设置 K/V", notes="设置 K/V notes") @ApiImplicitParams({ @ApiImplicitParam(name = "key", value = "key", required = true, dataType = "string", paramType = "path"), @ApiImplicitParam(name = "value", value = "value", required = true, dataType = "string", paramType = "query") }) @PutMapping(value = "/keys/{key}", produces = "application/json;charset=UTF-8") public Boolean setValue(@PathVariable String key, @RequestParam("value") String value) { Object put = kv.put(key, value); return kv.containsKey(key); } } SpringCloudOpenFeign测试用例代码 import org.junit.Test; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.http.HttpEntity; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpMethod; import org.springframework.http.client.HttpComponentsClientHttpRequestFactory; import org.springframework.web.client.RestTemplate; import static org.junit.Assert.assertEquals; @SpringBootTest(classes = TODORun.class) public class DemoResourceTest { @SneakyThrows @Test public void b_Key() throws Exception { RestTemplate restTemplate = new RestTemplate(new HttpComponentsClientHttpRequestFactory()); Boolean setKeyRespond = restTemplate.exchange("http://TODO客户端ip端口/openfeign-demo/1025?value=gczy",HttpMethod.PUT,new HttpEntity(new HttpHeaders()),Boolean.class).getBody(); String getKeyRespond = restTemplate.getForObject("http://localhost:8081/openfeign-demo/1024", String.class); String getsetKeyRespond = restTemplate.getForObject("http://TODO客户端ip端口/openfeign-demo/1025", String.class); assertEquals(setKeyRespond,Boolean.TRUE); assertEquals(getKeyRespond, "hello OpenFeign"); assertEquals(getsetKeyRespond, "gczy"); } } SpringCloudOpenFeign源码分析 @FeignClient(value="todo") @EnableFeignClients(basePackages = "com.todo.node") @RequestParam() @GetMapping() // 节选部分源码 SpringCloudOpenFeign-core 2.2.2 // 同志们 顺着方法调用栈追踪源码. 别怕, 前方安全, 有注释 ! @Retention(RetentionPolicy.RUNTIME) @Target(ElementType.TYPE) @documented @import(FeignClientsRegistrar.class) public @interface EnableFeignClients { String[] basePackages() default {}; } @Target(ElementType.TYPE) @Retention(RetentionPolicy.RUNTIME) @documented public @interface FeignClient { @AliasFor("name") String value() default ""; } // 实现接口的中的方法完成 Feign 注册bean class FeignClientsRegistrar implements importBeanDefinitionRegistrar, ResourceLoaderAware, EnvironmentAware { private ResourceLoader resourceLoader; private Environment environment; @Override public void registerBeanDefinitions(Annotationmetadata metadata, BeanDefinitionRegistry registry) { // registerDefaultConfiguration(metadata, registry); registerFeignClients(metadata, registry); } @Override public void setResourceLoader(ResourceLoader resourceLoader) { this.resourceLoader = resourceLoader; } @Override public void setEnvironment(Environment environment) { this.environment = environment; } private void registerDefaultConfiguration(Annotationmetadata metadata, BeanDefinitionRegistry registry) { // 获得 @EnableFeignClients() 注解的自定义属性 Map defaultAttrs = metadata .getAnnotationAttributes(EnableFeignClients.class.getName(), true); // 当前项目是否使用 SpringCloudOpenFeign - @EnableFeignClients() if (defaultAttrs != null && defaultAttrs.containsKey("defaultConfiguration")) { String name; // 判断当前标识 @EnableFeignClients() 的配置类是否为封闭类 if (metadata.hasEnclosingClass()) { name = "default." + metadata.getEnclosingClassName(); } else { name = "default." + metadata.getClassName(); } // 初始化注册客户端配置为bean registerClientConfiguration(registry, name, defaultAttrs.get("defaultConfiguration")); } } public void registerFeignClients(Annotationmetadata metadata, BeanDefinitionRegistry registry) { // 初始化包扫描器和类加载器 ClassPathScanningCandidateComponentProvider scanner = getScanner(); scanner.setResourceLoader(this.resourceLoader); Set basePackages; // 获得 @EnableFeignClients() 注解的自定义属性 Map attrs = metadata .getAnnotationAttributes(EnableFeignClients.class.getName()); // 初始化包含类型筛选器 AnnotationTypeFilter annotationTypeFilter = new AnnotationTypeFilter( FeignClient.class); // 查看 @EnableFeignClients() clients属性是否指定 FeignClient客户端 final Class[] clients = attrs == null ? null : (Class[]) attrs.get("clients"); // 如果没有指定就根据 @EnableFeignClients() 属性获得客户端全部包名 if (clients == null || clients.length == 0) { scanner.addIncludeFilter(annotationTypeFilter); basePackages = getbasePackages(metadata); } else { // 指定clients属性则走原有逻辑 final Set clientClasses = new HashSet<>(); basePackages = new HashSet<>(); for (Class clazz : clients) { basePackages.add(ClassUtils.getPackageName(clazz)); clientClasses.add(clazz.getCanonicalName()); } AbstractClassTestingTypeFilter filter = new AbstractClassTestingTypeFilter() { @Override protected boolean match(Classmetadata metadata) { String cleaned = metadata.getClassName().replaceAll("\$", "."); return clientClasses.contains(cleaned); } }; scanner.addIncludeFilter( new AllTypeFilter(Arrays.asList(filter, annotationTypeFilter))); } // 根据全部自定义包名寻找 @FeignClient 类客户端 for (String basePackage : basePackages) { // 将 @FeignClient 类全部初始化为 bean Set candidateComponents = scanner .findCandidateComponents(basePackage); for (BeanDefinition candidateComponent : candidateComponents) { if (candidateComponent instanceof AnnotatedBeanDefinition) { // verify annotated class is an interface AnnotatedBeanDefinition beanDefinition = (AnnotatedBeanDefinition) candidateComponent; Annotationmetadata annotationmetadata = beanDefinition.getmetadata(); // 过滤 @FeignClient 非接口形式的客户端. Assert.isTrue(annotationmetadata.isInterface(), "@FeignClient can only be specified on an interface"); // 获取 @FeignClient 类的全部属性 Map attributes = annotationmetadata .getAnnotationAttributes( FeignClient.class.getCanonicalName()); // 获取调用微服务名称 String name = getClientName(attributes); // 注册 @FeignClient 类为bean registerClientConfiguration(registry, name, attributes.get("configuration")); // 将@FeignClient 服务接口形成代理实现 @RequestParam() @GetMapping() registerFeignClient(registry, annotationmetadata, attributes); } } } } } 下期预告-(二) JHipster 让 SpringCloud架构变得简单 转载请注明：文章转载自 www.mshxw.com 本文地址：https://www.mshxw.com/it/236415.html 上一篇 面试阿里被P8质问:ConcurrentHashMap真的线程安全吗？ 下一篇 在SpringBoot中验证用户上传的图片资源 Java相关栏目本月热门文章 1【Linux驱动开发】设备树详解（二）设备树语法详解 2别跟客户扯细节 3Springboot+RabbitMQ+ACK机制(生产方确认(全局、局部)、消费方确认)、知识盲区 4【Java】对象处理流（ObjectOutputStream和ObjectInputStream） 5【分页】常见两种SpringBoot项目中分页技巧 6一文带你搞懂OAuth2.0 7我要写整个中文互联网界最牛逼的JVM系列教程 | 「JVM与Java体系架构」章节：虚拟机与Java虚拟机介绍 8【Spring Cloud】新闻头条微服务项目：FreeMarker模板引擎实现文章静态页面生成 9JavaSE - 封装、static成员和内部类 10树莓派mjpg-streamer实现监控及拍照功能调试 11用c++写一个蓝屏代码 12从JDK8源码中看ArrayList和LinkedList的区别 13idea 1、报错java: 找不到符号 符号: 变量 log 2、转换成Maven项目 14在openwrt使用C语言增加ubus接口（包含C uci操作） 15Spring 解决循环依赖 16SpringMVC——基于MVC架构的Spring框架 17Andy‘s First Dictionary C++ STL set应用 18动态内存管理 19我的创作纪念日 20Docker自定义镜像-Dockerfile 热门相关搜索 路由器设置 木托盘 宝塔面板 儿童python教程 心情低落 朋友圈 vim 双一流学科 专升本 我的学校 日记学校 西点培训学校 汽修学校 情书 化妆学校 塔沟武校 异形模板 西南大学排名 最精辟人生短句 6步教你追回被骗的钱 南昌大学排名 清朝十二帝 北京印刷学院排名 北方工业大学排名 北京航空航天大学排名 首都经济贸易大学排名 中国传媒大学排名 首都师范大学排名 中国地质大学(北京)排名 北京信息科技大学排名 中央民族大学排名 北京舞蹈学院排名 北京电影学院排名 中国戏曲学院排名 河北政法职业学院排名 河北经贸大学排名 天津中德应用技术大学排名 天津医学高等专科学校排名 天津美术学院排名 天津音乐学院排名 天津工业大学排名 北京工业大学耿丹学院排名 北京警察学院排名 天津科技大学排名 北京邮电大学(宏福校区)排名 北京网络职业学院排名 北京大学医学部排名 河北科技大学排名 河北地质大学排名 河北体育学院排名 学习工具 代数计算器 三角函数 解析几何 立体几何 知识解答 教育知识 百科知识 生活知识 常识知识 写作必备 作文大全 作文素材 句子大全 实用范文 关于我们 关于我们 联系我们 网站地图 名师互学网交流群 名师互学网客服 名师互学网 版权所有 (c)2021-2022 ICP备案号：晋ICP备2021003244-6号 关于我们 文章归档 网站地图 联系我们 版权所有 (c)2021-2022 MSHXW.COM ICP备案号：晋ICP备2021003244-6号