开源：Taurus.DTS 微服务分布式任务框架，支持即时任务、延时任务、Cron表达式定时任务和广播任务。

开源：Taurus.DTS 微服务分布式任务框架，支持即时任务、延时任务、Cron表达式定时任务和广播任务。 表达式定时任务和广播任务 微服务分布式任务框架 ：Taurus. Taurus. 支持即时任务 Taurus 、Cron 延时任务 Cron

来源： 时间：2024/5/27 11:40:00  点击：2  

前言：

在发布完：开源：Taurus.DTC 微服务分布式事务框架，支持 .Net 和 .Net Core 双系列版本，之后想想，好像除了事务外，感觉里面多了一个任务发布订阅的基础功能。

本想既然都有了基础发布订阅功能了，那要不要顺带加上延时发布功能呢？加上了会不会让事务组件不纯了？

经过一翻深思，是在其上补上功能，还是，重新写一个组件，起初起名是个难题，因为 DTC 也可以是 Distributed Task Cxxxxx， 组件重名了？

经过一翻英文大作战，找到了：Distributed Task Scheduler，简写可以是DTS了，才开始重启一个组件。

于是就有了这个Taurus.DTS 任务组件，而且功能除了原有的即时任务发布订阅，和本来想加上的延时任务，后面又补上了基于Cron表达式的定时任务，和广播群发任务。

经过一翻大作战，有 Taurus.DTC 的基础代码作底层支持，花了大几天，解决了各种疑难杂症之后，终于出来了。

1、开源地址：

https://github.com/cyq1162/Taurus.DTS

2、Nuget 包引用ID：

由于 CYQ.Data Orm 组件本身支持10多种数据库，因此提供的包，只根据消息队列的需要分拆提供。

默认Taurus.DTS 支持同时使用 RabbitMQ 和 Kafka 两种消息队列。

如果一个项目中只用RabbitMQ，则引入 Tarurus.DTS.RabbitMQ，减少对 Kafka 的依赖包。

编绎的版本：支持太多，发布是个苦力活：

.Net 系列：由于引用依赖关系（RabbitMQ最低是 4.0，Kafka最低是 4.5）；

.Net Core系列、支持 2.1 到 8.0 版本及以后。

Standard 标准库：支持2.1 及以后。

3、Taurus.DTS 微服务分布式任务框架基础说明：

基础说明：

1、框架分为： Client（客户端，即任务发起端）和 Server（服务端，即方法订阅方）。

2、框架支持：即时任务、延时任务、Cron表达式任务定时任务、广播任务，四种方式。

3、项目需要配置的参数：1、数据库（可选）；2、MQ（必选）。

数据存储：

可选择数据库（MSSQL、MySql、Oracle、PostgreSql 等 CYQ.Data 所支持的10多种数据库之一）

MSSQL配置示例如下：

{
  "ConnectionStrings": {
    "DTS.Server.Conn": "server=.;database=MSLog;uid=sa;pwd=123456"
  }
}

消息队列：

目前消息队列支持 RabbitMQ 或者 Kafka（配置其中一方即可）：

{
  "AppSettings": {
  "DTS.Server.Rabbit":"127.0.0.1;guest;guest;/",//ip;username;password;virtualpath;
  "DTS.Server.Kafka":"127.0.0.1:9092" 
  }
}

以上配置为Server端，客户端更改 Server 为 Client 即可。

4、Server 端 使用示例：

1、Nuget 搜索 Taurus.DTS 引入工程项目中。

2、如果是 ASP.Net Core 程序：Program 或 Startup 添加服务使用引入：

  services.AddTaurusDts(); // 服务添加。
  app.UseTaurusDts(TaskStartType.Server); //服务使用，启用服务端

3、appsettings.json 配置基本属性：

  {
  "ConnectionStrings": {
    "DTS.Server.Conn": "host=localhost;port=3306;database=cyqdata;uid=root;pwd=123456;Convert Zero Datetime=True;"
  },
  "AppSettings": {
    "DTS.Server.Rabbit": "127.0.0.1;guest;guest;/" //IP;UserName;Password;VirtualPaath
}

4、选择数据库对应的依赖组件，如MySql，可以：

Nuget 上可以搜索 MySql.Data 、或者 CYQ.Data.MySql (会自动引入MySql.Data)  都可， 引入项目即可。

5、代码编写，可以参考源码中提供的示例代码，如下为控制台示例代码：

using System;
using Taurus.Plugin.DistributedTask;
namespace Console_App_Server {

 internal class Program
 {
 
     static void Main(string[] args)
    {

        DTSConfig.Server.Rabbit = "127.0.0.1;guest;guest;/";
        //DTSConfig.Server.Kafka = "127.0.0.1:9092;";
        //DTSConfig.Server.Conn = DTSConfig.Client.Conn;

        DTSConfig.ProjectName = "ConsoleApp5";

        DTS.Server.Start();//start client and server

        Console.WriteLine("---------------------------------------");

        Console.ReadLine();
    }


}


/// <summary>
/// 服务端 server class need to public
/// </summary>
public class Server
{
    [DTSSubscribe("DoInstantTask")]
    public static bool A(DTSSubscribePara para)
    {
        para.CallBackContent = "show you a.";
        return true;
    }

    [DTSSubscribe("DoDelayTask")]
    private static bool B(DTSSubscribePara para)
    {
        para.CallBackContent = "show you b.";
        return true;
    }
    [DTSSubscribe("DoCronTask")]
    private static bool C(DTSSubscribePara para)
    {
        para.CallBackContent = "show you c.";
        return true;
    }
    /// <summary>
    /// 定时任务
    /// </summary>
    [DTSSubscribe("DoBroadastTask")]
    private static bool TimerTask(DTSSubscribePara para)
    {
        para.CallBackContent = "show you d.";
        return true;
    }
}
 
}

5、Client 端 使用示例：

1、Nuget 搜索 Taurus.DTS 引入工程项目中。

2、如果是ASP.Net Core 程序：Program 或 Startup 添加服务使用引入：

  services.AddTaurusDts(); // 服务添加
  app.UseTaurusDts(StartType.Client); //服务使用，启用服务端

3、appsettings.json 配置基本属性：

  {
  "ConnectionStrings": {
    "DTS.Client.Conn": "host=localhost;port=3306;database=cyqdata;uid=root;pwd=123456;Convert Zero Datetime=True;"
  },
  "AppSettings": {
    "DTS.Client.Rabbit": "127.0.0.1;guest;guest;/" //IP;UserName;Password;VirtualPaath
}

4、选择数据库对应的依赖组件，如MySql，可以：

Nuget 上可以搜索 MySql.Data 、或者 CYQ.Data.MySql (会自动引入MySql.Data)  都可， 引入项目即可。

5、代码编写，可以参考源码中提供的示例代码，如下为控制台示例代码：

using System;
using System.Threading;
using Taurus.Plugin.DistributedTask;
namespace Console_App_Client {

  internal class Program
  {
  
    static void Main(string[] args)
    {
    
        DTSConfig.Client.IsPrintTraceLog = false;
        //AppConfig.Redis.Servers = "127.0.0.1:6379";

        DTSConfig.Client.Rabbit = "127.0.0.1;guest;guest;/";
        //DTSConfig.Client.Kafka = "127.0.0.1:9092;";
        DTSConfig.Client.Conn = "server=.;database=mslog;uid=sa;pwd=123456";

        DTSConfig.ProjectName = "ConsoleApp5";

        DTS.Client.Start();//start client and server
        
        Console.WriteLine("---------------------------------------");
        Console.WriteLine("1-InstantTask、2-DelayTask（1Minutes）、3-CronTask、4-DeleteCronTask、5-BroadastTask");
        Console.WriteLine("Input ：1、2、3、4、5，Press Enter.");
        while (true)
        {
            string line = Console.ReadLine();
            try
            {
                Client.Run(int.Parse(line));
            }
            catch(Exception err)
            {
                Console.WriteLine(err.Message);
            }
            
        }

    }
}

/// <summary>
/// 客户端 client class need to public if has callback method.
/// </summary>
public class Client
{
    public static void Run(int i)
    {

        if (i == 2)
        {
            //发布一个延时1分钟的任务
            DTS.Client.Delay.PublishAsync(1, "i publish a delay task.", "DoDelayTask", "DelayCallBack");
            Console.WriteLine("Wait for 1 minute...");
        }
        else if (i == 3)
        {
            //发布一个秒在30时的循环任务。
            DTS.Client.Cron.PublishAsync("10,30,50 * * * * ?", "i publish a timer task with cron express.", "DoCronTask", "CronCallBack");
            Console.WriteLine("Wait for execute task when second is 10,30,50...");
        }
        else if (i == 4)
        {
            //发布一个秒在30时的循环任务。
            DTS.Client.Cron.DeleteAsync("DoCronTask", null, "CronCallBack");
        }
        else if (i == 5)
        {
            //发布一个广播任务
            DTS.Client.Broadast.PublishAsync("i publish a task for all server.", "DoBroadastTask", "BroadastCallBack");
        }
        else
        {
            for (int k = 0; k < 1; k++)
            {
                //发布一个即时任务
                DTS.Client.Instant.PublishAsync("i publish a task instantly.", "DoInstantTask", "InstantCallBack");
                Console.WriteLine(k);
            }
            
        }
    }

    [DTSCallBack("InstantCallBack")]
    [DTSCallBack("DelayCallBack")]
    [DTSCallBack("CronCallBack")]
    [DTSCallBack("BroadastCallBack")]
    private static void OnCallBack(DTSCallBackPara para)
    {
        Console.WriteLine("Client callback : " + para.TaskType + " - " + para.CallBackKey + " - " + para.CallBackContent);
    }
}
 
}

6、Demo 运行示例：

demo 地址：https://github.com/cyq1162/Taurus.DTS/tree/master/demo

启动运行截图：

 输入1，发布即时任务：

7、其它：CYQ.Data 支持的数据库链接语句示例

###--------------------------------------------------------###

   Txt::  Txt Path=E:\
   Xml::  Xml Path=E:\
Access::  Provider=Microsoft.Jet.OLEDB.4.0; Data Source=E:\cyqdata.mdb
Sqlite::  Data Source=E:\cyqdata.db;failifmissing=false;
 MySql::  host=localhost;port=3306;database=cyqdata;uid=root;pwd=123456;Convert Zero Datetime=True;
 Mssql::  server=.;database=cyqdata;uid=sa;pwd=123456;provider=mssql; 
Sybase::  data source=127.0.0.1;port=5000;database=cyqdata;uid=sa;pwd=123456;provider=sybase; 
Postgre:  server=localhost;uid=sa;pwd=123456;database=cyqdata;provider=pg; 
    DB2:  Database=SAMPLE;User ID=administrator;Server=127.0.0.1;password=1234560;provider=db2; 
FireBird  user id=SYSDBA;password=123456;database=d:\\test.dbf;server type=Default;data source=127.0.0.1;port number=3050;provider=firebird;
Dameng::  user id=SYSDBA;password=123456789;data source=127.0.0.1;schema=test;provider=dameng;
KingBaseES server=127.0.0.1;User Id=system;Password=123456;Database=test;Port=54321;schema=public;provider=kingbasees;
Oracle ODP.NET::
Data Source=(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=127.0.0.1)(PORT = 1521)))(CONNECT_DATA =(SID = orcl)));User ID=sa;password=123456

由于各种数据库链接语句基本一致，除了特定写法外，可以通过链接补充：provider=mssql、provider=mysql、provider=db2、provider=postgre等来区分。
###--------------------------------------------------------###

8、总结：

由于 Taurus.DTS 分布式任务发布组件的独立发布，原有发布的 Taurus.DTC 分布式事务组件，下一版本会移除掉其基础的任务发布订阅功能，保留事务的纯洁属性。

今天发布的 Taurus.DTS 组件，为 .Net 和  .Net Core 微服务系列又又贡献了一个新的组件。

后续会发布分布式锁的教程，这个已经在 CYQ.Data 里实现了，并且在也在 Taurus.DTC 和 Taurus.DTS 中使用到了。

版权声明：本文原创发表于 博客园，作者为 路过秋天 本文欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，否则视为侵权。 个人微信公众号
Donation(扫码支持作者)：支付宝：
Donation(扫码支持作者)：微信：
评论

阅读排行

  1. SqlSugar框架之WPF应用端功能介绍
  2. 自定义分页控件
  3. 【.NET项目分享】免费开源的静态博客生成工具EasyBlog,5分钟拥有自己的博客
  4. 记一次 .NET某酒店后台服务 卡死分析
  5. efcore如何优雅的实现按年分库按月分表
  6. net core jwt的基本原理和实现
  7. 自研WPF插件系统(沙箱运行及热插拔)
  8. RabbitMQ的基本用法

最新资讯

  1. .Net PdfiumViewer 打印时无法渲染电子签名问题的解决方法
  2. .NET 内存管理两种有效的资源释放方式
  3. AOT漫谈专题(第三篇): 如何获取C#程序的CPU利用率
  4. .NET云原生应用实践（二）：Sticker微服务RESTful API的实现
  5. （系列六）.net8 全局异常捕获机制
  6. Some bytes have been replaced with the Unicode substitution character while loading file
  7. .NET 8 实现无实体库表 API 部署服务
  8. .NET程序获取当前IP经纬度，并通过经纬度实现天气查询功能