ABP框架——集成Mysql

-Advertisement-

最近公司很多業務都要求上雲，雲上的資料庫購買了mysql（估計是應為便宜吧），所以我用abp框架開發的應用都要逐步切換到mysql。經過一陣摸索踩坑，總算是切換成功了，所以先記錄下方便後續切換使用，也順便分享給有需要的朋友。一、集成MySQL 其實集成mysql主要是參照官方文檔進行就可以了（官方 ...

最近公司很多業務都要求上雲，雲上的資料庫購買了mysql（估計是應為便宜吧），所以我用abp框架開發的應用都要逐步切換到mysql。經過一陣摸索踩坑，總算是切換成功了，所以先記錄下方便後續切換使用，也順便分享給有需要的朋友。

一、集成MySQL

其實集成mysql主要是參照官方文檔進行就可以了（官方文檔：https://aspnetboilerplate.com/Pages/Documents/EF-Core-MySql-Integration），這裡也是簡單描述下關鍵步驟：

（1）安裝Pomelo.EntityFrameworkCore.MySql

安裝Pomelo.EntityFrameworkCore.MySqlNuGet包到*.EntityFrameworkCore 項目上

（2）配置DBContext

替換YourProjectNameDbContextConfigurer.cs文件，將“UseSqlServer”替換為“UseMySql”，如下

 1     public static class WeChatDbContextConfigurer
 2     {
 3         public static void Configure(DbContextOptionsBuilder<WeChatDbContext> builder, string connectionString)
 4         {
 5             builder.UseMySql(connectionString);
 6         }
 7 
 8         public static void Configure(DbContextOptionsBuilder<WeChatDbContext> builder, DbConnection connection)
 9         {
10             builder.UseMySql(connection);
11         }
12     }

（3）配置鏈接字元串

修改appsettings.json中的資料庫鏈接，如:

{
  "ConnectionStrings": {
    "Default": "server=127.0.0.1;uid=root;pwd=1234;database=mysqldemodb"
  },
  ...
}

（4）修改Program.cs

修改防止EF Core調用Program.BuildWebHost()，需要將BuildWebHost函數改名，錄入改成InitWebHost。如下

 1     public class Program
 2     {
 3         public static void Main(string[] args)
 4         {
 5             InitWebHost(args).Run();
 6         }
 7 
 8         public static IWebHost InitWebHost(string[] args)
 9         {
10             return WebHost.CreateDefaultBuilder(args)
11                 .UseStartup<Startup>()
12                 .Build();
13         }
14     }

（5）創建資料庫

打開程式包管理控制台，選擇預設項目*.EntityFrameworkCore，執行命令“update-database”即可。如下

二、集成HangFire

（1）卸載預設hangfire

卸載之前NuGet中abp預設安裝的hangfire包，並註釋Module中預設將hangfire的後臺任務的註入代碼。（如之前沒有使用sqlserver的hangfire，次步驟可忽略）

[DependsOn(typeof (AbpHangfireAspNetCoreModule))]
public class MyProjectWebModule : AbpModule
{
    public override void PreInitialize()
    {
         //註釋hangfire
        //Configuration.BackgroundJobs.UseHangfire();             
    }

    //...
}

（2）項目引用NuGet包（ Hangfire.AspNetCore，Hangfire.MySql.Core）

（3）修改startup.cs類

 1    public IServiceProvider ConfigureServices(IServiceCollection services)
 2         {
 3             //........
 4             //配置msql下的hangfire
 5             services.AddHangfire(x => x.UseStorage(new MySqlStorage(
 6                 _appConfiguration.GetConnectionString("Default"),
 7                     new MySqlStorageOptions
 8                     {
 9                         TransactionIsolationLevel = IsolationLevel.ReadCommitted, // 事務隔離級別。預設是讀取已提交。
10                         QueuePollInterval = TimeSpan.FromSeconds(15),             //- 作業隊列輪詢間隔。預設值為15秒。
11                         JobExpirationCheckInterval = TimeSpan.FromHours(1),       //- 作業到期檢查間隔（管理過期記錄）。預設值為1小時。
12                         CountersAggregateInterval = TimeSpan.FromMinutes(5),      //- 聚合計數器的間隔。預設為5分鐘。
13                         PrepareSchemaIfNecessary = true,                          //- 如果設置為true，則創建資料庫表。預設是true。
14                         DashboardJobListLimit = 50000,                            //- 儀錶板作業列表限制。預設值為50000。
15                         TransactionTimeout = TimeSpan.FromMinutes(1),           //- 交易超時。預設為1分鐘。
16                         TablePrefix = "Hangfire"
17                     }
18                 )));
19              //........
20         }

1          public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory)
2          {
3              app.UseHangfireServer();  //啟用hangfire服務
4              app.UseHangfireDashboard(); //使用hangfire面板
5          }

（4）啟動項目,訪問Hangfire面板

本地訪問地址：https://localhost:埠/Hangfire

（5）部署IIS相關配置

將hangfire部署在iis中時，必須要證應用程式一直運行，不會被iis回收。

a.設置應用程式池，

b.右鍵應用程式池-》高級設置，配置如下啟動模式為AlwaysRunning,閑置超時設置為0；

c.郵件站點，選擇高級設置，設定預載入啟用為true。

您的分享是我們最大的動力!