当前位置：首页 > news >正文

按DDD领域分析Openfeign

news 2026/4/10 2:09:27

按DDD领域分析Openfeign

请关注微信公众号：阿呆-bot

1. 入口类及说明

1.1 入口类：Feign 和 ReflectiveFeign

Feign 是抽象工厂类，ReflectiveFeign 是其基于反射的实现，负责创建 HTTP API 代理实例。

public abstract class Feign {public static Builder builder() {return new Builder();}public abstract <T> T newInstance(Target<T> target);
}public class ReflectiveFeign<C> extends Feign {public <T> T newInstance(Target<T> target) {Map<Method, MethodHandler> methodToHandler = targetToHandlersByName.apply(target, requestContext);InvocationHandler handler = factory.create(target, methodToHandler);return (T) Proxy.newProxyInstance(target.type().getClassLoader(), new Class<?>[] {target.type()}, handler);}
}

2. DDD 业务域划分

Core 模块可以划分为以下业务域：

2.1 契约域（Contract Domain）

职责: 解析接口方法上的注解，生成方法元数据。

核心类:

Contract: 契约接口
BaseContract: 基础契约实现
DeclarativeContract: 声明式契约基类
Contract.Default: 默认契约实现
MethodMetadata: 方法元数据

领域边界: 负责将 Java 接口方法转换为 HTTP 请求元数据，不涉及实际的 HTTP 请求执行。

PlantUML 类关系图

2.2 方法处理域（MethodHandler Domain）

职责: 处理接口方法的调用，执行 HTTP 请求并解码响应。

核心类:

MethodHandler: 方法处理器接口
SynchronousMethodHandler: 同步方法处理器
AsynchronousMethodHandler: 异步方法处理器
DefaultMethodHandler: 默认方法处理器（处理接口默认方法）
MethodHandlerConfiguration: 方法处理器配置

领域边界: 负责方法调用的执行流程，包括请求构建、HTTP 执行、响应处理，但不涉及注解解析。

PlantUML 类关系图

2.3 客户端域（Client Domain）

职责: 执行实际的 HTTP 请求，是 Feign 与底层 HTTP 库的抽象。

核心类:

Client: HTTP 客户端接口
Client.Default: 默认实现（基于 HttpURLConnection）
AsyncClient: 异步客户端接口

领域边界: 负责 HTTP 请求的执行，不涉及请求构建和响应解码。

PlantUML 类关系图

2.4 编解码域（Encoder/Decoder Domain）

职责: 将 Java 对象编码为 HTTP 请求体，将 HTTP 响应体解码为 Java 对象。

核心类:

Encoder: 编码器接口
Encoder.Default: 默认编码器
Decoder: 解码器接口
Decoder.Default: 默认解码器
ErrorDecoder: 错误解码器接口

领域边界: 负责对象序列化和反序列化，不涉及 HTTP 传输。

PlantUML 类关系图

2.5 目标域（Target Domain）

职责: 表示要调用的远程 HTTP 服务，包含服务类型、名称和基础 URL。

核心类:

Target: 目标接口
Target.HardCodedTarget: 硬编码目标实现
Target.EmptyTarget: 空目标实现

领域边界: 负责目标服务的表示和请求模板的应用，不涉及具体的 HTTP 请求执行。

PlantUML 类关系图

2.6 请求模板域（RequestTemplate Domain）

职责: 构建 HTTP 请求模板，支持 URI 模板表达式和参数替换。

核心类:

RequestTemplate: 请求模板类
RequestTemplate.Factory: 请求模板工厂接口（内部接口）
RequestTemplateFactoryResolver: 请求模板工厂解析器
template.UriTemplate: URI 模板
template.BodyTemplate: 请求体模板
template.HeaderTemplate: 请求头模板
template.QueryTemplate: 查询参数模板

领域边界: 负责请求模板的构建和参数替换，不涉及实际的 HTTP 请求发送。

PlantUML 类关系图

3. 领域间关系

3.1 领域协作流程

各业务域通过以下方式协作：

契约域 → 方法处理域: Contract 解析注解生成 MethodMetadata，MethodHandler 使用 MethodMetadata 构建请求
方法处理域 → 请求模板域: MethodHandler 使用 RequestTemplateFactory 创建请求模板
方法处理域 → 客户端域: MethodHandler 调用 Client 执行 HTTP 请求
方法处理域 → 编解码域: MethodHandler 使用 Encoder 编码请求体，使用 Decoder 解码响应体
方法处理域 → 目标域: MethodHandler 使用 Target 应用请求模板

PlantUML 时序图：方法调用流程

4. 关键代码片段

4.1 Contract 解析方法元数据

protected MethodMetadata parseAndValidateMetadata(Class<?> targetType, Method method) {final MethodMetadata data = new MethodMetadata();data.targetType(targetType);data.method(method);data.returnType(Types.resolve(targetType, targetType, method.getGenericReturnType()));data.configKey(Feign.configKey(targetType, method));processAnnotationOnClass(data, targetType);for (final Annotation methodAnnotation : method.getAnnotations()) {processAnnotationOnMethod(data, methodAnnotation, method);}// 处理参数注解for (int i = 0; i < parameterAnnotations.length; i++) {processAnnotationsOnParameter(data, parameterAnnotations[i], i);}return data;
}

4.2 SynchronousMethodHandler 执行请求

public Object invoke(Object[] argv) throws Throwable {RequestTemplate template = methodHandlerConfiguration.getBuildTemplateFromArgs().create(argv);Options options = findOptions(argv);Retryer retryer = this.methodHandlerConfiguration.getRetryer().clone();while (true) {try {return executeAndDecode(template, options);} catch (RetryableException e) {retryer.continueOrPropagate(e);continue;}}
}Object executeAndDecode(RequestTemplate template, Options options) throws Throwable {Request request = targetRequest(template);Response response = client.execute(request, options);return responseHandler.handleResponse(methodHandlerConfiguration.getMetadata().configKey(), response,methodHandlerConfiguration.getMetadata().returnType(), elapsedTime);
}

4.3 RequestTemplate 参数解析

public RequestTemplate resolve(Map<String, Object> variables) {if (variables == null || variables.isEmpty()) {return this;}RequestTemplate resolved = new RequestTemplate(this);if (uriTemplate != null) {resolved.uriTemplate = uriTemplate.expand(variables);}// 解析查询参数for (Map.Entry<String, QueryTemplate> entry : queries.entrySet()) {resolved.queries.put(entry.getKey(), entry.getValue().expand(variables));}// 解析请求头for (Map.Entry<String, HeaderTemplate> entry : headers.entrySet()) {resolved.headers.put(entry.getKey(), entry.getValue().expand(variables));}return resolved;
}