在ASP.NET Core 9 Web API中集成TCP服务器对接遗留系统的通用软件模式咨询

阿华AIGC实验室

2026-4-7

嘿，针对你在ASP.NET Core 9 Web API里集成TCP服务器对接遗留系统的需求，确实有几个经过验证的通用软件模式可以参考，刚好能帮你把现有的思路做更规范的落地：

1. 后台服务模式（IHostedService + 单例依赖注入）

这是ASP.NET Core官方推荐的后台任务实现方式，完美匹配你提到的「IHostedService持有TCP Server对象并通过DI注入单例」的思路。

你可以把TCP服务器的逻辑封装在一个继承自BackgroundService（IHostedService的抽象实现类）的类中，它会和Web API的生命周期完全绑定：API启动时自动初始化TCP监听，API停止时优雅关闭连接、释放资源。同时把这个类注册为单例，让API控制器或其他服务能通过DI直接注入，获取遗留系统传来的数据。

举个简单的代码示例：

public class LegacyTcpServer : BackgroundService
{
    private readonly ITcpDataStore _dataStore;
    private TcpListener _tcpListener;

    // 通过DI注入数据存储组件
    public LegacyTcpServer(ITcpDataStore dataStore)
    {
        _dataStore = dataStore;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        // 初始化TCP监听
        _tcpListener = new TcpListener(IPAddress.Any, 9999);
        _tcpListener.Start();
        Console.WriteLine("TCP服务器已启动，等待遗留系统连接...");

        while (!stoppingToken.IsCancellationRequested)
        {
            // 异步等待客户端连接
            using var tcpClient = await _tcpListener.AcceptTcpClientAsync(stoppingToken);
            // 异步处理客户端数据，避免阻塞监听线程
            _ = ProcessClientDataAsync(tcpClient, stoppingToken);
        }
    }

    public override async Task StopAsync(CancellationToken stoppingToken)
    {
        // 优雅停止TCP服务
        _tcpListener?.Stop();
        await base.StopAsync(stoppingToken);
        Console.WriteLine("TCP服务器已停止");
    }

    private async Task ProcessClientDataAsync(TcpClient client, CancellationToken stoppingToken)
    {
        try
        {
            using var stream = client.GetStream();
            using var reader = new StreamReader(stream);
            // 读取遗留系统发送的数据
            var data = await reader.ReadLineAsync(stoppingToken);
            if (!string.IsNullOrEmpty(data))
            {
                // 把数据存入线程安全的存储组件
                _dataStore.StoreReceivedData(data);
            }
        }
        catch (OperationCanceledException)
        {
            // 服务停止时的正常取消，无需处理
        }
        catch (Exception ex)
        {
            Console.WriteLine($"处理客户端数据出错：{ex.Message}");
        }
    }
}

在Program.cs中注册服务：

// 注册线程安全的数据存储组件（单例）
builder.Services.AddSingleton<ITcpDataStore, InMemoryTcpDataStore>();
// 注册TCP服务器后台服务
builder.Services.AddHostedService<LegacyTcpServer>();

2. 仓储模式（Repository Pattern）

这个模式可以和后台服务模式配合使用，用来隔离TCP服务器的数据处理逻辑和API的数据查询逻辑。

你可以定义一个线程安全的仓储接口（比如ITcpDataStore），TCP服务器收到数据后只负责把数据存入仓储，而API控制器直接依赖这个仓储来查询数据。这样做的好处是：

解耦TCP服务器和API的逻辑，TCP服务器不用关心数据怎么被查询
后续如果需要把数据从内存换成数据库、Redis等持久化存储，只需要修改仓储的实现类，不用动TCP服务器的代码

如果你的场景需要多个组件响应遗留系统的数据（比如API需要实时更新缓存、或者其他后台服务需要处理数据），可以用发布-订阅模式。

TCP服务器收到数据后，发布一个「数据接收事件」，API层或其他服务订阅这个事件，各自处理数据。你可以自己实现简单的事件总线，或者用ASP.NET Core生态中的轻量事件组件，这样TCP服务器只负责发布事件，完全不依赖下游的处理逻辑，解耦程度更高。

对你提到的几种实现方式的补充说明

静态变量：虽然实现简单，但它的生命周期不受ASP.NET Core的DI容器管理，很难进行单元测试，也无法优雅处理服务停止时的资源释放，生产环境不推荐使用。
自定义单例类：如果自己手动管理单例的生命周期，容易出现资源泄漏、线程安全问题，不如交给DI容器托管的单例+IHostedService组合，更可靠。

关键注意事项

线程安全：TCP服务器的连接处理是多线程/异步的，所以存储数据的容器必须用线程安全的实现，比如ConcurrentDictionary、ConcurrentQueue，避免数据竞争问题。
优雅关闭：一定要在StopAsync方法中处理TCP服务器的停止逻辑，关闭监听器、断开所有活跃连接，避免进程退出时出现资源泄漏。

内容来源于stack exchange