小标
2019-04-08
来源 :
阅读 2768
评论 0
摘要:本文主要向大家介绍了C#编程之基于.net standard 的动态编译实现,通过具体的内容向大家展示,希望对大家学习C#编程有所帮助。
本文主要向大家介绍了C#编程之基于.net standard 的动态编译实现,通过具体的内容向大家展示,希望对大家学习C#编程有所帮助。

在尝试了基于 Emit 中间语言后,最终决定使用生成代码片段然后动态编译的模式实现。
背景:
其一在前文中,我们通过框架实现了微服务面向使用者的透明调用,但是需要为每个服务写一个客户端代理,显得异常繁琐,其二项目中前端站点使用了传统的.Net Framework 框架,后端微服务我们使用了.Net Core 框架改造,短时间将前端站点调整成 .Net Core 框架亦不现实,为了能同时支持这两种框架。如何 .Net Standard 框架来自动创建微服务的客户端代理成为我们必须解决的问题。
问题转化
我们在回头简单看一下我们现在期望的微服务客户端代理长的样子:
通过上面分析,我们只需要将服务接口中的每个方法,判断是否有返回值,如果有返回值调用Invoke
首先想到是通过中间语言 IL 的 Emit 实现,但无奈这个使用起来实在是太不友好了, 几经折腾最终还是选择放弃了,后又想到其实可以通过动态生成这个代码片段,动态编译后加载到系统程序集中,应该就可以了。于是在这个方向的指引下,我们尝试着去一步步实现这个问题。
解决方案
如何生成这个代码片段? 通过上面的分析,我们知道只需要将接口反射获取其中的公共方法,并将接口的每个方法签名原样复制,在根据接口方法是否有返回值分别调用RemoteServiceProxy基类中相关方法即可,不过需要特殊注意的泛型方法翻译,以下是生成这个代码片段的参考实现.
寻找出为服务接口程序集文件,并处理每个文件
private static StringBuilder CreateApiProxyCode()
{ var path = GetBinPath(); var dir = new DirectoryInfo(path); //获取项目中微服务接口文件
var files = dir.GetFiles(""XZL*.Api.dll""); var codeStringBuilder = new StringBuilder(1024); //添加必要的using codeStringBuilder
.AppendLine(""using System;"")
.AppendLine(""using System.Collections.Generic;"")
.AppendLine(""using System.Text;"")
.AppendLine(""using XZL.Infrastructure.ApiService;"")
.AppendLine(""using XZL.Infrastructure.Defines;"")
.AppendLine(""using XZL.Model;"")
.AppendLine(""namespace XZL.ApiClientProxy"")
.AppendLine(""{""); //namespace begin //处理每个文件中的接口信息
foreach (var file in files)
{
CreateApiProxyCodeFromFile(codeStringBuilder, file);
}
codeStringBuilder.AppendLine(""}""); //namespace end
return codeStringBuilder;
}处理每个文件中的接口类型,并将每个程序集的依赖程序集找出来,方便后面动态编译
private static void CreateApiProxyCodeFromFile(StringBuilder fileCodeBuilder, FileInfo file)
{ try
{
Assembly apiAssembly = Assembly.Load(file.Name.Substring(0, file.Name.Length - 4)); var types = apiAssembly
.GetTypes()
.Where(c => c.IsInterface && c.IsPublic)
.ToList(); var apiSvcType = typeof(IApiService); bool isNeed = false; foreach (Type type in types)
{ //找出期望的接口类型
if (!apiSvcType.IsAssignableFrom(type))
{ continue;
} //找出接口的所有方法
var methods = type.GetMethods(BindingFlags.Public
| BindingFlags.FlattenHierarchy
| BindingFlags.Instance); if (!methods.Any())
{ continue;
} //定义代理类名,以及实现接口和继承RemoteServiceProxy
fileCodeBuilder.AppendLine($""public class {type.FullName.Replace(""."", ""_"")}Proxy :"" +
$""RemoteServiceProxy, {type.FullName}"")
.AppendLine(""{""); //class begin //处理每个方法
foreach (var mth in methods)
{
CreateApiProxyCodeFromMethod(fileCodeBuilder, type, mth);
}
fileCodeBuilder.AppendLine(""}""); //class end
isNeed = true;
} if (isNeed)
{ var apiRefAsms = apiAssembly.GetReferencedAssemblies();
refAssemblyList.Add(apiAssembly.GetName());
refAssemblyList.AddRange(apiRefAsms);
}
} catch
{
}
}处理接口中的每个方法
private static void CreateApiProxyCodeFromMethod(
StringBuilder fileCodeBuilder,
Type type,
MethodInfo mth)
{ var isMthReturn = !mth.ReturnType.Equals(typeof(void));
fileCodeBuilder.Append(""public ""); //添加返回值
if (isMthReturn)
{
fileCodeBuilder.Append(GetFriendlyTypeName(mth.ReturnType)).Append("" "");
} else
{
fileCodeBuilder.Append("" void "");
} //方法参数开始
fileCodeBuilder.Append(mth.Name).Append(""("");
var mthParams = mth.GetParameters(); if (mthParams.Any())
{ var mthparaList = new List(); foreach (var p in mthParams)
{
mthparaList.Add(GetFriendlyTypeName(p.ParameterType) + "" "" + p.Name);
}
fileCodeBuilder.Append(string.Join("","", mthparaList));
} //方法参数结束
fileCodeBuilder.Append("")""); //方法体开始
fileCodeBuilder.AppendLine(""{"");
if (isMthReturn)
{ //返回值
fileCodeBuilder.Append(""return Invoke"");
} else
{
fileCodeBuilder.Append("" InvokeWithoutReturn"");
} //拼接接口名及方法名
fileCodeBuilder.Append($""(\""{type.FullName}\"",\""{mth.Name}\""""); //方法本身参数
if (mthParams.Any())
{
fileCodeBuilder.Append("","").Append(string.Join("","", mthParams.Select(t => t.Name)));
}
fileCodeBuilder.Append("");""); //方法体结束
fileCodeBuilder.AppendLine(""}"");
}获取泛型类型字符串
private static string GetFriendlyTypeName(Type type)
{ if (!type.IsGenericType)
{ return type.FullName;
} string friendlyName = type.Name; int iBacktick = friendlyName.IndexOf('`'); if (iBacktick > 0)
{
friendlyName = friendlyName.Remove(iBacktick);
}
friendlyName += ""<"";
Type[] typeParameters = type.GetGenericArguments(); for (int i = 0; i < typeParameters.Length; ++i)
{ string typeParamName = GetFriendlyTypeName(typeParameters[i]);
friendlyName += (i == 0 ? typeParamName : "","" + typeParamName);
}
friendlyName += "">""; return friendlyName;
}如何添加依赖
既然是要编译源码,那么源码中的依赖必不可少,在上一步中我们已经将每个程序集的依赖一并找出,接下来我们将这些依赖全部整理出来
//缓存程序集依赖
var references = new List();
var refAsmFiles = new List(); //系统依赖
var sysRefLocation = typeof(Enumerable).GetTypeInfo().Assembly.Location;
refAsmFiles.Add(sysRefLocation); //refAsmFiles原本缓存的程序集依赖
refAsmFiles.Add(typeof(object).GetTypeInfo().Assembly.Location);
refAsmFiles.AddRange(refAssemblyList.Select(t => Assembly.Load(t).Location).Distinct().ToList()); //传统.NetFramework 需要添加mscorlib.dll
var coreDir = Directory.GetParent(sysRefLocation); var mscorlibFile = coreDir.FullName + Path.DirectorySeparatorChar + ""mscorlib.dll""; if (File.Exists(mscorlibFile))
{
references.Add(MetadataReference.CreateFromFile(mscorlibFile));
} var apiAsms = refAsmFiles.Select(t => MetadataReference.CreateFromFile(t)).ToList();
references.AddRange(apiAsms); //当前程序集依赖
var thisAssembly = Assembly.GetEntryAssembly(); if (thisAssembly != null)
{ var referencedAssemblies = thisAssembly.GetReferencedAssemblies(); foreach (var referencedAssembly in referencedAssemblies)
{ var loadedAssembly = Assembly.Load(referencedAssembly);
references.Add(MetadataReference.CreateFromFile(loadedAssembly.Location));
}
}编译
有了代码片段, 也有了编译程序集依赖, 接下来就是最重要的编译了.
//定义编译后文件名var path = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, ""Proxy"");if (!Directory.Exists(path))
{
Directory.CreateDirectory(path);
}var apiRemoteProxyDllFile = Path.Combine(path,
apiRemoteAsmName + DateTime.Now.ToString(""yyyyMMddHHmmssfff"") + "".dll"");var tree = SyntaxFactory.ParseSyntaxTree(codeBuilder.ToString());var compilation = CSharpCompilation.Create(apiRemoteAsmName)
.WithOptions(new CSharpCompilationOptions(OutputKind.DynamicallyLinkedLibrary))
.AddReferences(references)
.AddSyntaxTrees(tree);//执行编译EmitResult compilationResult = compilation.Emit(apiRemoteProxyDllFile);if (compilationResult.Success)
{ // Load the assembly
apiRemoteAsm = Assembly.LoadFrom(apiRemoteProxyDllFile);
}else{ foreach (Diagnostic codeIssue in compilationResult.Diagnostics)
{ string issue = $""ID: {codeIssue.Id}, Message: {codeIssue.GetMessage()},"" +
$"" Location: { codeIssue.Location.GetLineSpan()}, "" +
$""Severity: { codeIssue.Severity}"";
AppRuntimes.Instance.Loger.Error(""自动编译代码出现异常,"" + issue);
}
}结语
在经过以上处理后,虽算不上完美,但顺利的实现了我们期望的样子,在之前的GetService中,当发现属于远程服务的时候,只需要类似如下形式返回代理对象即可。同时为增加调用更加顺畅,我们将此编译的时机定在了发生在程序启动的时候,ps 当然或许还有一些其他更合适的时机.
static ConcurrentDictionary svcInstance = new ConcurrentDictionary();var typeName = ""XZL.ApiClientProxy."" + typeof(TService).FullName.Replace(""."", ""_"") + ""Proxy"";object obj = null;if (svcInstance.TryGetValue(typeName, out obj) && obj != null)
{ return (TService)obj;
}try{
obj = (TService)apiRemoteAsm.CreateInstance(typeName);
svcInstance.TryAdd(typeName, obj);
}catch{ throw new ICVIPException($""未找到 {typeof(TService).FullName} 的有效代理"");
}return (TService)obj;本文由职坐标整理并发布,希望对同学们有所帮助。了解更多详情请关注职坐标编程语言C#.NET频道!
喜欢 | 1
不喜欢 | 0
您输入的评论内容中包含违禁敏感词
我知道了

请输入正确的手机号码
请输入正确的验证码
您今天的短信下发次数太多了,明天再试试吧!
我们会在第一时间安排职业规划师联系您!
您也可以联系我们的职业规划师咨询:
版权所有 职坐标-一站式AI+学习就业服务平台 沪ICP备13042190号-4
上海海同信息科技有限公司 Copyright ©2015 www.zhizuobiao.com,All Rights Reserved.
沪公网安备 31011502005948号