動態編譯與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="//www.zmynmublwnt.cn/")]
public interface TestService
{
[OperationContract(Action = "//www.zmynmublwnt.cn/HelloWorld", ReplyAction = "//www.zmynmublwnt.cn/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;
}
}
