.Net core 的熱插拔機(jī)制的深入探索及卸載問題求救指南

{
 "runtimeTarget": {
 "name": ".NETCoreApp,Version=v3.1",
 "signature": ""
 },
 "compilationOptions": {},
 "targets": {
 ".NETCoreApp,Version=v3.1": {
 "PluginSample/1.0.0": {
 "dependencies": {
 "Microsoft.Extensions.Hosting.Abstractions": "5.0.0-rc.2.20475.5"
 },
 "runtime": {
 "PluginSample.dll": {}
 }
 },
 "Microsoft.Extensions.Configuration.Abstractions/5.0.0-rc.2.20475.5": {
 "dependencies": {
 "Microsoft.Extensions.Primitives": "5.0.0-rc.2.20475.5"
 },
 "runtime": {
 "lib/netstandard2.0/Microsoft.Extensions.Configuration.Abstractions.dll": {
 "assemblyVersion": "5.0.0.0",
 "fileVersion": "5.0.20.47505"
 }
 }
 ...

using (var dependencyFileStream = File.OpenRead("Sample.deps.json"))
{
 using (DependencyContextJsonReader dependencyContextJsonReader = new DependencyContextJsonReader())
 {
 //得到對(duì)應(yīng)的實(shí)體文件
 var dependencyContext = 
 dependencyContextJsonReader.Read(dependencyFileStream);
 //定義的運(yùn)行環(huán)境,沒有,則為全平臺(tái)運(yùn)行.
 string currentRuntimeIdentifier= dependencyContext.Target.Runtime;
 //運(yùn)行時(shí)所需要的dll文件
 var assemblyNames= dependencyContext.RuntimeLibraries;
 }
}

{
 "runtimes": {
 "win-arm64": {
 "#import": [
 "win"
 ]
 },
 "win-arm64-aot": {
 "#import": [
 "win-aot",
 "win-arm64"
 ]
 },
 "win-x64": {
 "#import": [
 "win"
 ]
 },
 "win-x64-aot": {
 "#import": [
 "win-aot",
 "win-x64"
 ]
 },
}

win7-x64 win7-x86
 | \ / |
 | win7 |
 | | |
win-x64 | win-x86
 \ | /
 win
 |
 any

public class PluginLoadContext : AssemblyLoadContext
{
 private AssemblyDependencyResolver _resolver;
 public PluginLoadContext(string pluginFolder, params string[] commonAssemblyFolders) : base(isCollectible: true)
 {
 this.ResolvingUnmanagedDll += PluginLoadContext_ResolvingUnmanagedDll;
 this.Resolving += PluginLoadContext_Resolving;
 //第1步,解析des.json文件,并調(diào)用Load和LoadUnmanagedDll函數(shù)
 _resolver = new AssemblyDependencyResolver(pluginFolder);
 //第6步,通過第4,5步,解析仍失敗的dll會(huì)自動(dòng)嘗試調(diào)用主程序中的程序集,
 //如果失敗,則直接拋出程序集無法加載的錯(cuò)誤
 }
 private Assembly PluginLoadContext_Resolving(AssemblyLoadContext assemblyLoadContext, AssemblyName assemblyName)
 {
 //第4步,Load函數(shù)加載程序集失敗后,執(zhí)行的事件
 }
 private IntPtr PluginLoadContext_ResolvingUnmanagedDll(Assembly assembly, string unmanagedDllName)
 {
 //第5步,LoadUnmanagedDll加載native dll失敗后執(zhí)行的事件
 }
 protected override Assembly Load(AssemblyName assemblyName)
 {
 //第2步,先執(zhí)行程序集的加載函數(shù)
 }
 protected override IntPtr LoadUnmanagedDll(string unmanagedDllName)
 {
 //第3步,先執(zhí)行的native dll加載邏輯
 }
}

class PluginLoadContext : AssemblyLoadContext
{
 private AssemblyDependencyResolver _resolver;

 public PluginLoadContext(string pluginPath)
 {
 _resolver = new AssemblyDependencyResolver(pluginPath);
 }

 protected override Assembly Load(AssemblyName assemblyName)
 {
 string assemblyPath = _resolver.ResolveAssemblyToPath(assemblyName);
 if (assemblyPath != null)
 {
 //加載程序集
 return LoadFromAssemblyPath(assemblyPath);
 }
 //返回null,則直接加載主項(xiàng)目程序集
 return null;
 }

 protected override IntPtr LoadUnmanagedDll(string unmanagedDllName)
 {
 string libraryPath = _resolver.ResolveUnmanagedDllToPath(unmanagedDllName);
 if (libraryPath != null)
 {
 //加載native dll文件
 return LoadUnmanagedDllFromPath(libraryPath);
 }
 //返回IntPtr.Zero,即null指針.將會(huì)加載主項(xiàng)中runtimes文件夾下的dll
 return IntPtr.Zero;
 }
}

namespace PluginSample
{
 public class SimpleService
 {
 public void Run(string name)
 {
 Console.WriteLine($"Hello World!");
 }
 }
}

namespace Test
{
 public class PluginLoader
 {
 pubilc AssemblyLoadContext assemblyLoadContext;
 public Assembly assembly;
 public Type type;
 public MethodInfo method;
 public void Load()
 {
 assemblyLoadContext = new PluginLoadContext("插件文件夾");
 assembly = alc.Load(new AssemblyName("PluginSample"));
 type = assembly.GetType("PluginSample.SimpleService");
 method=type.GetMethod()
 }
 }
}

public void Load(out WeakReference weakReference)
 {
 var assemblyLoadContext = new PluginLoadContext("插件文件夾");
 weakReference = new WeakReference(pluginLoadContext, true);
 assemblyLoadContext.UnLoad();
 }
 public void Check()
 {
 WeakReference weakReference=null;
 Load(out weakReference);
 //一般第二次,IsAlive就會(huì)變?yōu)镕alse,即AssemblyLoadContext卸載失敗.
 for (int i = 0; weakReference.IsAlive  (i  10); i++)
 {
 GC.Collect();
 GC.WaitForPendingFinalizers();
 }
 }

public class SimpleService
{
 //同步執(zhí)行,插件卸載成功
 public void Run(string name)
 {
 Console.WriteLine($"Hello {name}!");
 }
 //異步執(zhí)行,卸載成功
 public Task RunAsync(string name)
 {
 Console.WriteLine($"Hello {name}!");
 return Task.CompletedTask;
 }
 //異步執(zhí)行,卸載成功
 public Task RunTask(string name)
 {
 return Task.Run(() => {
 Console.WriteLine($"Hello {name}!");
 });
 }
 //異步執(zhí)行,卸載成功
 public Task RunWaitTask(string name)
 {
 return Task.Run( async ()=> {
 while (true)
 {
 if (CancellationTokenSource.IsCancellationRequested)
 {
  break;
 }
 await Task.Delay(1000);
 Console.WriteLine($"Hello {name}!");
 }
 });
 }
 //異步執(zhí)行,卸載成功
 public Task RunWaitTaskForCancel(string name, CancellationToken cancellation)
 {
 return Task.Run(async () => {
 while (true)
 {
 if (cancellation.IsCancellationRequested)
 {
  break;
 }
 await Task.Delay(1000);
 Console.WriteLine($"Hello {name}!");
 }
 });
 }
 //異步執(zhí)行,卸載失敗
 public async Task RunWait(string name)
 {
 while (true)
 {
 if (CancellationTokenSource.IsCancellationRequested)
 {
 break;
 }
 await Task.Delay(1000);
 Console.WriteLine($"Hello {name}!");
 }

 }
 //異步執(zhí)行,卸載失敗
 public Task RunWaitNewTask(string name)
 {
 return Task.Factory.StartNew(async ()=> {
 while (true)
 {
 if (CancellationTokenSource.IsCancellationRequested)
 {
  break;
 }
 await Task.Delay(1000);
 Console.WriteLine($"Hello {name}!");
 }
 },TaskCreationOptions.DenyChildAttach);
 }
}