TANG JIANG 1 year ago
parent
commit
292af58bb9
2 changed files with 31 additions and 1 deletions
  1. 30 0
      src/Sharing.Api/DemoBgService.cs
  2. 1 1
      src/Sharing.Api/StartupExtensions.cs

+ 30 - 0
src/Sharing.Api/DemoBgService.cs

@@ -0,0 +1,30 @@
+namespace Sharing.Api
+{
+    public class DemoBgService : BackgroundService
+    {
+        private readonly int nSleep = 1 * 10 * 1000;//10秒运行一次
+        private ILogger<DemoBgService> logger;
+
+        public DemoBgService(ILogger<DemoBgService> logger)
+        {
+            this.logger = logger;
+        }
+
+        /// <summary>
+        /// 任务的代码
+        /// </summary>
+        /// <param name="stoppingToken"></param>
+        /// <returns></returns>
+        protected override async Task ExecuteAsync(CancellationToken stoppingToken)
+        {
+            while (!stoppingToken.IsCancellationRequested)
+            {
+                string randomString = "Abc"+DateTime.Now.ToString() +"-"+ Guid.NewGuid().ToString();
+                Console.WriteLine(randomString);
+                await Task.Delay(nSleep, stoppingToken);
+            }
+        }
+
+       
+    }
+}

+ 1 - 1
src/Sharing.Api/StartupExtensions.cs

@@ -98,7 +98,7 @@ internal static class StartupExtensions
 
         //mq
         services.AddMq(configuration);
-
+        services.AddHostedService<DemoBgService>();
         return builder.Build();
     }