From aa35e4b6a6bea4de9becb36bf8c9fd8b39d6c826 Mon Sep 17 00:00:00 2001 From: Xuanye Wong Date: Mon, 14 Jan 2019 22:36:32 +0800 Subject: [PATCH] =?UTF-8?q?=E2=9C=A8=20=E8=A7=84=E5=88=92=E9=A1=B9?= =?UTF-8?q?=E7=9B=AE=E7=BB=93=E6=9E=84=EF=BC=8C=E6=B7=BB=E5=8A=A0=E4=B8=80?= =?UTF-8?q?=E4=BA=9B=E5=BF=85=E8=A6=81=E7=9A=84=E5=9F=BA=E7=A1=80=E7=B1=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/DotXxlJob.Core/DotXxlJob.Core.csproj | 4 +++ src/DotXxlJob.Core/IJobHandlerFactory.cs | 8 +++++ src/DotXxlJob.Core/JobExecuteHostedService.cs | 30 +++++++++++++++++++ src/DotXxlJob.Core/Model/TriggerParam.cs | 7 +++++ src/DotXxlJob.Core/TaskExcutor.cs | 7 +++++ src/DotXxlJob.Core/TaskExecutorFactory.cs | 7 +++++ 6 files changed, 63 insertions(+) create mode 100644 src/DotXxlJob.Core/IJobHandlerFactory.cs create mode 100644 src/DotXxlJob.Core/JobExecuteHostedService.cs create mode 100644 src/DotXxlJob.Core/Model/TriggerParam.cs create mode 100644 src/DotXxlJob.Core/TaskExcutor.cs create mode 100644 src/DotXxlJob.Core/TaskExecutorFactory.cs diff --git a/src/DotXxlJob.Core/DotXxlJob.Core.csproj b/src/DotXxlJob.Core/DotXxlJob.Core.csproj index d2a210c..c5fbb8f 100644 --- a/src/DotXxlJob.Core/DotXxlJob.Core.csproj +++ b/src/DotXxlJob.Core/DotXxlJob.Core.csproj @@ -4,4 +4,8 @@ netstandard2.0 + + + + diff --git a/src/DotXxlJob.Core/IJobHandlerFactory.cs b/src/DotXxlJob.Core/IJobHandlerFactory.cs new file mode 100644 index 0000000..ba986ab --- /dev/null +++ b/src/DotXxlJob.Core/IJobHandlerFactory.cs @@ -0,0 +1,8 @@ +namespace DotXxlJob.Core +{ + public interface IJobHandlerFactory + { + //TODO: 获取实际执行的JobHandler + IJobHandler GetJobHandler(string handlerName); + } +} \ No newline at end of file diff --git a/src/DotXxlJob.Core/JobExecuteHostedService.cs b/src/DotXxlJob.Core/JobExecuteHostedService.cs new file mode 100644 index 0000000..b708f3d --- /dev/null +++ b/src/DotXxlJob.Core/JobExecuteHostedService.cs @@ -0,0 +1,30 @@ +using System.Threading; +using System.Threading.Tasks; +using Microsoft.Extensions.Hosting; + +namespace DotXxlJob.Core +{ + /// + /// NOTE: 负责启动Executor服务,和进行服务注册的宿主服务 + /// + public class JobsExecuteHostedService:IHostedService + { + public Task StartAsync(CancellationToken cancellationToken) + { + //1 初始化服务注册 + //2 初始化adminClient + + //3 初始化执行线程 + + //4 初始化XXL_RPC服务端口,HTTP服务 + + throw new System.NotImplementedException(); + } + + public Task StopAsync(CancellationToken cancellationToken) + { + //清理Start中启动的资源 + throw new System.NotImplementedException(); + } + } +} \ No newline at end of file diff --git a/src/DotXxlJob.Core/Model/TriggerParam.cs b/src/DotXxlJob.Core/Model/TriggerParam.cs new file mode 100644 index 0000000..f8efb50 --- /dev/null +++ b/src/DotXxlJob.Core/Model/TriggerParam.cs @@ -0,0 +1,7 @@ +namespace DotXxlJob.Core.Model +{ + public class TriggerParam + { + + } +} \ No newline at end of file diff --git a/src/DotXxlJob.Core/TaskExcutor.cs b/src/DotXxlJob.Core/TaskExcutor.cs new file mode 100644 index 0000000..67851a8 --- /dev/null +++ b/src/DotXxlJob.Core/TaskExcutor.cs @@ -0,0 +1,7 @@ +namespace DotXxlJob.Core +{ + public class TaskExcutor + { + + } +} \ No newline at end of file diff --git a/src/DotXxlJob.Core/TaskExecutorFactory.cs b/src/DotXxlJob.Core/TaskExecutorFactory.cs new file mode 100644 index 0000000..1e3cb13 --- /dev/null +++ b/src/DotXxlJob.Core/TaskExecutorFactory.cs @@ -0,0 +1,7 @@ +namespace DotXxlJob.Core +{ + public class TaskExecutorFactory + { + + } +} \ No newline at end of file