Net5 WorkService 繼承 Quarzt 以及 Net5處理檔案上傳-有解無憂

Net5 版本以Core為底層非framework框架的windowservice 服務，

在VS里叫WorkService 可以以CMD方式運行也可以以Windowservice方式運行，部署簡單，

Program.cs如下，是關鍵配置和啟動項

using Microsoft.Extensions.Hosting;
using Quartz;
using WorkerService.Common;
using WorkerService.Job;

namespace WorkerService
{
    public class Program
    {
        public static void Main(string[] args)
        {
            
            CreateHostBuilder(args).Build().Run();
        }

    

        public static IHostBuilder CreateHostBuilder(string[] args) =>
            Host.CreateDefaultBuilder(args).UseWindowsService()
                .ConfigureServices((hostContext, services) =>
                {

                    #region  原生work Service

                    //自定義調度

                    //services.AddHostedService<Worker>();

                    #endregion



                    #region quartz 原始版本

                    //這個版本    trigger  job Schedule 是唯一關聯，不能一個組下多個任務


                    //services.AddQuartz(q =>
                    //{
                    //    q.UseMicrosoftDependencyInjectionScopedJobFactory();

                    //    // Create a "key" for the job
                    //    var jobKey = new JobKey("HelloTestJob");

                    //    // Register the job with the DI container
                    //    q.AddJob<HelloTestJob>(opts => opts.WithIdentity(jobKey));

                    //    // Create a trigger for the job
                    //    q.AddTrigger(opts => opts
                    //        .ForJob(jobKey) // link to the HelloWorldJob
                    //        .WithIdentity("HelloTestJob-trigger") // give the trigger a unique name
                    //        .WithCronSchedule("0/1 * * * * ?")); // run every 1 seconds

                    //});

                    //services.AddQuartzHostedService(q => q.WaitForJobsToComplete = true);


                    #endregion



                    #region quarzt 優化版本


                    //services.AddQuartz(q =>
                    //{
                    //    q.UseMicrosoftDependencyInjectionScopedJobFactory();

                    //    // Register the job, loading the schedule from configuration
                    //    q.AddJobAndTrigger<HelloTestJob>(hostContext.Configuration, "0/1 * * * * ?");//每秒運行一次

                    //    q.AddJobAndTrigger<HelloTestJob2>(hostContext.Configuration, "0/1 * * * * ?");
                    //});

                    //services.AddQuartzHostedService(q => q.WaitForJobsToComplete = true);


                    #endregion



                    #region  溫濕度 SF6 紅外圖片上傳
             


                    services.AddQuartz(q =>
                    {
                        q.UseMicrosoftDependencyInjectionScopedJobFactory();

                        //每秒 0/1 * * * * ?   每小時  0 0 * * * ?
                        // Register the job, loading the schedule from configuration
                        q.AddJobAndTrigger<TemperatureJob>(hostContext.Configuration, "0 0 * * * ?");

                        q.AddJobAndTrigger<SF6Job>(hostContext.Configuration, "0 0 * * * ?");

                        q.AddJobAndTrigger<InfraredJob>(hostContext.Configuration, "0 0 * * * ?");
                    });

                    services.AddQuartzHostedService(q => q.WaitForJobsToComplete = true);



                    #endregion



                });
    }





    



   

}

原始的 Host.CreateDefaultBuilder(args) 需要增加 .UseWindowsService() 支持對windowservice

quarzt 在 NET5的nuget 中叫 Quartz.Extensions.Hosting

services.AddHostedService<Worker>(); 是原始的windows定時任務版本

代碼如下，在 await Task.Delay(1000, stoppingToken); 設定定時啟動的毫秒數就可以了

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

namespace WorkerService.Job.Test
{
    public class Worker : BackgroundService
    {
        private readonly ILogger<Worker> _logger;

        public Worker(ILogger<Worker> logger)
        {
            _logger = logger;
        }

        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
        {
            while (!stoppingToken.IsCancellationRequested)
            {
                _logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);


                FileStream stream = new FileStream(@"d:\aa.txt", FileMode.Create);//fileMode指定是讀取還是寫入
                StreamWriter writer = new StreamWriter(stream);
                writer.WriteLine("123456"+ DateTimeOffset.Now);//寫入一行，寫完后會自動換行
                writer.Write("abc");//寫完后不會換行
                writer.WriteLine("ABC");
                writer.Close();//釋放記憶體
                stream.Close();//釋放記憶體


                await Task.Delay(1000, stoppingToken);
            }
        }
    }
}

quartz 原始版本（program.cs代碼截圖）

在目前這個quartz 3.3.3 版本中好像不能一個Key 下多個Job集成作業，所以每個job需要一個一個注冊，推薦使用優化版本

quarzt 優化版本（program.cs代碼截圖）

對原始版本進行了封裝，在每一次呼叫的時候會注冊新的唯一實體，

以下是幫助類

using Microsoft.Extensions.Configuration;
using Quartz;
using System;

namespace WorkerService.Common
{
    public static class ServiceCollectionQuartzConfiguratorExtensions
    {
        public static void AddJobAndTrigger<T>(
            this IServiceCollectionQuartzConfigurator quartz,
            IConfiguration config, string cronSchedule)
            where T : IJob
        {
            // Use the name of the IJob as the appsettings.json key
            string jobName = typeof(T).Name;

            // Try and load the schedule from configuration
            var configKey = $"Quartz:{jobName}";
            //var cronSchedule = config[configKey];

            // Some minor validation
            if (string.IsNullOrEmpty(cronSchedule))
            {
                throw new Exception($"No Quartz.NET Cron schedule found for job in configuration at {configKey}");
            }

            // register the job as before
            var jobKey = new JobKey(jobName);
            quartz.AddJob<T>(opts => opts.WithIdentity(jobKey));

            quartz.AddTrigger(opts => opts
                .ForJob(jobKey)
                .WithIdentity(jobName + "-trigger")
                .WithCronSchedule(cronSchedule)); // use the schedule from configuration
        }
    }
}

以下是Job

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

namespace WorkerService.Job.Test
{

    [DisallowConcurrentExecution]
    public class HelloTestJob2 : IJob
    {
        private readonly ILogger<HelloTestJob2> _logger;


        public HelloTestJob2(ILogger<HelloTestJob2> logger)
        {
            _logger = logger;

        }

        public Task Execute(IJobExecutionContext context)
        {
            FileStream stream = new FileStream(@"d:\aa1.txt", FileMode.Create);//fileMode指定是讀取還是寫入
            StreamWriter writer = new StreamWriter(stream);
            writer.WriteLine("123456aaa" + DateTimeOffset.Now);//寫入一行，寫完后會自動換行
            writer.Write("abc");//寫完后不會換行
            writer.WriteLine("ABC");
            writer.Close();//釋放記憶體
            stream.Close();//釋放記憶體

            return Task.CompletedTask;
        }
    }



}

程式會根據Corn 設定的運行時間定期在 Task Execute(IJobExecutionContext context)方法內運行

然后就是蠻搞笑的，大伙都不用Net5 嗎，寫服務上傳檔案，遇到問題搜索NET5處理檔案上傳問題，居然都是空白的，那我就只好自己寫解決方案了，

客戶端圖片上傳的HTTPHelper.cs部分代碼如下

       /// <summary>
        /// 上傳檔案
        /// </summary>
        /// <param name="url">請求地址</param>
        /// <param name="path">檔案路徑（帶檔案名）</param>
        /// <returns></returns>
        public static string HttpPostFile(string url, string path)
        {
            // 設定引數
            HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
            CookieContainer cookieContainer = new CookieContainer();
            request.CookieContainer = cookieContainer;
            request.AllowAutoRedirect = true;
            request.Method = "POST";string boundary = DateTime.Now.Ticks.ToString("X"); // 隨機分隔線
            request.ContentType = "multipart/form-data;charset=utf-8;boundary=" + boundary;
            byte[] itemBoundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "\r\n");
            byte[] endBoundaryBytes = Encoding.UTF8.GetBytes("\r\n--" + boundary + "--\r\n");

            int pos = path.LastIndexOf("\\");
            string fileName = path.Substring(pos + 1);

            //請求頭部資訊
            StringBuilder sbHeader = new StringBuilder(string.Format("Content-Disposition:form-data;name=\"file\";filename=\"{0}\"\r\nContent-Type:application/octet-stream\r\n\r\n", fileName));
            byte[] postHeaderBytes = Encoding.UTF8.GetBytes(sbHeader.ToString());

            StringBuilder builder = new StringBuilder($"Content-Disposition:form-data;name=\"subPath\"\r\n\r\ntmswechat");
            byte[] postHeaderBytestwo = Encoding.UTF8.GetBytes(builder.ToString());

            FileStream fs = new FileStream(path, FileMode.Open, FileAccess.Read);
            byte[] bArr = new byte[fs.Length];
            fs.Read(bArr, 0, bArr.Length);
            fs.Close();

            Stream postStream = request.GetRequestStream();
            postStream.Write(itemBoundaryBytes, 0, itemBoundaryBytes.Length);
            postStream.Write(postHeaderBytes, 0, postHeaderBytes.Length);
            postStream.Write(bArr, 0, bArr.Length);
            postStream.Write(itemBoundaryBytes, 0, itemBoundaryBytes.Length);
            postStream.Write(postHeaderBytestwo, 0, postHeaderBytestwo.Length);
            postStream.Write(endBoundaryBytes, 0, endBoundaryBytes.Length);
            postStream.Close();

            //發送請求并獲取相應回應資料
            HttpWebResponse response = request.GetResponse() as HttpWebResponse;
            //直到request.GetResponse()程式才開始向目標網頁發送Post請求
            Stream instream = response.GetResponseStream();
            StreamReader sr = new StreamReader(instream, Encoding.UTF8);
            //回傳結果網頁（html）代碼
            string content = sr.ReadToEnd();
            return content;
        }

重點是服務端的接收，部分代碼如下

try
                    {
                    var files = Request.Form.Files;
                    if (files != null)
                    {
                        var file = files[0];
                
                        var location = System.AppDomain.CurrentDomain.SetupInformation.ApplicationBase + $"Image\\" + file.FileName;

                        if (!Directory.Exists(System.AppDomain.CurrentDomain.SetupInformation.ApplicationBase + $"Image\\")) //判斷上傳檔案夾是否存在，若不存在，則創建
                        {
                            Directory.CreateDirectory(System.AppDomain.CurrentDomain.SetupInformation.ApplicationBase + $"Image\\"); //創建檔案夾
                        }

                        using (var stream = new FileStream(location, FileMode.Create))
                        {
                            await file.CopyToAsync(stream);
                            result = 1;
                        }
                    }

                    //using (var reader = new StreamReader(Request.Body))//從身體里讀取
                    //{

                    //    var body = await reader.ReadToEndAsync(); 
                      
                    //}
                    }
                    catch (Exception e )
                    {

                        throw;
                    }

哪怕你用的是檔案流上傳，不是表單提交，但是你的檔案依舊在Request.Form.Files 里！！！！

但你也可以通過Request.body 讀到流

//using (var reader = new StreamReader(Request.Body))//從身體里讀取
//{

// var body = await reader.ReadToEndAsync();

//}

轉載請註明出處，本文鏈接：https://www.uj5u.com/net/427384.html

標籤：.NET技术

上一篇：.NetCore程式寄托于IIS部署時提示：行程無法訪問該檔案，因為它正在被其他行程使用。

下一篇：【學習筆記】運算式主體定義的成員（常規語法：member => expression;）