溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要為大家展示了“Net5 WorkService繼承Quarzt及Net5如何處理文件上傳功能”，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領大家一起研究并學習一下“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
//自定義調(diào)度
//services.AddHostedService<Worker>();
#endregion
#region quartz 原始版本
//這個版本 trigger job Schedule 是唯一關聯(lián)，不能一個組下多個任務
//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);
#region quarzt 優(yōu)化版本
// // Register the job, loading the schedule from configuration
// q.AddJobAndTrigger<HelloTestJob>(hostContext.Configuration, "0/1 * * * * ?");//每秒運行一次
// q.AddJobAndTrigger<HelloTestJob2>(hostContext.Configuration, "0/1 * * * * ?");
#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);
});
}
}原始的Host.CreateDefaultBuilder(args) 需要增加 .UseWindowsService() 支持 對windowservice
quarzt 在 NET5的nuget 中叫Quartz.Extensions.Hosting
services.AddHostedService<Worker>(); 是原始的windows定時任務版本
代碼如下， 在await Task.Delay(1000, stoppingToken); 設定定時啟動的毫秒數(shù)就可以了
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();//釋放內(nèi)存
stream.Close();//釋放內(nèi)存
await Task.Delay(1000, stoppingToken);
}
}
}
}quartz 原始版本（program.cs代碼截圖）
在目前這個quartz 3.3.3 版本中好像不能一個Key 下多個Job集成作業(yè)。所以每個job需要一個一個注冊。推薦使用優(yōu)化版本
quarzt 優(yōu)化版本（program.cs代碼截圖）
對原始版本進行了封裝。在每一次調(diào)用的時候會注冊新的唯一實例。
以下是幫助類
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();//釋放內(nèi)存
stream.Close();//釋放內(nèi)存
return Task.CompletedTask;
}
}
}程序會根據(jù)Corn 設定的運行時間定期在Task Execute(IJobExecutionContext context)方法內(nèi)運行
然后就是蠻搞笑的，大伙都不用Net5 嗎。寫服務上傳文件。遇到問題搜索NET5處理文件上傳問題，居然都是空白的。 那我就只好自己寫解決方案了。
客戶端圖片上傳的HTTPHelper.cs部分代碼如下
/// <summary>
/// 上傳文件
/// </summary>
/// <param name="url">請求地址</param>
/// <param name="path">文件路徑（帶文件名）</param>
/// <returns></returns>
public static string HttpPostFile(string url, string path)
{
// 設置參數(shù)
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();
//發(fā)送請求并獲取相應回應數(shù)據(jù)
HttpWebResponse response = request.GetResponse() as HttpWebResponse;
//直到request.GetResponse()程序才開始向目標網(wǎng)頁發(fā)送Post請求
Stream instream = response.GetResponseStream();
StreamReader sr = new StreamReader(instream, Encoding.UTF8);
//返回結果網(wǎng)頁（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\\")) //判斷上傳文件夾是否存在，若不存在，則創(chuàng)建
{
Directory.CreateDirectory(System.AppDomain.CurrentDomain.SetupInformation.ApplicationBase + $"Image\\"); //創(chuàng)建文件夾
}
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 里?。。。?/p>
但你也可以通過Request.body 讀到流
//using (var reader = new StreamReader(Request.Body))//從身體里讀取
//{
// var body = await reader.ReadToEndAsync();
//}以上是“Net5 WorkService繼承Quarzt及Net5如何處理文件上傳功能”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業(yè)資訊頻道！
免責聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉載和分享為主，文章觀點不代表本網(wǎng)站立場，如果涉及侵權請聯(lián)系站長郵箱：is@yisu.com進行舉報，并提供相關證據(jù)，一經(jīng)查實，將立刻刪除涉嫌侵權內(nèi)容。
