c# - 1053 Windows 服务错误使用 .NET Core 3.1 Worker 服务

Question

我创建了一个 Worker Service，它在 Visual Studio 2019 中的调试和发布中都按预期工作。该服务监视要创建的 .csv，并使用适当的编码 (UTF-8) 将其重写到另一个目录。当我发布它并创建 Windows 服务时，在启动 Windows 服务时我收到了 错误 1053:服务没有及时响应启动或控制请求。据我了解，我的 OnStart 返回速度不够快。但我不确定如何调试。

程序类

using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Serilog;
using System;

namespace SupplyProUTF8service
{
    public class Program
    {
        public static void Main(string[] args)
        {

            Log.Logger = new LoggerConfiguration()
                .MinimumLevel.Debug()
                .MinimumLevel.Override("Microsoft", Serilog.Events.LogEventLevel.Warning)
                .Enrich.FromLogContext()
                .WriteTo.File(@"\\REP-APP\temp\workerservice\log.txt", rollingInterval: RollingInterval.Day)
                .CreateLogger();

            try
            {
                Log.Information("Application Started.");
                CreateHostBuilder(args).Build().Run();

            }
            catch (Exception e)
            {

                Log.Fatal(e, "Application terminated unexpectedly");
            }
            finally
            {
                Log.CloseAndFlush();
            }

            CreateHostBuilder(args).Build().Run();

        }


        public static IHostBuilder CreateHostBuilder(string[] args)
            => Host.CreateDefaultBuilder(args).UseWindowsService().ConfigureServices((hostContext, services)
                => { services.AddHostedService<Worker>(); }).UseSerilog();
    }
}

新 worker 类(Class) 仍然出现 1053 错误

using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;
using System;
using System.IO;
using System.Threading;
using System.Threading.Tasks;

namespace SupplyProUTF8service
{
    public class Worker : BackgroundService
    {

        private readonly string ordrstkPath;
        private readonly string conrstkPath;
        private readonly ILogger<Worker> _logger;

        public Worker(ILogger<Worker> logger)
        {
            ordrstkPath = @"\\Rep-app\sftp_root\supplypro\ordrstk";
            conrstkPath = @"\\Rep-app\sftp_root\supplypro\Conrstk";
            _logger = logger;
        }

        public override Task StartAsync(CancellationToken cancellationToken)
        {

            _logger.LogInformation("SupplyProRewrite Service started");
            return base.StartAsync(cancellationToken);
        }


        private FileSystemWatcher Watch(string path)
        {
            //initialize
            FileSystemWatcher watcher = new FileSystemWatcher
            {

                //assign paramater path
                Path = path,

                //don't watch subdirectories
                IncludeSubdirectories = false
            };

            //file created event
            watcher.Created += FileSystemWatcher_Created;

            //filters
            watcher.NotifyFilter = NotifyFilters.LastWrite | NotifyFilters.FileName | NotifyFilters.DirectoryName | NotifyFilters.Size | NotifyFilters.Attributes;

            //only look for csv
            watcher.Filter = "*.csv";

            // Begin watching.
            watcher.EnableRaisingEvents = true;

            return watcher;
        }
        private void FileSystemWatcher_Created(object sender, FileSystemEventArgs e)
        {
            _logger.LogInformation("{FullPath} has been created", e.FullPath);
            Thread.Sleep(10000);
            while (!IsFileLocked(e.FullPath))
            {
                ReadWriteStream(e.FullPath, e.Name);
                break;
            }
        }

        private static bool IsFileLocked(string filePath)
        {
            try
            {
                using FileStream originalFileStream = new FileStream(filePath, FileMode.Open, FileAccess.Read);
                originalFileStream.Close();
            }
            catch (Exception)
            {
                return true;
            }
            return false;
        }

        private void ReadWriteStream(string path, string fileName)
        {

            string originalPath = path;
            //destination path by replacing SFTP user directory
            string destinationPath = path.Replace(@"\supplypro\", @"\ftpuser\");

            string currentLine;

            using FileStream originalFileStream = new FileStream(path, FileMode.Open, FileAccess.Read);
            using FileStream destinationFileStream = new FileStream(destinationPath, FileMode.Create, FileAccess.Write);
            using StreamReader streamReader = new StreamReader(originalFileStream);
            using StreamWriter streamWriter = new StreamWriter(destinationFileStream);
            try
            {
                currentLine = streamReader.ReadLine();
                while (currentLine != null)
                {

                    streamWriter.WriteLine(currentLine);
                    currentLine = streamReader.ReadLine();

                }

                streamReader.Close();
                streamWriter.Close();

                //archive path
                string archivePath = path.Replace(fileName, @"archive\" + fileName);

                //move to archive path
                while (!IsFileLocked(originalPath))
                {
                    try
                    {
                        File.Move(originalPath, archivePath, true);
                        _logger.LogInformation("{FileName} moved to archive", fileName);
                        break;
                    }
                    catch (Exception e)
                    {
                        _logger.LogError("Unable to move {fileName} to archive", fileName, e);
                        break;
                    }
                }


            }
            catch (Exception e)
            {
                //error path
                string errorPath = path.Replace(fileName, @"error\" + fileName);

                //move to error path
                while (!IsFileLocked(originalPath))
                {
                    File.Move(path, errorPath);
                    _logger.LogError("{FullPath} file was moved to error", originalPath, e);
                    break;
                }

            }
            finally
            {
                destinationFileStream.Close();
                originalFileStream.Close();

            }
        }
        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
        {
            using (Watch(ordrstkPath))
            {
                _logger.LogInformation("ordrstk being watched");
                await Task.Delay(Timeout.Infinite, stoppingToken);
            }

            using(Watch(conrstkPath))
            {
                _logger.LogInformation("conrstk being watched");
                await Task.Delay(Timeout.Infinite, stoppingToken);
            }
        }
    }
}

Answer 1

我不确定我为什么不首先这样做。我向那些花时间看这个的人道歉。我最终使用 .\WorkerService.exe 在 Powershell 中运行应用程序。这引发了我缺少 ASP.net Core 运行时的错误。我之前安装了 .NET Core 的运行时，最近安装了 5.0。此辅助服务必须需要具有托管运行时的特定 ASP.Net Core:Download .服务现在可以正常启动。