动态引用WebService,建立WebService虚拟机

80酷酷网    80kuku.com

  web|动态建立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, 0, (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);

}

}



}

分享到
  • 微信分享
  • 新浪微博
  • QQ好友
  • QQ空间
点击: