如何实现无需人工干预的FTP自动持续轮询？Angular方案问题咨询

这是个很典型的前端逻辑依赖页面上下文的问题——你的Angular代码只能在浏览器加载页面时运行，一旦页面关闭或者没人访问，任务就停了。要实现持续自动的FTP监控，核心是把逻辑从前端移到后端，让ASP.NET MVC服务器自己来运行这个持续任务。下面是具体的解决方案：

核心思路 #

前端代码（包括Angular）是运行在用户浏览器中的，只有当页面被打开时才会执行逻辑。而后台任务是运行在服务器端的，不受用户访问情况的影响，能持续执行监控和处理操作。所以我们需要：

• 将FTP监控、文件处理的逻辑从Angular迁移到ASP.NET后端
• 在服务器端创建一个持续运行的后台服务来执行这些逻辑

具体实现步骤 #

1. 创建后台监控服务 #

在ASP.NET中，推荐使用Hosted Service（适用于.NET Core及以上版本）来实现持续运行的后台任务。如果是传统的.NET Framework，可以用Windows服务或者任务调度库（比如Hangfire）。

下面是一个基于.NET Core Hosted Service的示例：

using FluentFTP;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Configuration;
using System;
using System.Threading;
using System.Threading.Tasks;

public class FTPMonitorService : BackgroundService
{
    private readonly ILogger<FTPMonitorService> _logger;
    private readonly IConfiguration _config;

    // 通过依赖注入获取日志和配置
    public FTPMonitorService(ILogger<FTPMonitorService> logger, IConfiguration config)
    {
        _logger = logger;
        _config = config;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _logger.LogInformation("FTP自动监控服务已启动");

        // 循环执行监控，直到服务停止
        while (!stoppingToken.IsCancellationRequested)
        {
            try
            {
                // 检查FTP服务器并处理新文件
                await CheckAndProcessFTPFiles();
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "FTP监控过程中发生错误");
            }

            // 设置检查间隔，比如每隔60秒检查一次（可根据需求调整）
            await Task.Delay(TimeSpan.FromSeconds(60), stoppingToken);
        }

        _logger.LogInformation("FTP自动监控服务已停止");
    }

    private async Task CheckAndProcessFTPFiles()
    {
        // 从配置文件读取FTP参数（建议存在appsettings.json中）
        string ftpServer = _config["FTP:ServerAddress"];
        string monitorPath = _config["FTP:MonitorDirectory"];
        string username = _config["FTP:Username"];
        string password = _config["FTP:Password"];
        string localProcessPath = _config["Local:ProcessDirectory"];
        string localArchivePath = _config["Local:ArchiveDirectory"];

        // 使用FluentFTP库简化FTP操作（需要先安装NuGet包：Install-Package FluentFTP）
        using (var ftpClient = new FtpClient(ftpServer, username, password))
        {
            await ftpClient.ConnectAsync();

            // 获取监控目录下的所有文件
            var fileList = await ftpClient.GetListingAsync(monitorPath);
            foreach (var ftpFile in fileList.Where(f => f.Type == FtpObjectType.File))
            {
                // 判断是否为未处理的新文件（这里可以通过记录已处理文件名到数据库/本地文件来实现）
                if (!IsFileProcessed(ftpFile.Name))
                {
                    // 下载文件到本地处理目录
                    await ftpClient.DownloadFileAsync(
                        $"{localProcessPath}/{ftpFile.Name}", 
                        ftpFile.FullName
                    );

                    // 执行你的文件处理逻辑（比如解析内容、存入数据库等）
                    ProcessFile($"{localProcessPath}/{ftpFile.Name}");

                    // 标记文件为已处理：可以移动到FTP的归档目录，或者记录到本地存储
                    await ftpClient.MoveFileAsync(
                        ftpFile.FullName, 
                        $"{monitorPath}/archive/{ftpFile.Name}"
                    );

                    _logger.LogInformation($"已处理FTP文件：{ftpFile.Name}");
                }
            }

            await ftpClient.DisconnectAsync();
        }
    }

    // 自定义方法：判断文件是否已处理（示例逻辑，需根据实际需求实现）
    private bool IsFileProcessed(string fileName)
    {
        // 示例：检查本地归档目录是否存在该文件
        return System.IO.File.Exists($"{_config["Local:ArchiveDirectory"]}/{fileName}");
    }

    // 自定义方法：处理下载后的文件
    private void ProcessFile(string localFilePath)
    {
        // 这里替换成你的实际文件处理逻辑，比如读取内容、解析数据、写入数据库等
        _logger.LogInformation($"开始处理本地文件：{localFilePath}");
        // 示例逻辑：读取文件内容
        string content = System.IO.File.ReadAllText(localFilePath);
        // ...后续处理
    }
}

2. 注册后台服务 #

在Startup.cs中注册这个Hosted Service，让ASP.NET启动时自动运行它：

public void ConfigureServices(IServiceCollection services)
{
    // 其他服务注册（比如MVC、数据库等）
    services.AddControllersWithViews();

    // 注册FTP监控后台服务
    services.AddHostedService<FTPMonitorService>();
}

3. 移除前端依赖逻辑 #

原来的Angular代码（<div ng-app="myApp1" ng-controller="FTPCtrl"></div>）可以保留，但不再负责触发FTP监控——你可以改成用来展示FTP处理的日志或者结果，让用户查看状态，而监控逻辑完全由后端服务自动执行。

关键注意事项 #

• 权限配置：确保后台服务有访问FTP服务器、本地处理目录的权限（比如服务器的应用池账号权限）
• 错误处理：完善的异常捕获和日志记录很重要，避免一次小错误导致整个监控任务停止
• 重复处理避免：一定要实现可靠的"已处理文件"判断逻辑（比如用数据库记录、FTP归档目录、本地文件记录），防止重复处理同一文件
• 性能优化：根据FTP服务器的负载情况调整检查间隔，不要过于频繁地发起FTP请求
• 传统.NET Framework兼容：如果是旧版的ASP.NET（非Core），可以考虑将监控逻辑封装成Windows服务，或者使用Hangfire这样的任务调度库来实现定时任务

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