.NET Core新服务未实现接口时回退至旧.NET Framework服务方案咨询

完全可行，不需要依赖外部代理，通过.NET Core的中间件机制结合HttpClient就能实现需求，核心是在请求处理管道中判断当前请求是否有本地实现，无实现时转发到旧服务。下面提供两种实用方案：

方案一：捕获404响应后转发（自动检测未实现接口） #

这种方式无需手动维护接口列表，利用ASP.NET Core的路由匹配机制，当请求匹配不到任何本地端点时会返回404，我们在中间件中捕获这个状态，将请求转发到旧服务。

步骤1：配置HttpClient #

在Program.cs中注册用于转发请求的HttpClient实例：

builder.Services.AddHttpClient("OldServiceClient", client =>
{
    client.BaseAddress = new Uri("http://旧服务的基础地址/");
    client.Timeout = TimeSpan.FromSeconds(30); // 根据业务需求配置超时
});

步骤2：编写转发中间件 #

创建中间件类处理转发逻辑：

public class OldServiceForwardMiddleware
{
    private readonly RequestDelegate _next;
    private readonly IHttpClientFactory _httpClientFactory;
    private readonly ILogger<OldServiceForwardMiddleware> _logger;

    public OldServiceForwardMiddleware(RequestDelegate next, IHttpClientFactory httpClientFactory, ILogger<OldServiceForwardMiddleware> logger)
    {
        _next = next;
        _httpClientFactory = httpClientFactory;
        _logger = logger;
    }

    public async Task InvokeAsync(HttpContext context)
    {
        // 先让管道处理请求，判断是否有本地实现
        await _next(context);

        // 若返回404，说明本地无对应接口，执行转发
        if (context.Response.StatusCode == StatusCodes.Status404NotFound)
        {
            _logger.LogInformation("转发请求至旧服务：{Path}", context.Request.Path);
            
            // 重置已开始写入的响应
            context.Response.Clear();

            var client = _httpClientFactory.CreateClient("OldServiceClient");
            var forwardRequest = new HttpRequestMessage(new HttpMethod(context.Request.Method), context.Request.Path);

            // 复制原请求的Header
            foreach (var header in context.Request.Headers)
            {
                if (!forwardRequest.Headers.TryAddWithoutValidation(header.Key, header.Value.ToArray()) && forwardRequest.Content != null)
                {
                    forwardRequest.Content.Headers.TryAddWithoutValidation(header.Key, header.Value.ToArray());
                }
            }

            // 处理请求体（请求体仅能读取一次，需先缓存到内存流）
            if (context.Request.ContentLength > 0 || !string.IsNullOrEmpty(context.Request.ContentType))
            {
                using var stream = new MemoryStream();
                await context.Request.Body.CopyToAsync(stream);
                stream.Position = 0;
                forwardRequest.Content = new StreamContent(stream);
                forwardRequest.Content.Headers.ContentType = new System.Net.Http.Headers.MediaTypeHeaderValue(context.Request.ContentType);
            }

            // 发送请求到旧服务并获取响应
            var oldServiceResponse = await client.SendAsync(forwardRequest, HttpCompletionOption.ResponseHeadersRead, context.RequestAborted);

            // 将旧服务的响应返回给客户端
            context.Response.StatusCode = (int)oldServiceResponse.StatusCode;
            foreach (var header in oldServiceResponse.Headers)
            {
                context.Response.Headers.TryAdd(header.Key, header.Value.ToArray());
            }
            foreach (var header in oldServiceResponse.Content.Headers)
            {
                context.Response.Headers.TryAdd(header.Key, header.Value.ToArray());
            }

            await oldServiceResponse.Content.CopyToAsync(context.Response.Body);
        }
    }
}

步骤3：注册中间件 #

在Program.cs的管道中注册该中间件，注意要放在路由中间件之前：

app.UseMiddleware<OldServiceForwardMiddleware>();

app.UseRouting();
app.UseAuthorization();

app.MapControllers();

方案二：手动维护已实现接口列表，提前转发 #

如果需要更精准的控制（比如避免非接口类的404被误转发），可以手动维护已实现的接口集合，在请求到达时直接判断是否需要转发。

步骤1：定义已实现接口集合 #

可以在静态类或配置文件中维护：

public static class ImplementedEndpoints
{
    public static readonly HashSet<string> Endpoints = new HashSet<string>(StringComparer.OrdinalIgnoreCase)
    {
        "GET /user/GetUser" // 格式："请求方法 接口路径"
    };
}

步骤2：修改中间件逻辑 #

调整中间件的InvokeAsync方法，提前判断请求是否需要转发：

public async Task InvokeAsync(HttpContext context)
{
    var requestKey = $"{context.Request.Method} {context.Request.Path}";
    // 若请求不在已实现列表中，直接转发到旧服务
    if (!ImplementedEndpoints.Endpoints.Contains(requestKey))
    {
        _logger.LogInformation("请求不在已实现列表，转发至旧服务：{RequestKey}", requestKey);
        // 此处复用方案一中的转发逻辑（复制请求、发送到旧服务、返回响应）
        return;
    }

    // 若请求在已实现列表中，继续让管道处理
    await _next(context);
}

关键注意事项 #

• 请求体处理：ASP.NET Core中请求体默认仅能读取一次，转发时需先复制到内存流，避免后续读取失败。
• Header完整性：确保原请求的关键Header（如Authorization、Content-Type）被正确复制，同时旧服务的响应Header也要完整返回给客户端。
• 异常处理：需添加捕获逻辑，处理旧服务不可用、超时等异常场景，返回符合业务要求的错误响应。
• 路由顺序：中间件的注册顺序必须正确，比如方案一的中间件要放在路由中间件之前，才能捕获到404响应。

内容的提问来源于stack exchange，提问作者Vladimir Lenin