程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> .NET網頁編程 >> ASP.NET >> 關於ASP.NET >> .NET的動態編譯與WS服務調用詳解

.NET的動態編譯與WS服務調用詳解

編輯:關於ASP.NET
    這篇文章介紹了.NET的動態編譯與WS服務調用詳解,有需要的朋友可以參考一下,希望對你有所幫助  

        動態編譯與WS服務,有關系麼?今天就亂彈一番,如何使用動態編譯動態生成WS服務調用的代理類,然後通過這個代理類調用WS服務。
        首先,動態編譯這玩意在.NET裡面是非常簡單的,實際上只涉及到兩個類型:CodeDomProvider以及CompilerParameters他們都位於System.CodeDom.Compiler命名空間。
        以下代碼可將源碼動態編譯為一個程序集:
    動態編譯

    復制代碼 代碼如下:
    CodeDomProvider provider = CodeDomProvider.CreateProvider("CSharp");
    CompilerParameters codeParameters = new CompilerParameters();
    codeParameters.GenerateExecutable = false; //編譯為dll,如果為true則編譯為exe
    codeParameters.GenerateInMemory = true; //編譯後的程序集保存到內存中
    StringBuilder code = new StringBuilder();
    //此處構造源代碼
    CompilerResults results = provider.CompileAssemblyFromSource(codeParameters, code.ToString());
    Assembly assembly = null; //動態編譯生成的程序集
    if (!results.Errors.HasErrors)
    {
        assembly = results.CompiledAssembly;
    }


        獲得assembly後,隨後我們即可以通過反射獲取程序集裡面的類型,然後實例化,調用類型方法…
        不過在此之前,我們得構造WS服務的代理類,它是什麼樣子的呢?我們使用WCF框架,創建服務代理類也是十分簡單的,常見的代理類結構如下:
    服務調用代理類

    復制代碼 代碼如下:
    [ServiceContract(Namespace="http://www.jb51.net/")]
    public interface TestService
    {
        [OperationContract(Action = "http://www.jb51.net/HelloWorld", ReplyAction = "http://www.jb51.net/HelloWorldResponse")]
        string HelloWorld();
    }
    public class TestServiceClient : ClientBase<TestService>, TestService
    {
        public TestServiceClient(Binding binding, EndpointAddress address) :
            base(binding, address)
        {
        }
        public string HelloWorld()
        {
            return base.Channel.HelloWorld();
        }
    }


        所以,我們要動態構造出代理類源碼,應該知道服務的命名空間、服務方法的Action地址、ReplyAction地址,當然還有服務方法的名稱,返回類 型,參數列表。這裡,我們省略掉服務方法的參數列表,構造代理類,實際上就是一個字符串組裝的問題,先創建一個類型,用於保存構造代理類所要用到的參數:

    服務代理類構造參數

    復制代碼 代碼如下:
    public class WebServiceParamaters
    {
        public string address;
        public string Address
        {
            get { return address; }
            set
            {
                address = value;
            }
        }
        private string serviceNamespace;
        public string ServiceNamespace
        {
            get { return serviceNamespace; }
            set
            {
                serviceNamespace = value;
            }
        }
       private string methodAction;
        public string MethodAction
        {
            get { return methodAction; }
            set
            {
                methodAction = value;
            }
        }
        private string methodReplyAction;
        public string MethodReplyAction
        {
            get { return methodReplyAction; }
            set
            {
                methodReplyAction = value;
            }
        }
        private string methodName;
        public string MethodName
        {
            get { return methodName; }
            set
            {
                methodName = value;
            }
        }
        private string returnType;
        public string ReturnType
        {
            get { return returnType; }
            set
            {
                returnType = value;
            }
        }
    }


     好,現在我們只需要構造出代理類源碼,然後動態編譯出代理類的程序集,最後通過反射調用服務方法:
    WebServiceProxyCreator

    復制代碼 代碼如下:
    public class WebServiceProxyCreator
    {
        public Object WebServiceCaller(WebServiceParamaters parameters)
        {
            CodeDomProvider provider = CodeDomProvider.CreateProvider("CSharp");
            CompilerParameters codeParameters = new CompilerParameters();
            codeParameters.GenerateExecutable = false;
            codeParameters.GenerateInMemory = true;
            StringBuilder code = new StringBuilder();
            CreateProxyCode(code, parameters);
    codeParameters.ReferencedAssemblies.Add("System.dll");
    codeParameters.ReferencedAssemblies.Add("System.ServiceModel.dll");
            CompilerResults results = provider.CompileAssemblyFromSource(codeParameters, code.ToString());
            Assembly assembly = null;
            if (!results.Errors.HasErrors)
            {
                assembly = results.CompiledAssembly;
            }
            Type clientType = assembly.GetType("RuntimeServiceClient");
           ConstructorInfo ci = clientType.GetConstructor(new Type[] { typeof(Binding), typeof(EndpointAddress) });
            BasicHttpBinding binding = new BasicHttpBinding(); //只演示傳統的WebService調用
            EndpointAddress address = new EndpointAddress(parameters.address);
            Object client = ci.Invoke(new object[] { binding, address });
            MethodInfo mi = clientType.GetMethod(parameters.MethodName);
            Object result = mi.Invoke(client, null);
            mi = clientType.GetMethod("Close"); //關閉代理
            mi.Invoke(client, null);
            return result;
       }
        public static void CreateProxyCode(StringBuilder code, WebServiceParamaters parameters)
        {
            code.AppendLine("using System;");
            code.AppendLine("using System.ServiceModel;");
            code.AppendLine("using System.ServiceModel.Channels;");
            code.Append(@"[ServiceContract(");
            if (!String.IsNullOrEmpty(parameters.ServiceNamespace))
            {
                code.Append("Namespace="").Append(parameters.ServiceNamespace).Append(""");
            }
            code.AppendLine(")]");
            code.AppendLine("public interface IRuntimeService");
            code.AppendLine("{");
            code.Append("[OperationContract(");
            if (!String.IsNullOrEmpty(parameters.MethodAction))
            {
                code.Append("Action="").Append(parameters.MethodAction).Append(""");
                if (!String.IsNullOrEmpty(parameters.MethodReplyAction))
                {
                    code.Append(", ");
                }
            }
            if (!String.IsNullOrEmpty(parameters.MethodReplyAction))
            {
                code.Append("ReplyAction="").Append(parameters.MethodReplyAction).Append(""");
            }
            code.AppendLine(")]");
            code.Append(parameters.ReturnType).Append(" ");
            code.Append(parameters.MethodName).AppendLine("();");
            code.AppendLine("}");
            code.AppendLine();
            code.AppendLine("public class RuntimeServiceClient : ClientBase<IRuntimeService>, IRuntimeService");
            code.AppendLine("{");
            code.AppendLine("public RuntimeServiceClient(Binding binding, EndpointAddress address) :base(binding, address)");
            code.AppendLine("{");
            code.AppendLine("}");
            code.Append("public ").Append(parameters.ReturnType).Append(" ");
            code.Append(parameters.MethodName).AppendLine("()");
            code.AppendLine("{");
            code.Append("return base.Channel.").Append(parameters.MethodName).AppendLine("();");
            code.AppendLine("}");
            code.AppendLine("}");
        }
    }


      注意,紅色部分,由於代理類使用了WCF框架,所以編譯時我們需要添加System.ServiceModel的引用,當然System.dll肯定是必 須的,這裡要注意,System.ServiceModel.dll應該保存到應用程序目錄,否則動態編譯時會引發異常,很簡單,在工程引用中添加 System.ServiceModel的引用,然後在屬性中將拷貝到本地屬性設置為true。
       到此,我們就可以直接通過傳入的服務地址、服務方法名稱以及相關的命名空間,即可調用服務(盡管我們只能調用無參服務,並且盡管我們也只能調用使用 BasicHttpBinding綁定的服務,這些限制的原因是…我懶,好吧,相信只要經過一點改動即可去掉這些限制)。
       可惜,我們的程序還很傻:每次調用服務都需要去生成代碼、編譯、創建代理實例最後再調用,嗯…那就緩存吧:
      在WebServiceParameters類中重寫GetHashCode方法:

    復制代碼 代碼如下:
     public override int GetHashCode()
      {
          return String.Concat(serviceNamespace, methodAction, methodReplyAction, methodName, returnType).GetHashCode();
      }
     


    然後在WebServiceProxyCreator中加入緩存機制:

    復制代碼 代碼如下:


      public class WebServiceProxyCreator
       {
           private static Dictionary<int, Type> proxyTypeCatch = new Dictionary<int, Type>();

           public Object WebServiceCaller(WebServiceParamaters parameters)
           {
               int key = parameters.GetHashCode();
               Type clientType = null;
               if (proxyTypeCatch.ContainsKey(key))
              {
                  clientType = proxyTypeCatch[key];
                  Debug.WriteLine("使用緩存");
              }
              else
              {

                  CodeDomProvider provider = CodeDomProvider.CreateProvider("CSharp");
                  CompilerParameters codeParameters = new CompilerParameters();
                  codeParameters.GenerateExecutable = false;
                  codeParameters.GenerateInMemory = true;

                  StringBuilder code = new StringBuilder();
                  CreateProxyCode(code, parameters);

                  codeParameters.ReferencedAssemblies.Add("System.dll");
                  codeParameters.ReferencedAssemblies.Add("System.ServiceModel.dll");

                  CompilerResults results = provider.CompileAssemblyFromSource(codeParameters, code.ToString());
                  Assembly assembly = null;
                  if (!results.Errors.HasErrors)
                  {
                      assembly = results.CompiledAssembly;
                  }

                  clientType = assembly.GetType("RuntimeServiceClient");

                  proxyTypeCatch.Add(key, clientType);
              }
              ConstructorInfo ci = clientType.GetConstructor(new Type[] { typeof(Binding), typeof(EndpointAddress) });
              BasicHttpBinding binding = new BasicHttpBinding(); //只演示傳統的WebService調用
              EndpointAddress address = new EndpointAddress(parameters.address);
              Object client = ci.Invoke(new object[] { binding, address });

              MethodInfo mi = clientType.GetMethod(parameters.MethodName);
              Object result = mi.Invoke(client, null);
              mi = clientType.GetMethod("Close"); //關閉代理
              mi.Invoke(client, null);
              return result;
          }

     }

    1. 上一頁:
    2. 下一頁:
    Copyright © 程式師世界 All Rights Reserved