如何基于.NET构建持续运行的SOAP请求转发控制台应用？

核心架构思路 #

• 用Hosted Service实现7×24小时不间断运行：.NET Core的IHostedService/BackgroundService是控制台程序长期运行的标准方案，自带启动、停止的生命周期管理，配合Microsoft.Extensions.Hosting包就能快速搭好基础框架。
• 内嵌SOAP服务端：借助SoapCore包在控制台中托管SOAP端点，替代传统ASMX服务，无需额外依赖IIS等Web服务器。
• 请求转发逻辑：编写转发处理器，根据请求路由或内容匹配目标服务（本地/线上均可），用HttpClient池化管理连接，避免频繁创建销毁连接带来的性能损耗。

关键实现步骤 #

1. 项目初始化与依赖安装 #

• 创建.NET Core控制台项目，安装必要NuGet包：

  Install-Package Microsoft.Extensions.Hosting
  Install-Package SoapCore
  Install-Package System.ServiceModel.Primitives
  

2. 配置SOAP端点 #

• 先定义SOAP服务的契约接口，示例如下：

  [ServiceContract]
  public interface IForwardService
  {
      [OperationContract]
      Task<string> ProcessRequestAsync(string requestData);
  }
  

• 在Host配置中注册SoapCore中间件并绑定端点：

  var host = Host.CreateDefaultBuilder(args)
      .ConfigureWebHostDefaults(webBuilder =>
      {
          webBuilder.UseUrls("http://localhost:5000"); // 设置服务监听地址
          webBuilder.ConfigureServices(services =>
          {
              services.AddSoapCore();
              services.AddSingleton<IForwardService, ForwardServiceImpl>();
          });
          webBuilder.Configure(app =>
          {
              app.UseRouting();
              app.UseEndpoints(endpoints =>
              {
                  // 绑定SOAP请求的访问路径
                  endpoints.UseSoapEndpoint<IForwardService>("/soap", new SoapEncoderOptions());
              });
          });
      })
      .Build();
  

3. 实现请求转发逻辑 #

• 在ForwardServiceImpl中注入IHttpClientFactory，用于创建目标服务的SOAP客户端：

  public class ForwardServiceImpl : IForwardService
  {
      private readonly IHttpClientFactory _httpClientFactory;
  
      public ForwardServiceImpl(IHttpClientFactory httpClientFactory)
      {
          _httpClientFactory = httpClientFactory;
      }
  
      public async Task<string> ProcessRequestAsync(string requestData)
      {
          // 可根据业务规则从配置文件或数据库读取目标服务地址
          var targetUrl = "http://target-service/soap-endpoint";
          var client = _httpClientFactory.CreateClient();
          
          // 构造符合目标服务要求的SOAP请求内容，实际项目可使用序列化工具生成
          var soapRequest = $@"<soapenv:Envelope xmlns:soapenv=""http://schemas.xmlsoap.org/soap/envelope/"" xmlns:ser=""http://your-target-namespace"">
  <soapenv:Header/>
  <soapenv:Body>
     <ser:YourOperation>
        <ser:RequestData>{requestData}</ser:RequestData>
     </ser:YourOperation>
  </soapenv:Body>
  

</soapenv:Envelope>";
var content = new StringContent(soapRequest, Encoding.UTF8, "text/xml");

var response = await client.PostAsync(targetUrl, content);
      return await response.Content.ReadAsStringAsync();
  }

}

### 4. 保障服务稳定运行
- 添加全局异常捕获，配合操作系统服务托管（Windows服务或Linux systemd）实现崩溃自动重启：
```csharp
try
{
    await host.RunAsync();
}
catch (Exception ex)
{
    // 替换为实际日志组件（如Serilog、NLog）记录异常
    Console.WriteLine($"服务异常：{ex.Message}\n{ex.StackTrace}");
}

• 集成日志：使用Microsoft.Extensions.Logging添加控制台或文件日志，便于问题排查。

优化技巧 #

• 连接池优化：通过IHttpClientFactory配置HttpClient的超时时间、最大连接数，避免对目标服务造成过大压力。
• 动态路由：将目标服务地址配置在appsettings.json中，无需修改代码即可切换转发目标。
• 健康检查：集成Microsoft.Extensions.Diagnostics.HealthChecks，监控SOAP端点和目标服务的状态，及时发现故障。
• 容错处理：使用Polly库实现重试、熔断、降级策略，当目标服务不可用时，返回友好提示或触发备用逻辑。

参考实现思路 #

• 可参考.NET官方的BackgroundService示例，结合SoapCore的使用案例，将SOAP服务托管与后台服务结合。
• 若需复杂的请求转换、过滤逻辑，可借鉴API网关的设计思路，适配不同目标服务的SOAP契约差异。

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