动态引用WebService

概述

????? 建立WebService虚拟代理，使用xml登记WebService的引用地址。实现动态引用WebService.

????? 使用技术

1、????????? 动态编译

2、????????? 反射技术

实现代码

using System;

using System.Reflection ;

using System.Web .Services .Description ;

using Microsoft.CSharp;

using System.CodeDom ;

using System.CodeDom.Compiler ;

using? System.IO ;

using? System.Text ;

using System.Xml ;

using System.Net ;

using WebServiceProxy;

namespace WebServiceProxy

{

??????? public class WebServiceProxy

???? {

???????? private Assembly _ass = null;??????????????

?

???????? private string _protocolName = "Soap";?????

???????? private string _srcWSProxy = string.Empty;?

?

???????? public Assembly Assembly { get{ return _ass; } }

?

???????? public string ProtocolName

?

???????? { get{ return _protocolName; } set {_protocolName = value; } }

?

???????? public string SrcWSProxy { get{ return _srcWSProxy; } }

?

?

?

???????? public WebServiceProxy ()

?

???????? {

?

???????? }

?

???????? public WebServiceProxy (string wsdlSourceName)

?

???????? {

?

????????????? AssemblyFromWsdl(GetWsdl(wsdlSourceName));

?

???????? }

?

???????? public string WsdlFromUrl(string url)

?

???????? {

?

????????????? WebRequest req = WebRequest.Create(url);

?

????????????? WebResponse result = req.GetResponse();

?

????????????? Stream ReceiveStream = result.GetResponseStream();

?

????????????? Encoding encode = System.Text.Encoding.GetEncoding("utf-8");

?

????????????? StreamReader sr = new StreamReader( ReceiveStream,encode );

?

????????????? string strWsdl = sr.ReadToEnd();

?

????????????? return strWsdl;

?

???????? }

?

???????? public string GetWsdl(string source)

???????? {

?

????????????? if(source.StartsWith("<?xml version") == true)

?

????????????? {

?????????????????? return source;?????????????

????????????? }

????????????? else

?

????????????? if(source.StartsWith("http://") == true)

????????????? {

?????????????????? return WsdlFromUrl(source);??

????????????? }

?

????????????? return WsdlFromFile(source);??

???????? }

???????? public string WsdlFromFile(string fileFullPathName)

???????? {

????????????? FileInfo fi = new FileInfo(fileFullPathName);

????????????? if(fi.Extension == "wsdl")

????????????? {

?????????????????? FileStream fs = new FileStream(fileFullPathName,FileMode.Open,

?????????????????????? FileAccess.Read);

?????????????????? StreamReader sr = new StreamReader(fs);

?????????????????? char[] buffer = new char[(int)fs.Length];

?????????????????? sr.ReadBlock(buffer,(int)fs.Length);

?????????????????? return new string(buffer);

????????????? }

???????????????

????????????? throw new Exception("This is no a wsdl file");

???????? }

?

???????? public Assembly AssemblyFromWsdl(string strWsdl)

???????? {

????????????? // Xml text reader

????????????? StringReader? wsdlStringReader = new StringReader(strWsdl);

????????????? XmlTextReader tr = new XmlTextReader(wsdlStringReader);

????????????? ServiceDescription sd = ServiceDescription.Read(tr);

????????????? tr.Close();

?

????????????? // WSDL service description importer

????????????? CodeNamespace cns = new CodeNamespace("WebServiceProxy.WebServiceAccessor");

????????????? ServiceDescriptionImporter sdi = new ServiceDescriptionImporter();

????????????? sdi.AddServiceDescription(sd,null,null);

????????????? sdi.ProtocolName = _protocolName;

????????????? sdi.Import(cns,null);

?

????????????? // source code generation

????????????? CSharpCodeProvider cscp = new CSharpCodeProvider();

????????????? ICodeGenerator icg = cscp.CreateGenerator();

????????????? StringBuilder srcStringBuilder = new StringBuilder();

????????????? StringWriter sw = new StringWriter(srcStringBuilder);

????????????? icg.GenerateCodeFromNamespace(cns,sw,null);

????????????? _srcWSProxy = srcStringBuilder.ToString();

????????????? sw.Close();

?

????????????? // assembly compilation.

????????????? CompilerParameters cp = new CompilerParameters();

????????????? cp.ReferencedAssemblies.Add("System.dll");

????????????? cp.ReferencedAssemblies.Add("System.Xml.dll");

????????????? cp.ReferencedAssemblies.Add("System.Web.Services.dll");

????????????? cp.GenerateExecutable = false;

????????????? cp.GenerateInMemory = true;

????????????? cp.IncludeDebugInformation = false;

????????????? ICodeCompiler icc = cscp.CreateCompiler();

????????????? CompilerResults cr = icc.CompileAssemblyFromSource(cp,_srcWSProxy);

????????????? if(cr.Errors.Count > 0)

?????????????????? throw new Exception(string.Format("Build failed: {0} errors",

?????????????????????? cr.Errors.Count));

?

????????????? return _ass = cr.CompiledAssembly;

???????? }

?

?

???????? public object CreateInstance(string objTypeName)

???????? {

????????????? Type t = _ass.GetType("WebServiceProxy.WebServiceAccessor" + "." + objTypeName);

????????????? return Activator.CreateInstance(t);

???????? }

?

?

???????? public object Invoke(object obj,string methodName,params object[] args)

???????? {

????????????? MethodInfo mi = obj.GetType().GetMethod(methodName);

????????????? return mi.Invoke(obj,args);

???????? }

???? }

?

}