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 @@
-
+
-
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(), 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(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);