feat(Isolation): Added isolation support

Masa.Contrib.sln

@@ -130,11 +130,23 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Masa.BuildingBlocks.SearchE
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Masa.BuildingBlocks.Service.MinimalAPIs", "src\BuildingBlocks\MASA.BuildingBlocks\src\Service\Masa.BuildingBlocks.Service.MinimalAPIs\Masa.BuildingBlocks.Service.MinimalAPIs.csproj", "{E72E105D-B15F-4D69-9A13-CAA49D4889D6}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Masa.Contrib.Dispatcher.Events.HandlerOrder.Tests", "test\Masa.Contrib.Dispatcher.Events.HandlerOrder.Tests\Masa.Contrib.Dispatcher.Events.HandlerOrder.Tests.csproj", "{4A052E17-4D9E-41EF-89A5-73B917053F8E}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Masa.Contrib.Dispatcher.Events.HandlerOrder.Tests", "test\Masa.Contrib.Dispatcher.Events.HandlerOrder.Tests\Masa.Contrib.Dispatcher.Events.HandlerOrder.Tests.csproj", "{4A052E17-4D9E-41EF-89A5-73B917053F8E}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Masa.Contrib.SearchEngine.AutoComplete", "src\SearchEngine\Masa.Contrib.SearchEngine.AutoComplete\Masa.Contrib.SearchEngine.AutoComplete.csproj", "{3F8532EF-3DC9-45F8-9562-994ABE066585}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Masa.Contrib.SearchEngine.AutoComplete", "src\SearchEngine\Masa.Contrib.SearchEngine.AutoComplete\Masa.Contrib.SearchEngine.AutoComplete.csproj", "{3F8532EF-3DC9-45F8-9562-994ABE066585}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Masa.Contrib.SearchEngine.AutoComplete.Tests", "test\Masa.Contrib.SearchEngine.AutoComplete.Tests\Masa.Contrib.SearchEngine.AutoComplete.Tests.csproj", "{31262D61-26A4-4302-968D-52B8DA4558CD}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Masa.Contrib.SearchEngine.AutoComplete.Tests", "test\Masa.Contrib.SearchEngine.AutoComplete.Tests\Masa.Contrib.SearchEngine.AutoComplete.Tests.csproj", "{31262D61-26A4-4302-968D-52B8DA4558CD}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Masa.BuildingBlocks.Isolation", "src\BuildingBlocks\MASA.BuildingBlocks\src\Isolation\Masa.BuildingBlocks.Isolation\Masa.BuildingBlocks.Isolation.csproj", "{B689E82B-B3E8-4C83-B56C-D4C27206AAC6}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Masa.Contrib.Isolation.UoW.EF", "src\Isolation\Masa.Contrib.Isolation.UoW.EF\Masa.Contrib.Isolation.UoW.EF.csproj", "{0C25062D-60A5-4690-974A-CDA9619866B4}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Masa.Contrib.Isolation.MultiTenant", "src\Isolation\Masa.Contrib.Isolation.MultiTenant\Masa.Contrib.Isolation.MultiTenant.csproj", "{6D9A3F62-8AB6-40AD-B32F-2A435A9D3341}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Masa.Contrib.Isolation.Environment", "src\Isolation\Masa.Contrib.Isolation.Environment\Masa.Contrib.Isolation.Environment.csproj", "{E9A3C62C-EA85-40C3-BB3B-7836D0337F63}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Masa.Contrib.Isolation.UoW.EF.Tests", "test\Masa.Contrib.Isolation.UoW.EF.Tests\Masa.Contrib.Isolation.UoW.EF.Tests.csproj", "{50551732-AAE0-4F77-B401-9DD02E226CDB}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Masa.Contrib.Isolation.UoW.EF.Web.Tests", "test\Masa.Contrib.Isolation.UoW.EF.Web.Tests\Masa.Contrib.Isolation.UoW.EF.Web.Tests.csproj", "{7CF33D08-9468-464D-B52E-955A5667EE42}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -504,6 +516,54 @@ Global
 		{31262D61-26A4-4302-968D-52B8DA4558CD}.Release|Any CPU.Build.0 = Release|Any CPU
 		{31262D61-26A4-4302-968D-52B8DA4558CD}.Release|x64.ActiveCfg = Release|Any CPU
 		{31262D61-26A4-4302-968D-52B8DA4558CD}.Release|x64.Build.0 = Release|Any CPU
+		{B689E82B-B3E8-4C83-B56C-D4C27206AAC6}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{B689E82B-B3E8-4C83-B56C-D4C27206AAC6}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{B689E82B-B3E8-4C83-B56C-D4C27206AAC6}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{B689E82B-B3E8-4C83-B56C-D4C27206AAC6}.Debug|x64.Build.0 = Debug|Any CPU
+		{B689E82B-B3E8-4C83-B56C-D4C27206AAC6}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{B689E82B-B3E8-4C83-B56C-D4C27206AAC6}.Release|Any CPU.Build.0 = Release|Any CPU
+		{B689E82B-B3E8-4C83-B56C-D4C27206AAC6}.Release|x64.ActiveCfg = Release|Any CPU
+		{B689E82B-B3E8-4C83-B56C-D4C27206AAC6}.Release|x64.Build.0 = Release|Any CPU
+		{0C25062D-60A5-4690-974A-CDA9619866B4}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{0C25062D-60A5-4690-974A-CDA9619866B4}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{0C25062D-60A5-4690-974A-CDA9619866B4}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{0C25062D-60A5-4690-974A-CDA9619866B4}.Debug|x64.Build.0 = Debug|Any CPU
+		{0C25062D-60A5-4690-974A-CDA9619866B4}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{0C25062D-60A5-4690-974A-CDA9619866B4}.Release|Any CPU.Build.0 = Release|Any CPU
+		{0C25062D-60A5-4690-974A-CDA9619866B4}.Release|x64.ActiveCfg = Release|Any CPU
+		{0C25062D-60A5-4690-974A-CDA9619866B4}.Release|x64.Build.0 = Release|Any CPU
+		{6D9A3F62-8AB6-40AD-B32F-2A435A9D3341}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{6D9A3F62-8AB6-40AD-B32F-2A435A9D3341}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{6D9A3F62-8AB6-40AD-B32F-2A435A9D3341}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{6D9A3F62-8AB6-40AD-B32F-2A435A9D3341}.Debug|x64.Build.0 = Debug|Any CPU
+		{6D9A3F62-8AB6-40AD-B32F-2A435A9D3341}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{6D9A3F62-8AB6-40AD-B32F-2A435A9D3341}.Release|Any CPU.Build.0 = Release|Any CPU
+		{6D9A3F62-8AB6-40AD-B32F-2A435A9D3341}.Release|x64.ActiveCfg = Release|Any CPU
+		{6D9A3F62-8AB6-40AD-B32F-2A435A9D3341}.Release|x64.Build.0 = Release|Any CPU
+		{E9A3C62C-EA85-40C3-BB3B-7836D0337F63}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{E9A3C62C-EA85-40C3-BB3B-7836D0337F63}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{E9A3C62C-EA85-40C3-BB3B-7836D0337F63}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{E9A3C62C-EA85-40C3-BB3B-7836D0337F63}.Debug|x64.Build.0 = Debug|Any CPU
+		{E9A3C62C-EA85-40C3-BB3B-7836D0337F63}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{E9A3C62C-EA85-40C3-BB3B-7836D0337F63}.Release|Any CPU.Build.0 = Release|Any CPU
+		{E9A3C62C-EA85-40C3-BB3B-7836D0337F63}.Release|x64.ActiveCfg = Release|Any CPU
+		{E9A3C62C-EA85-40C3-BB3B-7836D0337F63}.Release|x64.Build.0 = Release|Any CPU
+		{50551732-AAE0-4F77-B401-9DD02E226CDB}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{50551732-AAE0-4F77-B401-9DD02E226CDB}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{50551732-AAE0-4F77-B401-9DD02E226CDB}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{50551732-AAE0-4F77-B401-9DD02E226CDB}.Debug|x64.Build.0 = Debug|Any CPU
+		{50551732-AAE0-4F77-B401-9DD02E226CDB}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{50551732-AAE0-4F77-B401-9DD02E226CDB}.Release|Any CPU.Build.0 = Release|Any CPU
+		{50551732-AAE0-4F77-B401-9DD02E226CDB}.Release|x64.ActiveCfg = Release|Any CPU
+		{50551732-AAE0-4F77-B401-9DD02E226CDB}.Release|x64.Build.0 = Release|Any CPU
+		{7CF33D08-9468-464D-B52E-955A5667EE42}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{7CF33D08-9468-464D-B52E-955A5667EE42}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{7CF33D08-9468-464D-B52E-955A5667EE42}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{7CF33D08-9468-464D-B52E-955A5667EE42}.Debug|x64.Build.0 = Debug|Any CPU
+		{7CF33D08-9468-464D-B52E-955A5667EE42}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{7CF33D08-9468-464D-B52E-955A5667EE42}.Release|Any CPU.Build.0 = Release|Any CPU
+		{7CF33D08-9468-464D-B52E-955A5667EE42}.Release|x64.ActiveCfg = Release|Any CPU
+		{7CF33D08-9468-464D-B52E-955A5667EE42}.Release|x64.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -571,6 +631,12 @@ Global
 		{4A052E17-4D9E-41EF-89A5-73B917053F8E} = {2BE750A5-8AC7-457C-9BB2-6E3D5E2D23B8}
 		{3F8532EF-3DC9-45F8-9562-994ABE066585} = {8C39C640-0E8A-43A7-890C-9742B6B70AA4}
 		{31262D61-26A4-4302-968D-52B8DA4558CD} = {38E6C400-90C0-493E-9266-C1602E229F1B}
+		{B689E82B-B3E8-4C83-B56C-D4C27206AAC6} = {DC578D74-98F0-4F19-A230-CFA8DAEE0AF1}
+		{0C25062D-60A5-4690-974A-CDA9619866B4} = {022D6FF5-4B65-4213-9A97-C69E2B2F99E1}
+		{6D9A3F62-8AB6-40AD-B32F-2A435A9D3341} = {022D6FF5-4B65-4213-9A97-C69E2B2F99E1}
+		{E9A3C62C-EA85-40C3-BB3B-7836D0337F63} = {022D6FF5-4B65-4213-9A97-C69E2B2F99E1}
+		{50551732-AAE0-4F77-B401-9DD02E226CDB} = {38E6C400-90C0-493E-9266-C1602E229F1B}
+		{7CF33D08-9468-464D-B52E-955A5667EE42} = {38E6C400-90C0-493E-9266-C1602E229F1B}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {40383055-CC50-4600-AD9A-53C14F620D03}

src/Data/Masa.Contrib.Data.UoW.EF/DispatcherOptionsExtensions.cs

@@ -40,7 +40,7 @@ private static IServiceCollection UseUoW<TDbContext>(
 
         services.AddSingleton<UoWProvider>();
         services.TryAddScoped<IUnitOfWorkAccessor, UnitOfWorkAccessor>();
-        services.TryAddSingleton<IUnitOfWorkManager, UnitOfWorkManager>();
+        services.TryAddSingleton<IUnitOfWorkManager, UnitOfWorkManager<TDbContext>>();
         services.TryAddScoped<IConnectionStringProvider, DefaultConnectionStringProvider>();
         services.TryAddSingleton<IDbConnectionStringProvider, DbConnectionStringProvider>();
 

src/Data/Masa.Contrib.Data.UoW.EF/UnitOfWork.cs

@@ -4,7 +4,9 @@ public class UnitOfWork<TDbContext> : IUnitOfWork where TDbContext : MasaDbConte
 {
     public IServiceProvider ServiceProvider { get; }
 
-    protected DbContext Context;
+    private readonly DbContext? _context = null;
+
+    protected DbContext Context => _context ?? ServiceProvider.GetRequiredService<TDbContext>();
 
     public DbTransaction Transaction
     {
@@ -30,11 +32,7 @@ public DbTransaction Transaction
 
     public bool UseTransaction { get; set; } = true;
 
-    public UnitOfWork(IServiceProvider serviceProvider)
-    {
-        ServiceProvider = serviceProvider;
-        Context = serviceProvider.GetRequiredService<TDbContext>();
-    }
+    public UnitOfWork(IServiceProvider serviceProvider) => ServiceProvider = serviceProvider;
 
     public async Task SaveChangesAsync(CancellationToken cancellationToken = default)
     {
@@ -59,7 +57,7 @@ public async Task RollbackAsync(CancellationToken cancellationToken = default)
         await Context.Database.RollbackTransactionAsync(cancellationToken);
     }
 
-    public async ValueTask DisposeAsync() => await Context.DisposeAsync();
+    public async ValueTask DisposeAsync() => await (_context?.DisposeAsync() ?? ValueTask.CompletedTask);
 
-    public void Dispose() => Context.Dispose();
+    public void Dispose() => _context?.Dispose();
 }

src/Data/Masa.Contrib.Data.UoW.EF/UnitOfWorkManager.cs

@@ -1,14 +1,23 @@
 namespace Masa.Contrib.Data.UoW.EF;
 
-public class UnitOfWorkManager : IUnitOfWorkManager
+public class UnitOfWorkManager<TDbContext> : IUnitOfWorkManager where TDbContext : MasaDbContext
 {
     private readonly IServiceProvider _serviceProvider;
 
     public UnitOfWorkManager(IServiceProvider serviceProvider) => _serviceProvider = serviceProvider;
 
-    public IUnitOfWork CreateDbContext()
+    /// <summary>
+    /// Create new DbContext
+    /// We create DbContext with lazy loading enabled by default
+    /// </summary>
+    /// <param name="lazyLoading">Deferred creation of DbContext, easy to specify tenant or environment by yourself, which is very effective for physical isolation</param>
+    /// <returns></returns>
+    public IUnitOfWork CreateDbContext(bool lazyLoading = true)
     {
         var scope = _serviceProvider.CreateAsyncScope();
+        if (!lazyLoading)
+            scope.ServiceProvider.GetRequiredService<TDbContext>();
+
         return scope.ServiceProvider.GetRequiredService<IUnitOfWork>();
     }
 
@@ -21,6 +30,7 @@ public IUnitOfWork CreateDbContext(MasaDbContextConfigurationOptions options)
         var scope = _serviceProvider.CreateAsyncScope();
         var unitOfWorkAccessor = scope.ServiceProvider.GetRequiredService<IUnitOfWorkAccessor>();
         unitOfWorkAccessor.CurrentDbContextOptions = options;
+
         return scope.ServiceProvider.GetRequiredService<IUnitOfWork>();
     }
 }

src/Dispatcher/Masa.Contrib.Dispatcher.IntegrationEvents.Dapr/ServiceCollectionExtensions.cs

@@ -47,7 +47,7 @@ internal static IServiceCollection TryAddDaprEventBus<TIntegrationEventLogServic
         if (services.All(service => service.ServiceType != typeof(IUnitOfWork)))
         {
             var logger = services.BuildServiceProvider().GetService<ILogger<IntegrationEventBus>>();
-            logger?.LogWarning("UoW is not enabled, local messages will not be integrated");
+            logger?.LogDebug("UoW is not enabled or add delay, UoW is not used will affect 100% delivery of the message");
         }
 
         return services;

src/Isolation/Masa.Contrib.Isolation.Environment/EnvironmentContext.cs

@@ -0,0 +1,8 @@
+namespace Masa.Contrib.Isolation.Environment;
+
+public class EnvironmentContext : IEnvironmentContext, IEnvironmentSetter
+{
+    public string CurrentEnvironment { get; private set; } = string.Empty;
+
+    public void SetEnvironment(string environment) => CurrentEnvironment = environment;
+}

src/Isolation/Masa.Contrib.Isolation.Environment/EnvironmentSaveChangesFilter.cs

@@ -0,0 +1,23 @@
+namespace Masa.Contrib.Isolation.Environment;
+
+public class EnvironmentSaveChangesFilter: ISaveChangesFilter
+{
+    private readonly IEnvironmentContext _environmentContext;
+
+    public EnvironmentSaveChangesFilter(IEnvironmentContext environmentContext)
+    {
+        _environmentContext = environmentContext;
+    }
+
+    public void OnExecuting(ChangeTracker changeTracker)
+    {
+        changeTracker.DetectChanges();
+        foreach (var entity in changeTracker.Entries().Where(entry => entry.State == EntityState.Added))
+        {
+            if (entity.Entity is IMultiEnvironment)
+            {
+                entity.CurrentValues[nameof(IMultiEnvironment.Environment)] = _environmentContext.CurrentEnvironment;
+            }
+        }
+    }
+}

src/Isolation/Masa.Contrib.Isolation.Environment/IsolationBuilderExtensions.cs

@@ -0,0 +1,13 @@
+namespace Masa.Contrib.Isolation.Environment;
+
+public static class IsolationBuilderExtensions
+{
+    public static IIsolationBuilder UseEnvironment(this IIsolationBuilder isolationBuilder)
+    {
+        isolationBuilder.Services.TryAddEnumerable(new ServiceDescriptor(typeof(ISaveChangesFilter), typeof(EnvironmentSaveChangesFilter), ServiceLifetime.Scoped));
+        isolationBuilder.Services.TryAddScoped<EnvironmentContext>();
+        isolationBuilder.Services.TryAddScoped(typeof(IEnvironmentContext), serviceProvider => serviceProvider.GetRequiredService<EnvironmentContext>());
+        isolationBuilder.Services.TryAddScoped(typeof(IEnvironmentSetter), serviceProvider => serviceProvider.GetRequiredService<EnvironmentContext>());
+        return isolationBuilder;
+    }
+}

src/Isolation/Masa.Contrib.Isolation.Environment/Masa.Contrib.Isolation.Environment.csproj

@@ -0,0 +1,17 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net6.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\BuildingBlocks\MASA.BuildingBlocks\src\Isolation\Masa.BuildingBlocks.Isolation\Masa.BuildingBlocks.Isolation.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Masa.Utils.Data.EntityFrameworkCore" Version="0.4.0-preview.2" />
+  </ItemGroup>
+
+</Project>

src/Isolation/Masa.Contrib.Isolation.Environment/README.md

@@ -0,0 +1,88 @@
+[中](README.zh-CN.md) | EN
+
+## Masa.Contrib.Isolation.Environment
+
+Example：
+
+```C#
+Install-Package Masa.Contrib.Isolation.UoW.EF
+Install-Package Masa.Contrib.Isolation.Environment
+Install-Package Masa.Utils.Data.EntityFrameworkCore.SqlServer
+```
+
+1. 配置appsettings.json
+``` appsettings.json
+{
+  "ConnectionStrings": {
+    "DefaultConnection": "server=localhost;uid=sa;pwd=P@ssw0rd;database=identity;",
+    "Isolations": [
+      {
+        "Environment": "development",
+        "ConnectionString": "server=localhost,1674;uid=sa;pwd=P@ssw0rd;database=identity;"
+      },
+      {
+        "Environment": "staging",
+        "ConnectionString": "server=localhost,1672;uid=sa;pwd=P@ssw0rd;database=identity;"
+      }
+    ]
+  }
+}
+```
+* 1.1 When the current environment is development: database address: server=localhost,1674;uid=sa;pwd=P@ssw0rd;database=identity;
+* 1.2 When the current environment is staging: database address: server=localhost,1672;uid=sa;pwd=P@ssw0rd;database=identity;
+* 1.3 When the current environment is another environment: database address: server=localhost;uid=sa;pwd=P@ssw0rd;database=identity;
+
+2. Using Isolation.UoW.EF
+```` C#
+builder.Services.AddEventBus(eventBusBuilder =>
+{
+    eventBusBuilder.UseIsolationUoW<CustomDbContext>(
+        dbOptions => dbOptions.UseSqlServer(),
+        isolationBuilder => isolationBuilder.UseEnvironment());
+});
+````
+
+3. DbContext needs to inherit IsolationDbContext
+
+```` C#
+public class CustomDbContext : IsolationDbContext
+{
+    public CustomDbContext(MasaDbContextOptions<CustomDbContext> options) : base(options)
+    {
+    }
+}
+````
+
+4. The class corresponding to the isolated table needs to implement IMultiEnvironment
+
+You can also choose not to implement IMultiEnvironment when using physical isolation
+
+##### Summarize
+
+* How is the environment resolved in the controller or MinimalAPI?
+    * The environment provides one parser by default, and the execution order is: EnvironmentVariablesParserProvider (gets the parameters in the system environment variables, the parameters of the default environment isolation: ASPNETCORE_ENVIRONMENT)
+* If the parser fails to resolve the environment, what is the last database used?
+    * If the parsing environment fails, return DefaultConnection directly
+* How to change the default environment parameter name
+
+```` C#
+builder.Services.AddEventBus(eventBusBuilder =>
+{
+    eventBusBuilder.UseIsolationUoW<CustomDbContext>(
+        dbOptions => dbOptions.UseSqlServer(),
+        isolationBuilder => isolationBuilder.SetEnvironmentKey("env").UseEnvironment());// Use environment isolation
+});
+````
+* How to change the parser
+
+```` C#
+builder.Services.AddEventBus(eventBusBuilder =>
+{
+    eventBusBuilder.UseIsolationUoW<CustomDbContext>(
+        dbOptions => dbOptions.UseSqlServer(),
+        isolationBuilder => isolationBuilder.SetEnvironmentParsers(new List<IEnvironmentParserProvider>()
+        {
+            new EnvironmentVariablesParserProvider() //By default, environment information in environment isolation is obtained from system environment variables
+        }).UseEnvironment());// Use environment isolation
+});
+````