C#動(dòng)態(tài)webservice調(diào)用接口
更新時(shí)間：2015年05月25日 15:24:21 投稿：hebedich
動(dòng)態(tài)調(diào)用webservice,就可以不用添加web引用了,上線的話也只是需要改一下wsdl地址就可以了
C#動(dòng)態(tài)webservice調(diào)用接口
using System;
using System.Collections;
using System.IO;
using System.Net;
using System.Text;
using System.Xml;
using System.Xml.Serialization;
namespace Hishop.Plugins
{
/// <summary>
/// 利用WebRequest/WebResponse進(jìn)行WebService調(diào)用的類
/// </summary>
public class WebServiceCaller
{
#region Tip:使用說明
//webServices 應(yīng)該支持Get和Post調(diào)用，在web.config應(yīng)該增加以下代碼
//<webServices>
// <protocols>
// <add name="HttpGet"/>
// <add name="HttpPost"/>
// </protocols>
//</webServices>
//調(diào)用示例：
//Hashtable ht = new Hashtable(); //Hashtable 為webservice所需要的參數(shù)集
//ht.Add("str", "test");
//ht.Add("b", "true");
//XmlDocument xx = WebSvcCaller.QuerySoapWebService("http://localhost:81/service.asmx", "HelloWorld", ht);
//MessageBox.Show(xx.OuterXml);
#endregion
/// <summary>
/// 需要WebService支持Post調(diào)用
/// </summary>
public static XmlDocument QueryPostWebService(String URL, String MethodName, Hashtable Pars)
{
HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(URL + "/" + MethodName);
request.Method = "POST";
request.ContentType = "application/x-www-form-urlencoded";
SetWebRequest(request);
byte[] data = EncodePars(Pars);
WriteRequestData(request, data);
return ReadXmlResponse(request.GetResponse());
}
/// <summary>
/// 需要WebService支持Get調(diào)用
/// </summary>
public static XmlDocument QueryGetWebService(String URL, String MethodName, Hashtable Pars)
{
HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(URL + "/" + MethodName + "?" + ParsToString(Pars));
request.Method = "GET";
request.ContentType = "application/x-www-form-urlencoded";
SetWebRequest(request);
return ReadXmlResponse(request.GetResponse());
}
/// <summary>
/// 通用WebService調(diào)用(Soap),參數(shù)Pars為String類型的參數(shù)名、參數(shù)值
/// </summary>
public static XmlDocument QuerySoapWebService(String URL, String MethodName, Hashtable Pars)
{
if (_xmlNamespaces.ContainsKey(URL))
{
return QuerySoapWebService(URL, MethodName, Pars, _xmlNamespaces[URL].ToString());
}
else
{
return QuerySoapWebService(URL, MethodName, Pars, GetNamespace(URL));
}
}
private static XmlDocument QuerySoapWebService(String URL, String MethodName, Hashtable Pars, string XmlNs)
{
_xmlNamespaces[URL] = XmlNs;//加入緩存，提高效率
HttpWebRequest request = (HttpWebRequest)HttpWebRequest.Create(URL);
request.Method = "POST";
request.ContentType = "text/xml; charset=utf-8";
request.Headers.Add("SOAPAction", "\"" + XmlNs + (XmlNs.EndsWith("/") ? "" : "/") + MethodName + "\"");
SetWebRequest(request);
byte[] data = EncodeParsToSoap(Pars, XmlNs, MethodName);
WriteRequestData(request, data);
XmlDocument doc = new XmlDocument(), doc2 = new XmlDocument();
doc = ReadXmlResponse(request.GetResponse());
XmlNamespaceManager mgr = new XmlNamespaceManager(doc.NameTable);
mgr.AddNamespace("soap", "http://schemas.xmlsoap.org/soap/envelope/");
String RetXml = doc.SelectSingleNode("http://soap:Body/*/*", mgr).InnerXml;
doc2.LoadXml("<root>" + RetXml + "</root>");
AddDelaration(doc2);
return doc2;
}
private static string GetNamespace(String URL)
{
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(URL + "?WSDL");
SetWebRequest(request);
WebResponse response = request.GetResponse();
StreamReader sr = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
XmlDocument doc = new XmlDocument();
doc.LoadXml(sr.ReadToEnd());
sr.Close();
return doc.SelectSingleNode("http://@targetNamespace").Value;
}
private static byte[] EncodeParsToSoap(Hashtable Pars, String XmlNs, String MethodName)
{
XmlDocument doc = new XmlDocument();
doc.LoadXml("<soap:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\" xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\"></soap:Envelope>");
AddDelaration(doc);
//XmlElement soapBody = doc.createElement_x_x("soap", "Body", "http://schemas.xmlsoap.org/soap/envelope/");
XmlElement soapBody = doc.CreateElement("soap", "Body", "http://schemas.xmlsoap.org/soap/envelope/");
//XmlElement soapMethod = doc.createElement_x_x(MethodName);
XmlElement soapMethod = doc.CreateElement(MethodName);
soapMethod.SetAttribute("xmlns", XmlNs);
foreach (string k in Pars.Keys)
{
//XmlElement soapPar = doc.createElement_x_x(k);
XmlElement soapPar = doc.CreateElement(k);
soapPar.InnerXml = ObjectToSoapXml(Pars[k]);
soapMethod.AppendChild(soapPar);
}
soapBody.AppendChild(soapMethod);
doc.DocumentElement.AppendChild(soapBody);
return Encoding.UTF8.GetBytes(doc.OuterXml);
}
private static string ObjectToSoapXml(object o)
{
XmlSerializer mySerializer = new XmlSerializer(o.GetType());
MemoryStream ms = new MemoryStream();
mySerializer.Serialize(ms, o);
XmlDocument doc = new XmlDocument();
doc.LoadXml(Encoding.UTF8.GetString(ms.ToArray()));
if (doc.DocumentElement != null)
{
return doc.DocumentElement.InnerXml;
}
else
{
return o.ToString();
}
}
/// <summary>
/// 設(shè)置憑證與超時(shí)時(shí)間
/// </summary>
/// <param name="request"></param>
private static void SetWebRequest(HttpWebRequest request)
{
request.Credentials = CredentialCache.DefaultCredentials;
request.Timeout = 10000;
}
private static void WriteRequestData(HttpWebRequest request, byte[] data)
{
request.ContentLength = data.Length;
Stream writer = request.GetRequestStream();
writer.Write(data, 0, data.Length);
writer.Close();
}
private static byte[] EncodePars(Hashtable Pars)
{
return Encoding.UTF8.GetBytes(ParsToString(Pars));
}
private static String ParsToString(Hashtable Pars)
{
StringBuilder sb = new StringBuilder();
foreach (string k in Pars.Keys)
{
if (sb.Length > 0)
{
sb.Append("&");
}
//sb.Append(HttpUtility.UrlEncode(k) + "=" + HttpUtility.UrlEncode(Pars[k].ToString()));
}
return sb.ToString();
}
private static XmlDocument ReadXmlResponse(WebResponse response)
{
StreamReader sr = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
String retXml = sr.ReadToEnd();
sr.Close();
XmlDocument doc = new XmlDocument();
doc.LoadXml(retXml);
return doc;
}
private static void AddDelaration(XmlDocument doc)
{
XmlDeclaration decl = doc.CreateXmlDeclaration("1.0", "utf-8", null);
doc.InsertBefore(decl, doc.DocumentElement);
}
private static Hashtable _xmlNamespaces = new Hashtable();//緩存xmlNamespace，避免重復(fù)調(diào)用GetNamespace
}
}
//調(diào)用并讀取解析返回結(jié)果
DataSet ds = new DataSet();
XmlNode xmlNode1;
XmlDataDocument xd = new XmlDataDocument();
StringBuilder sb;
Hashtable ht = new Hashtable();
ht.Add("xmlIn", "<Request><MemCode>001</MemCode></Request>");
xmlNode1 = Hishop.Plugins.WebServiceCaller.QuerySoapWebService("http://xxx.xxxx.com/Service.asmx", "SinPointQuery", ht);
if (xmlNode1 == null)
{
return;
}
string xmlstr= HttpUtility.HtmlDecode(xmlNode1.OuterXml);
sb = new StringBuilder(xmlstr);
if (sb.ToString().Equals(""))
{
return;
}
xd.LoadXml(sb.ToString());
ds.ReadXml(new XmlNodeReader(xd));
//ds可以返回出結(jié)果集
示例二：
1.動(dòng)態(tài)調(diào)用的方法:
/// <summary>
/// 動(dòng)態(tài)webservice調(diào)用
/// </summary>
/// <returns>string</returns>
public string wsTest()
{
string url = "http://localhost:8080/myWebserviceTest/services/myServices?wsdl";//wsdl地址
string name = "wsTest";//javaWebService開放的接口
WebServiceProxy wsd = new WebServiceProxy(url, name);
string[] str = { "測試c#調(diào)用java的webService" , "Hello WebService"};
string suc = (string)wsd.ExecuteQuery(name, str);
return suc;
}
2.動(dòng)態(tài)調(diào)用具體類:
using System;
using System.Collections;
using System.ComponentModel;
using System.Data;
using System.Linq;
using System.Web;
using System.Web.Services;
using System.Web.Services.Protocols;
using System.Xml.Linq;
using System.IO;
using System.Net;
using System.CodeDom;
using System.CodeDom.Compiler;
using System.Web.Services.Description;
using System.Xml.Serialization;
using System.Web.Services.Discovery;
using System.Xml.Schema;
using System.Text;
using System.Security.Cryptography;
using System.Reflection;
using System.Collections.Generic;
using System.Xml;
namespace TPSVService
{
/// <summary>
/// WebServiceProxy 的摘要說明
/// </summary>
[WebService(Namespace = "http://tempuri.org/")]
[WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)]
[ToolboxItem(false)]
// 若要允許使用 ASP.NET AJAX 從腳本中調(diào)用此 Web 服務(wù)，請取消對下行的注釋。
// [System.Web.Script.Services.ScriptService]
public class WebServiceProxy : System.Web.Services.WebService
{
#region 私有變量和屬性定義
/// <summary>
/// web服務(wù)地址
/// </summary>
private string _wsdlUrl = string.Empty;
/// <summary>
/// web服務(wù)名稱
/// </summary>
private string _wsdlName = string.Empty;
/// <summary>
/// 代理類命名空間
/// </summary>
private string _wsdlNamespace = "FrameWork.WebService.DynamicWebServiceCalling.{0}";
/// <summary>
/// 代理類類型名稱
/// </summary>
private Type _typeName = null;
/// <summary>
/// 程序集名稱
/// </summary>
private string _assName = string.Empty;
/// <summary>
/// 代理類所在程序集路徑
/// </summary>
private string _assPath = string.Empty;
/// <summary>
/// 代理類的實(shí)例
/// </summary>
private object _instance = null;
/// <summary>
/// 代理類的實(shí)例
/// </summary>
private object Instance
{
get
{
if (_instance == null)
{
_instance = Activator.CreateInstance(_typeName);
return _instance;
}
else
return _instance;
}
}
#endregion
#region 構(gòu)造函數(shù)
public WebServiceProxy(string wsdlUrl)
{
this._wsdlUrl = wsdlUrl;
string wsdlName = WebServiceProxy.getWsclassName(wsdlUrl);
this._wsdlName = wsdlName;
this._assName = string.Format(_wsdlNamespace, wsdlName);
this._assPath = Path.GetTempPath() + this._assName + getMd5Sum(this._wsdlUrl) + ".dll";
this.CreateServiceAssembly();
}
public WebServiceProxy(string wsdlUrl, string wsdlName)
{
this._wsdlUrl = wsdlUrl;
this._wsdlName = wsdlName;
this._assName = string.Format(_wsdlNamespace, wsdlName);
this._assPath = Path.GetTempPath() + this._assName + getMd5Sum(this._wsdlUrl) + ".dll";
this.CreateServiceAssembly();
}
#endregion
#region 得到WSDL信息，生成本地代理類并編譯為DLL，構(gòu)造函數(shù)調(diào)用，類生成時(shí)加載
/// <summary>
/// 得到WSDL信息，生成本地代理類并編譯為DLL
/// </summary>
private void CreateServiceAssembly()
{
if (this.checkCache())
{
this.initTypeName();
return;
}
if (string.IsNullOrEmpty(this._wsdlUrl))
{
return;
}
try
{
//使用WebClient下載WSDL信息
WebClient web = new WebClient();
Stream stream = web.OpenRead(this._wsdlUrl);
ServiceDescription description = ServiceDescription.Read(stream);//創(chuàng)建和格式化WSDL文檔
ServiceDescriptionImporter importer = new ServiceDescriptionImporter();//創(chuàng)建客戶端代理代理類
importer.ProtocolName = "Soap";
importer.Style = ServiceDescriptionImportStyle.Client; //生成客戶端代理
importer.CodeGenerationOptions = CodeGenerationOptions.GenerateProperties | CodeGenerationOptions.GenerateNewAsync;
importer.AddServiceDescription(description, null, null);//添加WSDL文檔
//使用CodeDom編譯客戶端代理類
CodeNamespace nmspace = new CodeNamespace(_assName); //為代理類添加命名空間
CodeCompileUnit unit = new CodeCompileUnit();
unit.Namespaces.Add(nmspace);
this.checkForImports(this._wsdlUrl, importer);
ServiceDescriptionImportWarnings warning = importer.Import(nmspace, unit);
CodeDomProvider provider = CodeDomProvider.CreateProvider("CSharp");
CompilerParameters parameter = new CompilerParameters();
parameter.ReferencedAssemblies.Add("System.dll");
parameter.ReferencedAssemblies.Add("System.XML.dll");
parameter.ReferencedAssemblies.Add("System.Web.Services.dll");
parameter.ReferencedAssemblies.Add("System.Data.dll");
parameter.GenerateExecutable = false;
parameter.GenerateInMemory = false;
parameter.IncludeDebugInformation = false;
CompilerResults result = provider.CompileAssemblyFromDom(parameter, unit);
provider.Dispose();
if (result.Errors.HasErrors)
{
string errors = string.Format(@"編譯錯(cuò)誤:{0}錯(cuò)誤！", result.Errors.Count);
foreach (CompilerError error in result.Errors)
{
errors += error.ErrorText;
}
throw new Exception(errors);
}
this.copyTempAssembly(result.PathToAssembly);
this.initTypeName();
}
catch (Exception e)
{
throw new Exception(e.Message);
}
}
#endregion
#region 執(zhí)行Web服務(wù)方法
/// <summary>
/// 執(zhí)行代理類指定方法，有返回值
/// </summary>
/// <param name="methodName">方法名稱</param>
/// <param name="param">參數(shù)</param>
/// <returns>object</returns>
public object ExecuteQuery(string methodName, object[] param)
{
object rtnObj = null;
string[] args = new string[2];
List<string> list = new List<string>();
List<string> list1 = new List<string>();
List<string> list2 = new List<string>();
object[] obj = new object[3];
try
{
if (this._typeName == null)
{
//記錄Web服務(wù)訪問類名錯(cuò)誤日志代碼位置
throw new TypeLoadException("Web服務(wù)訪問類名【" + this._wsdlName + "】不正確，請檢查！");
}
//調(diào)用方法
MethodInfo mi = this._typeName.GetMethod(methodName);
if (mi == null)
{
//記錄Web服務(wù)方法名錯(cuò)誤日志代碼位置
throw new TypeLoadException("Web服務(wù)訪問方法名【" + methodName + "】不正確，請檢查！");
}
try
{
if (param == null)
rtnObj = mi.Invoke(Instance, null);
else {
list.Add("Hello ");
list.Add("WebService ");
list.Add(" ! ");
list1.Add("I ");
list1.Add("am ");
list1.Add("test ");
list2.Add("do ");
list2.Add("it ");
list2.Add("now ");
obj[0] = list;
obj[1] = list1;
obj[2] = list2;
rtnObj = mi.Invoke(Instance, new object[] { obj });
//rtnObj = mi.Invoke(Instance, new object[] { param });
}
}
catch (TypeLoadException tle)
{
//記錄Web服務(wù)方法參數(shù)個(gè)數(shù)錯(cuò)誤日志代碼位置
throw new TypeLoadException("Web服務(wù)訪問方法【" + methodName + "】參數(shù)個(gè)數(shù)不正確，請檢查！", new TypeLoadException(tle.StackTrace));
}
}
catch (Exception ex)
{
throw new Exception(ex.Message, new Exception(ex.StackTrace));
}
return rtnObj;
}
/// <summary>
/// 執(zhí)行代理類指定方法，無返回值
/// </summary>
/// <param name="methodName">方法名稱</param>
/// <param name="param">參數(shù)</param>
public void ExecuteNoQuery(string methodName, object[] param)
{
try
{
if (this._typeName == null)
{
//記錄Web服務(wù)訪問類名錯(cuò)誤日志代碼位置
throw new TypeLoadException("Web服務(wù)訪問類名【" + this._wsdlName + "】不正確，請檢查！");
}
//調(diào)用方法
MethodInfo mi = this._typeName.GetMethod(methodName);
if (mi == null)
{
//記錄Web服務(wù)方法名錯(cuò)誤日志代碼位置
throw new TypeLoadException("Web服務(wù)訪問方法名【" + methodName + "】不正確，請檢查！");
}
try
{
if (param == null)
mi.Invoke(Instance, null);
else
mi.Invoke(Instance, param);
}
catch (TypeLoadException tle)
{
//記錄Web服務(wù)方法參數(shù)個(gè)數(shù)錯(cuò)誤日志代碼位置
throw new TypeLoadException("Web服務(wù)訪問方法【" + methodName + "】參數(shù)個(gè)數(shù)不正確，請檢查！", new TypeLoadException(tle.StackTrace));
}
}
catch (Exception ex)
{
throw new Exception(ex.Message, new Exception(ex.StackTrace));
}
}
#endregion
#region 私有方法
/// <summary>
/// 得到代理類類型名稱
/// </summary>
private void initTypeName()
{
Assembly serviceAsm = Assembly.LoadFrom(this._assPath);
Type[] types = serviceAsm.GetTypes();
string objTypeName = "";
foreach (Type t in types)
{
if (t.BaseType == typeof(SoapHttpClientProtocol))
{
objTypeName = t.Name;
break;
}
}
_typeName = serviceAsm.GetType(this._assName + "." + objTypeName);
}
/// <summary>
/// 根據(jù)web service文檔架構(gòu)向代理類添加ServiceDescription和XmlSchema
/// </summary>
/// <param name="baseWSDLUrl">web服務(wù)地址</param>
/// <param name="importer">代理類</param>
private void checkForImports(string baseWsdlUrl, ServiceDescriptionImporter importer)
{
DiscoveryClientProtocol dcp = new DiscoveryClientProtocol();
dcp.DiscoverAny(baseWsdlUrl);
dcp.ResolveAll();
foreach (object osd in dcp.Documents.Values)
{
if (osd is ServiceDescription) importer.AddServiceDescription((ServiceDescription)osd, null, null); ;
if (osd is XmlSchema) importer.Schemas.Add((XmlSchema)osd);
}
}
/// <summary>
/// 復(fù)制程序集到指定路徑
/// </summary>
/// <param name="pathToAssembly">程序集路徑</param>
private void copyTempAssembly(string pathToAssembly)
{
File.Copy(pathToAssembly, this._assPath);
}
private string getMd5Sum(string str)
{
Encoder enc = System.Text.Encoding.Unicode.GetEncoder();
byte[] unicodeText = new byte[str.Length * 2];
enc.GetBytes(str.ToCharArray(), 0, str.Length, unicodeText, 0, true);
MD5 md5 = new MD5CryptoServiceProvider();
byte[] result = md5.ComputeHash(unicodeText);
StringBuilder sb = new StringBuilder();
for (int i = 0; i < result.Length; i++)
{
sb.Append(result[i].ToString("X2"));
}
return sb.ToString();
}
/// <summary>
/// 是否已經(jīng)存在該程序集
/// </summary>
/// <returns>false:不存在該程序集,true:已經(jīng)存在該程序集</returns>
private bool checkCache()
{
if (File.Exists(this._assPath))
{
return true;
}
return false;
}
//私有方法，默認(rèn)取url入口的文件名為類名
private static string getWsclassName(string wsdlUrl)
{
string[] parts = wsdlUrl.Split('/');
string[] pps = parts[parts.Length - 1].Split('.');
return pps[0];
}
#endregion
}
}
以上所述就是本文的全部內(nèi)容了，希望大家能夠喜歡。
相關(guān)文章
C#解決多IfElse判斷語句和Switch語句問題的方法分享
這篇文章主要為大家介紹C#如何使用設(shè)計(jì)模式中的策略模式和委托來解決多個(gè)IfElse判斷語句和Switch語句，這種替換方式在其他語言也一樣可以做到，感興趣的可以了解一下2022-12-12
這篇文章主要介紹了C#讀寫EXCEL單元格的問題實(shí)現(xiàn)，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2019-04-04
這篇文章主要介紹了c#中禁用windows的任務(wù)管理器的方法,通過注冊表實(shí)現(xiàn)禁用,需要的朋友可以參考下2014-06-06
這篇文章主要介紹了C#信號量用法,結(jié)合簡單C#控制臺應(yīng)用程序形式分析了信號量的功能、定義、調(diào)用、釋放等操作技巧,需要的朋友可以參考下2016-07-07
.NET實(shí)現(xiàn):將EXE設(shè)置開機(jī)自動(dòng)啟動(dòng)
.NET實(shí)現(xiàn):將EXE設(shè)置開機(jī)自動(dòng)啟動(dòng)的方法，需要的朋友可以參考一下2013-03-03
這篇文章主要為大家詳細(xì)介紹了C#裁剪,縮放,清晰度,水印處理操作示例,具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2016-10-10
C# Dynamic之:ExpandoObject,DynamicObject,DynamicMetaOb的應(yīng)用(下)
本篇文章是對C#中ExpandoObject,DynamicObject,DynamicMetaOb的應(yīng)用進(jìn)行了詳細(xì)的分析介紹，需要的朋友參考下2013-05-05
C#遞歸應(yīng)用之實(shí)現(xiàn)JS文件的自動(dòng)引用
這篇文章主要為大家詳細(xì)介紹了C#如何利用遞歸實(shí)現(xiàn)JS文件的自動(dòng)引用的功能，文中的示例代碼講解詳細(xì)，具有一定的參考價(jià)值，需要的可以參考一下2023-03-03
本文主要介紹了C#無損壓縮圖片的相關(guān)知識。具有很好的參考價(jià)值。下面跟著小編一起來看下吧2017-04-04
C#使用JavaScriptSerializer序列化時(shí)的時(shí)間類型處理
這篇文章主要為大家詳細(xì)介紹了C#使用JavaScriptSerializer序列化時(shí)的時(shí)間類型處理，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-08-08