C#動態(tài)webservice調用接口
更新時間：2015年05月25日 15:24:21 投稿：hebedich
動態(tài)調用webservice,就可以不用添加web引用了,上線的話也只是需要改一下wsdl地址就可以了
C#動態(tài)webservice調用接口
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進行WebService調用的類
/// </summary>
public class WebServiceCaller
{
#region Tip:使用說明
//webServices 應該支持Get和Post調用，在web.config應該增加以下代碼
//<webServices>
// <protocols>
// <add name="HttpGet"/>
// <add name="HttpPost"/>
// </protocols>
//</webServices>
//調用示例：
//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調用
/// </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調用
/// </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調用(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>
/// 設置憑證與超時時間
/// </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，避免重復調用GetNamespace
}
}
//調用并讀取解析返回結果
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可以返回出結果集
示例二：
1.動態(tài)調用的方法:
/// <summary>
/// 動態(tài)webservice調用
/// </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#調用java的webService" , "Hello WebService"};
string suc = (string)wsd.ExecuteQuery(name, str);
return suc;
}
2.動態(tài)調用具體類:
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 從腳本中調用此 Web 服務，請取消對下行的注釋。
// [System.Web.Script.Services.ScriptService]
public class WebServiceProxy : System.Web.Services.WebService
{
#region 私有變量和屬性定義
/// <summary>
/// web服務地址
/// </summary>
private string _wsdlUrl = string.Empty;
/// <summary>
/// web服務名稱
/// </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>
/// 代理類的實例
/// </summary>
private object _instance = null;
/// <summary>
/// 代理類的實例
/// </summary>
private object Instance
{
get
{
if (_instance == null)
{
_instance = Activator.CreateInstance(_typeName);
return _instance;
}
else
return _instance;
}
}
#endregion
#region 構造函數(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，構造函數(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(@"編譯錯誤:{0}錯誤！", 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服務方法
/// <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服務訪問類名錯誤日志代碼位置
throw new TypeLoadException("Web服務訪問類名【" + this._wsdlName + "】不正確，請檢查！");
}
//調用方法
MethodInfo mi = this._typeName.GetMethod(methodName);
if (mi == null)
{
//記錄Web服務方法名錯誤日志代碼位置
throw new TypeLoadException("Web服務訪問方法名【" + 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服務方法參數(shù)個數(shù)錯誤日志代碼位置
throw new TypeLoadException("Web服務訪問方法【" + methodName + "】參數(shù)個數(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服務訪問類名錯誤日志代碼位置
throw new TypeLoadException("Web服務訪問類名【" + this._wsdlName + "】不正確，請檢查！");
}
//調用方法
MethodInfo mi = this._typeName.GetMethod(methodName);
if (mi == null)
{
//記錄Web服務方法名錯誤日志代碼位置
throw new TypeLoadException("Web服務訪問方法名【" + methodName + "】不正確，請檢查！");
}
try
{
if (param == null)
mi.Invoke(Instance, null);
else
mi.Invoke(Instance, param);
}
catch (TypeLoadException tle)
{
//記錄Web服務方法參數(shù)個數(shù)錯誤日志代碼位置
throw new TypeLoadException("Web服務訪問方法【" + methodName + "】參數(shù)個數(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文檔架構向代理類添加ServiceDescription和XmlSchema
/// </summary>
/// <param name="baseWSDLUrl">web服務地址</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>
/// 復制程序集到指定路徑
/// </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;
}
//私有方法，默認取url入口的文件名為類名
private static string getWsclassName(string wsdlUrl)
{
string[] parts = wsdlUrl.Split('/');
string[] pps = parts[parts.Length - 1].Split('.');
return pps[0];
}
#endregion
}
}
以上所述就是本文的全部內容了，希望大家能夠喜歡。
相關文章
C# 中的 IReadOnlyDictionary 和 IReadOnlyLis
C# 中的IReadOnlyDictionary和IReadOnlyList是接口,用于表示只讀的字典和只讀的列表,這些接口提供了對集合的只讀訪問權限,即不允許對集合進行修改操作,這篇文章主要介紹了C# 中的 IReadOnlyDictionary 和 IReadOnlyList實例詳解,需要的朋友可以參考下2024-03-03
C#中的Chart控件用于開發(fā)圖表功能,具有Series和ChartArea兩個重要屬性,Series屬性是SeriesCollection類型,包含多個Series對象,每個Series代表圖表中的一個數(shù)據(jù)系列,Series對象有一個Points屬性,用于存儲數(shù)據(jù)點,每個數(shù)據(jù)點是一個DataPoint對象2024-12-12
C#手動操作DataGridView使用各種數(shù)據(jù)源填充表格實例
本文主要介紹了C#手動操作DataGridView使用各種數(shù)據(jù)源填充表格實例，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-02-02
C#使用Fleck實現(xiàn)創(chuàng)建WebSocket服務器
這篇文章主要為大家詳細介紹了C#如何使用Fleck實現(xiàn)創(chuàng)建WebSocket服務器,文中的示例代碼講解詳細,感興趣的小伙伴可以跟隨小編一起學習一下2024-01-01
這篇文章主要介紹了C#日期控件datetimepicker保存空值的三種方法,本文分別講解了三種方法的實現(xiàn)原理和代碼示例,需要的朋友可以參考下2015-06-06
下面小編就為大家?guī)硪黄钊肜斫釹tringBuilder的使用方法。小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2016-05-05
這篇文章主要介紹了C#實現(xiàn)由四周向中心縮小的窗體退出特效,通過簡單的C#窗口調用參數(shù)設置實現(xiàn)該退出特效功能,非常簡單實用,需要的朋友可以參考下2015-08-08
這篇文章主要介紹了C# Aspose.Words 刪除word中的圖片操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-01-01
c#在excel中添加超鏈接示例分享,大家參考使用吧2013-12-12
這篇文章主要為大家詳細介紹了C#如何使用DateTime.Now.ToString方法將日期格式化為指定格式,文中的示例代碼講解詳細,有需要的小伙伴可以參考下2024-01-01