【源码品读】深入了解FeignContract协议解析过程

abstract class BaseContract implements Contract {

List<MethodMetadata> parseAndValidatateMetadata(Class<?> var1);

@Override
public List<MethodMetadata> parseAndValidatateMetadata(Class<?> targetType) {checkState(targetType.getTypeParameters().length == 0, "Parameterized types unsupported: %s",targetType.getSimpleName());checkState(targetType.getInterfaces().length <= 1, "Only single inheritance supported: %s",targetType.getSimpleName());if (targetType.getInterfaces().length == 1) {checkState(targetType.getInterfaces()[0].getInterfaces().length == 0,"Only single-level inheritance supported: %s",targetType.getSimpleName());}Map<String, MethodMetadata> result = new LinkedHashMap<String, MethodMetadata>();for (Method method : targetType.getMethods()) {if (method.getDeclaringClass() == Object.class ||(method.getModifiers() & Modifier.STATIC) != 0 ||Util.isDefault(method)) {continue;}MethodMetadata metadata = parseAndValidateMetadata(targetType, method);checkState(!result.containsKey(metadata.configKey()), "Overrides unsupported: %s",metadata.configKey());result.put(metadata.configKey(), metadata);}return new ArrayList<>(result.values());
}

public interface List<E> extends Collection<E> {

  public static boolean isDefault(Method method) {// Default methods are public non-abstract, non-synthetic, and non-static instance methods// declared in an interface.// method.isDefault() is not sufficient for our usage as it does not check// for synthetic methods. As a result, it picks up overridden methods as well as actual default// methods.final int SYNTHETIC = 0x00001000;return ((method.getModifiers()& (Modifier.ABSTRACT | Modifier.PUBLIC | Modifier.STATIC | SYNTHETIC)) == Modifier.PUBLIC)&& method.getDeclaringClass().isInterface();}

protected MethodMetadata parseAndValidateMetadata(Class<?> targetType, Method method) {MethodMetadata data = new MethodMetadata();data.returnType(Types.resolve(targetType, targetType, method.getGenericReturnType()));data.configKey(Feign.configKey(targetType, method));if (targetType.getInterfaces().length == 1) {processAnnotationOnClass(data, targetType.getInterfaces()[0]);}processAnnotationOnClass(data, targetType);for (Annotation methodAnnotation : method.getAnnotations()) {processAnnotationOnMethod(data, methodAnnotation, method);}checkState(data.template().method() != null,"Method %s not annotated with HTTP method type (ex. GET, POST)",method.getName());Class<?>[] parameterTypes = method.getParameterTypes();Type[] genericParameterTypes = method.getGenericParameterTypes();Annotation[][] parameterAnnotations = method.getParameterAnnotations();int count = parameterAnnotations.length;for (int i = 0; i < count; i++) {boolean isHttpAnnotation = false;if (parameterAnnotations[i] != null) {isHttpAnnotation = processAnnotationsOnParameter(data, parameterAnnotations[i], i);}if (parameterTypes[i] == URI.class) {data.urlIndex(i);} else if (!isHttpAnnotation) {checkState(data.formParams().isEmpty(),"Body parameters cannot be used with form parameters.");checkState(data.bodyIndex() == null, "Method has too many Body parameters: %s", method);data.bodyIndex(i);data.bodyType(Types.resolve(targetType, targetType, genericParameterTypes[i]));}}if (data.headerMapIndex() != null) {checkMapString("HeaderMap", parameterTypes[data.headerMapIndex()],genericParameterTypes[data.headerMapIndex()]);}if (data.queryMapIndex() != null) {if (Map.class.isAssignableFrom(parameterTypes[data.queryMapIndex()])) {checkMapKeys("QueryMap", genericParameterTypes[data.queryMapIndex()]);}}return data;
}

@Override
protected void processAnnotationOnClass(MethodMetadata data, Class<?> clz) {if (clz.getInterfaces().length == 0) {RequestMapping classAnnotation = findMergedAnnotation(clz,RequestMapping.class);if (classAnnotation != null) {// Prepend path from class annotation if specifiedif (classAnnotation.value().length > 0) {String pathValue = emptyToNull(classAnnotation.value()[0]);pathValue = resolve(pathValue);if (!pathValue.startsWith("/")) {pathValue = "/" + pathValue;}data.template().uri(pathValue);}}}
}

@Override
protected void processAnnotationOnMethod(MethodMetadata data,Annotation methodAnnotation, Method method) {if (!RequestMapping.class.isInstance(methodAnnotation) && !methodAnnotation.annotationType().isAnnotationPresent(RequestMapping.class)) {return;}RequestMapping methodMapping = findMergedAnnotation(method, RequestMapping.class);// HTTP MethodRequestMethod[] methods = methodMapping.method();if (methods.length == 0) {methods = new RequestMethod[] { RequestMethod.GET };}checkOne(method, methods, "method");data.template().method(Request.HttpMethod.valueOf(methods[0].name()));// pathcheckAtMostOne(method, methodMapping.value(), "value");if (methodMapping.value().length > 0) {String pathValue = emptyToNull(methodMapping.value()[0]);if (pathValue != null) {pathValue = resolve(pathValue);// Append path from @RequestMapping if value is present on methodif (!pathValue.startsWith("/") && !data.template().path().endsWith("/")) {pathValue = "/" + pathValue;}data.template().uri(pathValue, true);}}// producesparseProduces(data, method, methodMapping);// consumesparseConsumes(data, method, methodMapping);// headersparseHeaders(data, method, methodMapping);data.indexToExpander(new LinkedHashMap<Integer, Param.Expander>());
}

@RequestMapping(method = RequestMethod.GET)
public @interface GetMapping {

private void checkOne(Method method, Object[] values, String fieldName) {checkState(values != null && values.length == 1,"Method %s can only contain 1 %s field. Found: %s", method.getName(),fieldName, values == null ? null : Arrays.asList(values));
}

private void checkAtMostOne(Method method, Object[] values, String fieldName) {checkState(values != null && (values.length == 0 || values.length == 1),"Method %s can only contain at most 1 %s field. Found: %s",method.getName(), fieldName,values == null ? null : Arrays.asList(values));
}

private String resolve(String value) {if (StringUtils.hasText(value)&& this.resourceLoader instanceof ConfigurableApplicationContext) {return ((ConfigurableApplicationContext) this.resourceLoader).getEnvironment().resolvePlaceholders(value);}return value;
}

private void parseProduces(MethodMetadata md, Method method,RequestMapping annotation) {String[] serverProduces = annotation.produces();String clientAccepts = serverProduces.length == 0 ? null: emptyToNull(serverProduces[0]);if (clientAccepts != null) {md.template().header(ACCEPT, clientAccepts);}
}

private void parseConsumes(MethodMetadata md, Method method,RequestMapping annotation) {String[] serverConsumes = annotation.consumes();String clientProduces = serverConsumes.length == 0 ? null: emptyToNull(serverConsumes[0]);if (clientProduces != null) {md.template().header(CONTENT_TYPE, clientProduces);}
}

private void parseHeaders(MethodMetadata md, Method method,RequestMapping annotation) {// TODO: only supports one header value per keyif (annotation.headers() != null && annotation.headers().length > 0) {for (String header : annotation.headers()) {int index = header.indexOf('=');if (!header.contains("!=") && index >= 0) {md.template().header(resolve(header.substring(0, index)),resolve(header.substring(index + 1).trim()));}}}
}

【源码品读】深入了解FeignContract协议解析过程相关推荐

英雄远征Erlang源码分析（5）-协议解析与玩家登录处理
现在,客户端与服务器的连接算是正式建立了,此时用户需要做的第一件事就是登陆.不过在登录之前,我们要先研究下前后端通信的协议. 客户端与服务端建立连接后,通过提前制定好的协议进行交互.具体的协议文档在d ...
Uboot中start.S源码的指令级的详尽解析在线版
http://bbs.chinaunix.net/thread-2312785-1-1.html 以后所有内容更新,都放在这里: Uboot中start.S源码的指令级的详尽解析在线版 Uboot ...
Uboot中start.S源码的指令级的详尽解析（转）
Uboot中start.S源码的指令级的详尽解析转载于:https://www.cnblogs.com/LittleTiger/p/10877516.html
php tire树,Immutable.js源码之List 类型的详细解析（附示例）
本篇文章给大家带来的内容是关于Immutable.js源码之List 类型的详细解析(附示例),有一定的参考价值,有需要的朋友可以参考一下,希望对你有所帮助. 一.存储图解我以下面这段代码为例子,画 ...
什么是php的ast结构,什么是AST？Vue源码中AST语法树的解析
这篇文章给大家介绍的内容是关于什么是AST?Vue源码中AST语法树的解析,有一定的参考价值,有需要的朋友可以参考一下,希望对你有所帮助. 什么是AST AST是指抽象语法树(abstract syn ...
Uboot中start.S源码的指令级的详尽解析
Uboot中start.S源码的指令级的详尽解析版本:v1.9 Crifan Li 摘要本文对Uboot中的Start.S的源码的几乎每一行,都进行了详细的解析本文提供多种格式供: 在线阅读 H ...
Spectacle源码及分析3 —— Main.cpp解析2
接前一篇文章<Spectacle源码及分析2 -- Main.cpp解析1>: Spectacle源码及分析2 -- Main.cpp解析1_蓝天居士的博客-CSDN博客继续深入分析Ma ...
找一个网页，用浏览器查看源码并复制，然后尝试解析一下HTML，输出Python官网发布的会议时间、名称和地点——python学习笔记
1. 题目: 找一个网页,例如https://www.python.org/events/python-events/,用浏览器查看源码并复制,然后尝试解析一下HTML,输出Python官网发布的会议 ...
Spring AOP 源码分析 - 拦截器链的执行过程
1.简介本篇文章是 AOP 源码分析系列文章的最后一篇文章,在前面的两篇文章中,我分别介绍了 Spring AOP 是如何为目标 bean 筛选合适的通知器,以及如何创建代理对象的过程.现在我们的得 ...

【源码品读】深入了解FeignContract协议解析过程

【源码品读】深入了解FeignContract协议解析过程相关推荐

最新文章

热门文章