提交

TakeStock.API/Startup.cs

@@ -4,6 +4,7 @@ using Domain.TakeStock.Repository;
 using EasyNetQ;
 using EasyNetQ.AutoSubscribe;
 using Hangfire;
+using Hangfire.MemoryStorage;
 using Hangfire.MySql;
 using IService.TakeStock;
 using MessageQueue;
@@ -32,11 +33,11 @@ namespace TakeStock.API
         public Startup(IConfiguration configuration)
         {
             Configuration = configuration;
-            Redis = ConnectionMultiplexer.Connect(Configuration.GetConnectionString("Redis"));
+            //Redis = ConnectionMultiplexer.Connect(Configuration.GetConnectionString("Redis"));
         }
 
         public IConfiguration Configuration { get; }
-        public static ConnectionMultiplexer Redis;
+        //public static ConnectionMultiplexer Redis;
 
         // This method gets called by the runtime. Use this method to add services to the container.
         public void ConfigureServices(IServiceCollection services)
@@ -73,7 +74,10 @@ namespace TakeStock.API
             services.AddHttpClient();
 
             // Add Hangfire services.
-            services.AddHangfire(configuration => configuration.UseRedisStorage(Redis));
+            services.AddHangfire(config =>
+            {
+                config.UseMemoryStorage();
+            });
             // Add the processing server as IHostedService
             services.AddHangfireServer();
 
@@ -111,7 +115,6 @@ namespace TakeStock.API
             //dbContext.Migration();
 
             //app.UseSubscribe("TakeStockService", AppDomain.CurrentDomain.GetAssemblies().Single(a => a.GetName().Name == "Service"));
-
         }
 
         public void RegisterHttpClient(IServiceCollection services)

TakeStock.API/TakeStock.API.csproj

-<Project Sdk="Microsoft.NET.Sdk.Web">
+<Project Sdk="Microsoft.NET.Sdk.Web">
 
   <PropertyGroup>
     <TargetFramework>netcoreapp2.2</TargetFramework>
@@ -13,6 +13,7 @@
     <PackageReference Include="Hangfire.AspNetCore" Version="1.7.3" />
     <PackageReference Include="Hangfire.Dashboard.Authorization" Version="2.1.0" />
     <PackageReference Include="Hangfire.Dashboard.Dark" Version="1.0.6" />
+    <PackageReference Include="Hangfire.MemoryStorage" Version="1.6.3" />
     <PackageReference Include="Hangfire.MySqlStorage" Version="2.0.0" />
     <PackageReference Include="Hangfire.Redis.StackExchange" Version="1.8.0" />
     <PackageReference Include="Microsoft.AspNetCore.App" />