惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

WordPress大学
WordPress大学
T
The Blog of Author Tim Ferriss
F
Fortinet All Blogs
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
阮一峰的网络日志
阮一峰的网络日志
The GitHub Blog
The GitHub Blog
Y
Y Combinator Blog
MyScale Blog
MyScale Blog
雷峰网
雷峰网
博客园 - 叶小钗
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻
GbyAI
GbyAI
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
博客园 - 三生石上(FineUI控件)
云风的 BLOG
云风的 BLOG
V
V2EX
宝玉的分享
宝玉的分享
酷 壳 – CoolShell
酷 壳 – CoolShell
N
Netflix TechBlog - Medium
Vercel News
Vercel News
美团技术团队
人人都是产品经理
人人都是产品经理
The Cloudflare Blog

博客园 - 落叶子

FreeRedis 实现消费确认队列和消费延时确认队列 快速部署单机k3s+Kuboard控制面板 解决微软鼠标设置宏后桌面有效果 进游戏就没有效果了 .net core 使用QRCoder在linux 下生成带logo的二维码 GC 性能调优相关 .net 中使用OpenCvSharp 判断一张图片中是否包含指定图标 maui BlazorWebView+本地html (vue、uniapp等都可以) 接入支付宝sdk 进行支付宝支付 开发 Android app maui BlazorWebView+本地html (vue、uniapp等都可以) 接入微信sdk 开发 Android app maui BlazorWebView+本地html 打包Android app 实现支付宝H5支付 maui WebView 打包Android app 实现线上网页 支付宝H5支付 maui BlazorWebView Android 中混合使用https和http 原生js+html+css 实现大转盘抽奖效果,实现人员占位,转盘缓慢停止时依次显示奖品图片 Serilog日志同步到redis中和自定义Enricher来增加额外的记录信息 c# .net 多类实现同一个接口,动态指定使用哪一个类的实现 C#、 .net 修改和移除 url 中的参数 windows 批量删除docker 镜像 uniapp 原生websocket 使用 signalr k8s docker 中部署think php 并搭建php websocket .net core Unicode 转中文
FreeScheduler 在asp.net core 中使用依赖注入的方式进行注入...
落叶子 · 2024-08-22 · via 博客园 - 落叶子

1. 创建 SchedulerTask.cs 类 ,代码如下

 public class SchedulerTask
 {
     private readonly ILogger<SchedulerTask> _logger;
     private readonly IServiceScopeFactory _serviceScopeFactory;public SchedulerTask(ILogger<SchedulerTask> logger, IServiceScopeFactory serviceScopeFactory)
     {
         _logger = logger;
         _serviceScopeFactory = serviceScopeFactory;
     }

     public async Task ExecuteAsync(TaskInfo task)
     {

         if (task.Topic == "test")
         {
             //调用其他服务
             using (var scope = _serviceScopeFactory.CreateScope())
             {
                 var xxx = scope.ServiceProvider.GetRequiredService<xxx>();
               
             }

         }

     }
    
 }

2.在main 函数中注入

public class Program
{
    public static void Main(string[] args)
    {
        var builder = WebApplication.CreateBuilder(args);

        builder.Services.AddControllers();
        //开始注入
        builder.Services.AddSingleton<SchedulerTask>();
        Func<IServiceProvider, Scheduler> schedulerFactory = r =>
        {
            var schedulerTask = r.GetRequiredService<SchedulerTask>();
            return new FreeSchedulerBuilder()
                .OnExecuting(task =>
                {

                     schedulerTask.ExecuteAsync(task).Wait(); //加wait 任务可以顺延
                })
                .UseTimeZone(TimeSpan.FromHours(8))
                .Build();
        };
        builder.Services.AddSingleton(schedulerFactory);
        var app = builder.Build();
        //程序启动时添加任务
        using (var scope = app.Services.CreateScope())
        {
            var scheduler = scope.ServiceProvider.GetRequiredService<Scheduler>();
            scheduler.AddTask("test", "test", -1, 3);
        }
        app.UseFreeSchedulerUI("/freescheduler/");
        app.UseAuthorization();


        app.MapControllers();

        app.Run();
    }
}

3. 其他地方使用

[Route("api/[controller]/[action]")]
[ApiController]
public class SchedulerController : ControllerBase
{
    private readonly Scheduler _scheduler;
    public SchedulerController(Scheduler scheduler)
    {
        _scheduler = scheduler;
    }
    [HttpGet]
    public void AddTask(string topic)
    {
        _scheduler.AddTask(topic, topic, -1, 10);
    }
}