WebServices 动态调用 接口自动创建 EMIT

?

通过使用 System.Reflection.Emit 动态创建代码，实现从WebService对象上抽离接口。从而方便实用。
using System; using System.Reflection; using System.IO; using System.Web; using System.CodeDom; using System.CodeDom.Compiler; using System.Collections.Generic; using System.Text; using System.Net; using System.Web.Services; using System.Web.Services.Description; using System.Web.Services.Protocols; using System.Reflection.Emit; using System.Net.Security; using System.Security.Cryptography.X509Certificates; namespace GDC { public static class DynWebService { public static T GetWebServiceInterface<T>(string wsdlURL,string className) where T : class { object obj = GeObject(wsdlURL,className); return GetWrapper<T>(obj); } static bool CheckValidationResult(object sender,X509Certificate certificate,X509Chain chain,SslPolicyErrors sslPolicyErrors) { return true; } public static object GeObject(string wsdlURL,string className) { System.Net.ServicePointManager.ServerCertificateValidationCallback = new System.Net.Security.RemoteCertificateValidationCallback(CheckValidationResult); WebClient aWc = new WebClient(); Stream aStream = aWc.OpenRead(wsdlURL); ServiceDescription aSD = ServiceDescription.Read(aStream); ServiceDescriptionImporter importer = new ServiceDescriptionImporter(); importer.ProtocolName = "Soap"; importer.Style = ServiceDescriptionImportStyle.Client; importer.CodeGenerationOptions = System.Xml.Serialization.CodeGenerationOptions.GenerateProperties | System.Xml.Serialization.CodeGenerationOptions.GenerateNewAsync; importer.AddServiceDescription(aSD,null,null); CodeNamespace aNamespace = new CodeNamespace(); CodeCompileUnit unit = new CodeCompileUnit(); unit.Namespaces.Add(aNamespace); ServiceDescriptionImportWarnings aW = importer.Import(aNamespace,unit); CodeDomProvider provider = CodeDomProvider.CreateProvider("CSharp"); CompilerParameters para = new CompilerParameters(); para.GenerateExecutable = false; para.GenerateInMemory = true; para.ReferencedAssemblies.Add("System.dll"); para.ReferencedAssemblies.Add("System.XML.dll"); para.ReferencedAssemblies.Add("System.Web.Services.dll"); para.ReferencedAssemblies.Add("System.Data.dll"); CompilerResults result = provider.CompileAssemblyFromDom(para,unit); if (!result.Errors.HasErrors) { Assembly asm = result.CompiledAssembly; Type t = asm.GetType(className,true,true); object obj = Activator.CreateInstance(t); ((System.Web.Services.Protocols.WebClientProtocol)(obj)).Url = wsdlURL;//预防端口影射导致的端口不一致。 return obj; } else throw new Exception("WebService 动态编译错误。"); } public static T GetWrapper<T>(object obj) where T : class { if (obj == null) return null; return GetWrapperCore<T>(obj) as T; } private static T GetWrapperCore<T>(object obj) where T : class { Type t = typeof(T); if (!t.IsInterface) return obj as T; Type wrapperType = new WrapperHelper<T>(obj).GetWrapperType(); if (wrapperType == null) return null; object result = Activator.CreateInstance(wrapperType,obj); return result as T; } } internal sealed class InterfaceNotImplementedException : Exception { public InterfaceNotImplementedException() { } } internal class WrapperHelper<T> where T : class { #region Consts private const TypeAttributes TYPE_ATTRIBUTES = TypeAttributes.Public | TypeAttributes.Sealed | TypeAttributes.Serializable; private const FieldAttributes FIELD_ATTRIBUTES = FieldAttributes.Private; private const MethodAttributes METHOD_ATTRIBUTES = MethodAttributes.Public | MethodAttributes.NewSlot | MethodAttributes.Virtual | MethodAttributes.Final | MethodAttributes.HideBySig; #endregion #region Fields private object _obj; private Type _objType; private Type _interfaceType; private TypeBuilder _type; private FieldBuilder _field; #endregion #region Ctors public WrapperHelper(object obj) { _obj = obj; _objType = obj.GetType(); _interfaceType = typeof(T); } #endregion #region Private Methods private void PrepareType() { AssemblyName myAssemblyName = new AssemblyName(); myAssemblyName.Name = RandomName; AssemblyBuilder myAssembly = AppDomain.CurrentDomain.DefineDynamicAssembly( myAssemblyName,AssemblyBuilderAccess.RunAndSave); ModuleBuilder myModule = myAssembly.DefineDynamicModule(RandomName,true); _type = myModule.DefineType(RandomName,TYPE_ATTRIBUTES,typeof(object),new Type[] { _interfaceType }); } private void PrepareField() { _field = _type.DefineField("_source",_interfaceType,FIELD_ATTRIBUTES); } private void PrepareCtor() { Type[] myConstructorArgs = new Type[] { _objType }; ConstructorBuilder myConstructor = _type.DefineConstructor( MethodAttributes.Public,CallingConventions.Standard,myConstructorArgs); ILGenerator myConstructorIL = myConstructor.GetILGenerator(); myConstructorIL.Emit(OpCodes.Ldarg_0); ConstructorInfo mySuperConstructor = typeof(object).GetConstructor(new Type[0]); myConstructorIL.Emit(OpCodes.Call,mySuperConstructor); myConstructorIL.Emit(OpCodes.Ldarg_0); myConstructorIL.Emit(OpCodes.Ldarg_1); myConstructorIL.Emit(OpCodes.Stfld,_field); myConstructorIL.Emit(OpCodes.Ret); } private void PrepareMethods() { foreach (MethodInfo mi in _interfaceType.GetMethods()) GenMethod(mi); } private MethodBuilder GenMethod(MethodInfo mi) { MethodBuilder result; Type[] paramTypes; ILGenerator ilGen; MethodInfo implMi = FindImplementedMethod(mi); paramTypes = GetParameterTypes(mi.GetParameters()); result = _type.DefineMethod(mi.Name,METHOD_ATTRIBUTES,mi.ReturnType,paramTypes); ilGen = result.GetILGenerator(); if (mi.ReturnType != typeof(void)) ilGen.DeclareLocal(_objType); ilGen.Emit(OpCodes.Ldarg_0); ilGen.Emit(OpCodes.Ldfld,_field); for (int i = 0; i < paramTypes.Length; i++) { if (i == 0) ilGen.Emit(OpCodes.Ldarg_1); else if (i == 1) ilGen.Emit(OpCodes.Ldarg_2); else if (i == 2) ilGen.Emit(OpCodes.Ldarg_3); else ilGen.Emit(OpCodes.Ldarg_S,i + 1); } ilGen.Emit(OpCodes.Callvirt,implMi); if (mi.ReturnType != typeof(void)) { ilGen.Emit(OpCodes.Stloc_0); ilGen.Emit(OpCodes.Ldloc_0); } ilGen.Emit(OpCodes.Ret); return result; } private void PrepareProperties() { foreach (PropertyInfo pi in _interfaceType.GetProperties()) GenProperty(pi); } private void GenProperty(PropertyInfo pi) { Type[] paramTypes = GetParameterTypes(pi.GetIndexParameters()); MethodBuilder mb; PropertyBuilder pb = _type.DefineProperty( pi.Name,pi.Attributes,pi.PropertyType,paramTypes); if (pi.CanRead) { mb = GenMethod(pi.GetGetMethod()); pb.SetGetMethod(mb); } if (pi.CanWrite) { mb = GenMethod(pi.GetSetMethod()); pb.SetSetMethod(mb); } } private void PrepareEvents() { foreach (EventInfo ei in _interfaceType.GetEvents()) GenEvent(ei); } private void GenEvent(EventInfo pi) { MethodBuilder mb; EventBuilder eb = _type.DefineEvent( pi.Name,pi.EventHandlerType); mb = GenMethod(pi.GetAddMethod()); eb.SetAddOnMethod(mb); mb = GenMethod(pi.GetRemoveMethod()); eb.SetRemoveOnMethod(mb); } private MethodInfo FindImplementedMethod(MethodInfo mi) { MethodInfo result; result = _objType.GetMethod(mi.Name,BindingFlags.Instance | BindingFlags.Public,GetParameterTypes(mi.GetParameters()),null); if (result == null || result.ReturnType != mi.ReturnType) throw new InterfaceNotImplementedException(); return result; } #endregion #region Public Members public Type GetWrapperType() { try { PrepareType(); PrepareField(); PrepareCtor(); PrepareMethods(); PrepareProperties(); PrepareEvents(); } catch (InterfaceNotImplementedException) { return null; } return _type.CreateType(); } #endregion #region Static Members private static string RandomName { get { return GetRandomName(10); } } private static string GetRandomName(int count) { Random r = new Random(); byte[] b = new byte[count]; r.NextBytes(b); string result = Convert.ToBase64String(b); result = result.Replace('=','_').Replace('/','_').Replace('+','_'); return result; } private static Type[] GetParameterTypes(ParameterInfo[] pis) { Type[] result = new Type[pis.Length]; for (int i = 0; i < pis.Length; i++) result[i] = pis[i].ParameterType; return result; } #endregion } }

?

实际使用代码

??????????? string wsdl = @"http://localhost/FSQS_WebService/Service.asmx?WSDL ";
??????????? ITableWritor obj = DynWebService.GetWebServiceInterface<ITableWritor>(wsdl,"Service");
??????????? string info = obj.TestConnection();

?

其中ITableWritor?是如下接口

?

?public interface ITableWritor
??? {
??????? void UpdataTable(string clientID,string targetTableName,string srcName,DataTable sourceContent);
??????? string UpdataFile(string clientID,string srcname,string bufferFilePath,int type);
??????? string TestConnection();
??? }

?

其中"Service" 是asmx文件中对应的类的类名。类"Service"上可以显示实现ITableWritor接口。也可以仅仅包含接口所有的同名同参数，同返回值得的函数、属性。（事件应该是无效的。呵呵）