From 2a432088aa595f288ae2c2624d5d3a4501bbd12e Mon Sep 17 00:00:00 2001
From: liguoyang <Ligy.97@foxmail.com>
Date: Tue, 30 Jan 2024 17:19:00 +0800
Subject: [PATCH] =?UTF-8?q?fix=20hangfire=E5=88=87=E6=8D=A2=E5=88=B0redis?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Dlhis.ScheduledTask.csproj                |  3 +--
 Src/Dlhis.ScheduledTask/Packs/HangfirePack.cs | 19 +++++++++----------
 Src/Dlhis.ScheduledTask/Program.cs            |  8 ++++++++
 3 files changed, 18 insertions(+), 12 deletions(-)

diff --git a/Src/Dlhis.ScheduledTask/Dlhis.ScheduledTask.csproj b/Src/Dlhis.ScheduledTask/Dlhis.ScheduledTask.csproj
index f2496b56..c87349e5 100644
--- a/Src/Dlhis.ScheduledTask/Dlhis.ScheduledTask.csproj
+++ b/Src/Dlhis.ScheduledTask/Dlhis.ScheduledTask.csproj
@@ -19,10 +19,9 @@
     <ItemGroup>
       <PackageReference Include="Hangfire.AspNetCore" Version="1.8.7" />
       <PackageReference Include="Hangfire.Dashboard.BasicAuthorization" Version="1.0.2" />
-      <PackageReference Include="Hangfire.MySqlStorage" Version="2.0.3" />
+      <PackageReference Include="Hangfire.Redis.StackExchange" Version="1.9.3" />
       <PackageReference Include="Kurisu.AspNetCore" Version="0.5.2" />
       <PackageReference Include="Microsoft.AspNetCore.DataProtection.StackExchangeRedis" Version="6.0.26" />
-      <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.19.4" />
     </ItemGroup>
 
     <ItemGroup>
diff --git a/Src/Dlhis.ScheduledTask/Packs/HangfirePack.cs b/Src/Dlhis.ScheduledTask/Packs/HangfirePack.cs
index 32fed15f..2fc2c372 100644
--- a/Src/Dlhis.ScheduledTask/Packs/HangfirePack.cs
+++ b/Src/Dlhis.ScheduledTask/Packs/HangfirePack.cs
@@ -1,8 +1,8 @@
 using Hangfire;
 using Hangfire.Dashboard.BasicAuthorization;
-using Hangfire.MySql;
+using Hangfire.Redis.StackExchange;
 using Kurisu.AspNetCore.Startup;
-
+using StackExchange.Redis;
 
 namespace Dlhis.ScheduledTask.Packs;
 
@@ -14,16 +14,15 @@ public class HangfirePack : BaseAppPack
 
     public override void ConfigureServices(IServiceCollection services)
     {
-        services.AddHangfire(configuration =>
+        services.AddHangfire((sp, config) =>
         {
-            var options = new MySqlStorageOptions
-            {
-                TablesPrefix = "hangfire"
-            };
-
-            configuration.UseSimpleAssemblyNameTypeSerializer()
+            config.UseSimpleAssemblyNameTypeSerializer()
             .UseRecommendedSerializerSettings()
-            .UseStorage(new MySqlStorage(Configuration.GetConnectionString("HangfireConnection"), options));
+            .UseRedisStorage(sp.GetService<IConnectionMultiplexer>(), new RedisStorageOptions
+            {
+                Db = 5,
+                Prefix = "hangfire"
+            });
 
         });
 
diff --git a/Src/Dlhis.ScheduledTask/Program.cs b/Src/Dlhis.ScheduledTask/Program.cs
index f86ba335..1b163c0c 100644
--- a/Src/Dlhis.ScheduledTask/Program.cs
+++ b/Src/Dlhis.ScheduledTask/Program.cs
@@ -2,7 +2,9 @@ using System.Net.NetworkInformation;
 using Kurisu.AspNetCore.Startup;
 using Kurisu.Startup;
 using Microsoft.AspNetCore.DataProtection;
+using Microsoft.Extensions.Options;
 using StackExchange.Redis;
+using static StackExchange.Redis.Role;
 
 class Program
 {
@@ -22,6 +24,12 @@ public class Startup : DefaultStartup
     {
         base.ConfigureServices(services);
 
+        services.AddSingleton<IConnectionMultiplexer>(sp =>
+        {
+            return ConnectionMultiplexer.Connect("192.168.199.30:30115,defaultDatabase:1,password=zxc111");
+        });
+
+
         var p = new Ping();
         Console.WriteLine(p.Send("192.168.199.124").Status);