淺談WebService開發(一)


一、什么是WebService:

簡單通俗來說,就是企業之間、網站之間通過Internet來訪問並使用在線服務,一些數據,由於安全性問題,不能提供數據庫給其他單位使用,這時候可以使   用WebService服務提供。

二、創建WebService

\
 

創建WebService之后,我們就可以在文件里寫返回數據的方法了。

三、返回數據的四種形式

筆者水平有限,只列出這四種數據的返回形式:

(1)直接返回DataSet對象
(2)返回DataSet對象用Binary序列化后的字節數組
(3)返回DataSetSurrogate對象用Binary序列化后的 字節數組
(4)返回DataSetSurrogate對象用Binary序列化並Zip 壓縮后的字節數組

理論上來說,網絡傳輸字節與傳輸時間,應該是遞減的,其中,(3)(4)種方法需要引用微軟提供的開源組件  下載地址:http://support.microsoft.com/kb/829740/zh-cn

下面展示這四種返回數據的代碼,其中(1)是其三種方法的根本,都要得到一個DataSet作為根本,然后來做各種轉換壓縮的操作:

[WebMethod(Description = "直接返回DataSet對象")]
     public DataSet GetDataSet()
     {
         string connStr = System.Configuration.ConfigurationManager.ConnectionStrings["conn"].ToString();
         SqlConnection conn = new SqlConnection(connStr);
         string sql = "select * from china_city";
         conn.Open();
         SqlDataAdapter sda = new SqlDataAdapter(sql, conn);
         DataSet ds = new DataSet("China");
         sda.Fill(ds);
         conn.Close();
         return ds;
     }  

     [WebMethod(Description = "直接返回DataSet對象,並用Binary序列化后的字節數組")]
     public byte[] GetDataSetBytes()
     {
         DataSet ds = GetDataSet();
         BinaryFormatter ser = new BinaryFormatter();  //序列化對象
         MemoryStream ms = new MemoryStream();  //內存流
         ser.Serialize(ms, ds);
         byte[] buffer = ms.ToArray();    //字節流
         return buffer;
     }  

     [WebMethod(Description = "直接返回DataSetSurrogate對象,並用Binary序列化后的字節數組")]
     public byte[] GetDataSetSurrogateBytes()
     {
         DataSet ds = GetDataSet();
         DataSetSurrogate dss = new DataSetSurrogate(ds);
         BinaryFormatter ser = new BinaryFormatter();  //序列化對象
         MemoryStream ms = new MemoryStream();  //內存流
         ser.Serialize(ms, dss);
         byte[] buffer = ms.ToArray();    //字節流
         return buffer;  

     }  

     [WebMethod(Description = "直接返回DataSetSurrogate對象,並用Binary序列化后並且ZIP壓縮的字節數組")]
     public byte[] GetDataSetSurrogateZipBytes()
     {
         DataSet ds = GetDataSet();
         DataSetSurrogate dss = new DataSetSurrogate(ds);
         BinaryFormatter ser = new BinaryFormatter();  //序列化對象
         MemoryStream ms = new MemoryStream();  //內存流
         ser.Serialize(ms, dss);
         byte[] buffer = ms.ToArray();    //字節流
         byte[] bufferZip = ComPress(buffer);
         return buffer;
     }
     //壓縮方法
     public byte[] ComPress(byte[] data)
     {
         try
         {
             MemoryStream ms = new MemoryStream();
             Stream zipStream = null;
             zipStream = new GZipStream(ms, CompressionMode.Compress, true);
             zipStream.Write(data, 0, data.Length);
             zipStream.Close();
             ms.Position = 0;
             byte[] compressed_data = new byte[ms.Length];
             ms.Read(compressed_data, 0, int.Parse(ms.Length.ToString()));
             return compressed_data;
         }
         catch
         {
             return null;
         }
     }

我們可以在瀏覽器中查看下WebService的效果,如圖,在這個頁面中,有提供四個方法,這四個方法就是上述我們寫的四個返回數據的方法了,點擊方法即可返回相應的數據,這樣,我們數據提供方的代碼就可以寫好了,接下來,我們寫調用數據的方法!

\
 

四、調用數據

客戶端WebService程序

 

private void button1_Click(object sender, EventArgs e)
    {
        com.dzbsoft.www.Service1 ds = new com.dzbsoft.www.Service1();  //new出WebService對象
        DateTime dtBegin = DateTime.Now;
        DataSet dataSet = ds.GetNorthwindDataSet();
        this.label1.Text = string.Format("耗時:{0}", DateTime.Now - dtBegin);
        binddata(dataSet);
    }
    private void button2_Click(object sender, EventArgs e)
    {
        com.dzbsoft.www.Service1 ds = new com.dzbsoft.www.Service1();
        DateTime dtBegin = DateTime.Now;
        byte[] buffer = ds.GetDataSetBytes();
        BinaryFormatter ser = new BinaryFormatter();
        DataSet dataSet = ser.Deserialize(new MemoryStream(buffer)) as DataSet;
        this.label2.Text = string.Format("耗時:{0}", DateTime.Now - dtBegin) + "  " + buffer.Length;
        binddata(dataSet);
    }
    private void button3_Click(object sender, EventArgs e)
    {
        com.dzbsoft.www.Service1 ds = new com.dzbsoft.www.Service1();
        DateTime dtBegin = DateTime.Now;
        byte[] buffer = ds.GetDataSetSurrogateBytes();
        BinaryFormatter ser = new BinaryFormatter();
        DataSetSurrogate dss = ser.Deserialize(new MemoryStream(buffer)) as DataSetSurrogate;
        DataSet dataSet = dss.ConvertToDataSet();
        this.label3.Text = string.Format("耗時:{0}", DateTime.Now - dtBegin) + "  " + buffer.Length;
        binddata(dataSet);
    }
    private void button4_Click(object sender, EventArgs e)
    {
        com.dzbsoft.www.Service1 ds = new com.dzbsoft.www.Service1();
        DateTime dtBegin = DateTime.Now;
        byte[] zipBuffer = ds.GetDataSetSurrogateZipBytes();
        byte[] buffer = UnZipClass.Decompress(zipBuffer);
        BinaryFormatter ser = new BinaryFormatter();
        DataSetSurrogate dss = ser.Deserialize(new MemoryStream(buffer)) as DataSetSurrogate;
        DataSet dataSet = dss.ConvertToDataSet();
        this.label4.Text = string.Format("耗時:{0}", DateTime.Now - dtBegin) + "  " + zipBuffer.Length;
        binddata(dataSet);
    }
    private void binddata(DataSet dataSet)
    {
        this.dataGridView1.DataSource = dataSet.Tables[0];
        this.label5.Text = "共計:" + dataSet.Tables[0].Rows.Count + "條記錄";
    }

  在數據返回的方法中,我們使用了數據的壓縮,所以,在調用方這邊,需要進行解壓,代碼:

客戶端UnZipClass程序
    public static class UnZipClass
    {
        public static byte[] Decompress(byte[] data)
        {
            try
            {
                MemoryStream ms = new MemoryStream(data);
                Stream zipStream = null;
                zipStream = new GZipStream(ms, CompressionMode.Decompress);
                byte[] dc_data = null;
                dc_data = ExtractBytesFromStream(zipStream, data.Length);
                return dc_data;
            }
            catch
            {
                return null;
            }
        }
        public static byte[] ExtractBytesFromStream(Stream zipStream, int dataBlock)
        {
            byte[] data = null;
            int totalBytesRead = 0;
            try
            {
                while (true)
                {
                    Array.Resize(ref data, totalBytesRead + dataBlock + 1);
                    int bytesRead = zipStream.Read(data, totalBytesRead, dataBlock);
                    if (bytesRead == 0)
                    {
                        break;
                    }
                    totalBytesRead += bytesRead;
                }
                Array.Resize(ref data, totalBytesRead);
                return data;
            }
            catch
            {
                return null;
            }
        }
    }

  在上例中,調用四個方法的效果是一樣的,唯一不同的是,傳輸過程中,數據量大小和傳輸時間的差異。

如果創建一個webservice和簡單的調用,本文將注重webservice的效率調用問題,所以,我回說說如何實現同步與異步調用 webservice,如果說得哪里不對或者不好的地方,歡迎大家評論指導。
首先,什么是同步,什么是異步呢?打個比方來說,小明和小 華,互相打架,小明打了小華3下之后,小華才能打回小明,這叫同步,如果,小華勇敢點,在小明打了第一下開始做出反擊,也打回小明,這叫異步。 也就是說,只能等待另外一個作業進行完才能進行下一個操作的叫同步,在另外一個作業進行的同時也進行其他操作,叫異步。

先創建一個webservice

using System;
using System.Web;
using System.Web.Services;
using System.Web.Services.Protocols;

[WebService(Namespace = "http://tempuri.org/")]
[WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)]
//若要允許使用 <a href="http://www.it165.net/pro/webasp/" target="_blank" class="keylink">ASP</a>.NET AJAX 從腳本中調用此 Web 服務,請取消對下行的注釋。
// [System.Web.Script.Services.ScriptService]
public class GetWebService : System.Web.Services.WebService
{

    [WebMethod]
    public string HelloWorld()
    {
        int res = 0;
        for (long i = 0; i < 1000000000; i++)    //循環10億次,目的是模仿大批量操作,這里至少需要數秒的操作以便看出異步的效果
        {
            res++;
        }
        return " Hello World";
    }

}

webservice創建好了,新建一個winform項目,引入webservice,我在引入webservice的時候,差點被坑爹了,原來。VS里是提供

Add Service References 和 Add Web References
這兩種,其實就是年代遺留下來的問題。web引用是2.0版本的,而服務引用是3.5版本的,微軟為了保持向前兼容的特性,也保留了這兩種方法,分別可以看這里

添加web引用和添加服務引用有什么區別?Add Service References 和 Add Web References 有啥區別?

\
 

項目右鍵 添加服務引用,如果你用的是VS2008,菜單可能是添加web引用。

 

\
 

如果是本地做學習測試之用的,瀏覽器瀏覽你創建的webservice,得到URL,如果是使用網絡上的webservice,這里則輸入給予的URL地址,點擊前往即可,

再看看左下角的高級按鈕嗎?點擊高級吧!!

\
 

把生成異步操作(必須勾上,不然沒有異步方法)勾上,生成消息合同也需勾上,看到左下角的添加WEB引用了嗎?這就是基於.NET Framework2.0 的。點擊確定即可完成引入webservice。

兩種不同版本的引入webservice也將造成代碼的不同,所以,為了說明這個問題,我們也把2.0的引入方法也說明一下。

\
 

2.0的引入方法更加簡潔,如果你在看浪曦的webservice視頻教程,肯定很熟悉這個界面。我個人也是比較喜歡這種方法的。

編寫代碼

localhost.GetWebService webservice = new localhost.GetWebService(); //通過2.0的添加WEB引用需要這種方式new出webservice對象      

    ServiceReference1.GetWebServiceSoapClient getWebService = new ServiceReference1.GetWebServiceSoapClient(); //通過添加服務引用需要這種方式new出webservice對象

    //同步調用webservice
     private void btnSyn_Click(object sender, EventArgs e)
     {
         string res = webservice.HelloWorld();
         this.textBox1.Text += "完成了";
         this.textBox1.Text += res + System.Environment.NewLine;
     }

     //異步調用webservice
     private void btnAsyn_Click(object sender, EventArgs e)
     {
         //給HelloWorld方法注冊調用完成時執行的方法AsyncHelloWorldComplete
         webservice.HelloWorldCompleted += new localhost.HelloWorldCompletedEventHandler(AsyncHelloWorldComplete);
         //開始異步調用
         webservice.HelloWorldAsync();
         this.textBox1.Text += "完成了" + System.Environment.NewLine;
     }

     //完成webservice操作時會執行的方法
     void AsyncHelloWorldComplete(object sender, localhost.HelloWorldCompletedEventArgs e)
     {
         string res = e.Result;
         this.textBox1.Text += res + System.Environment.NewLine;
     }

  

代碼說明:

\
 

1、HelloWorld方法:同步直接調用webservice的方法,返回結果時輸出“成功了”加上返回的結果;
2、webservice.HelloWorldAsync() :開始異步調用webservice
3、HelloWorldCompleted是webservice為我們提供委托調用,意思是將操作完成時執行的操作給參數中的方法執行,本例給了AsyncHelloWorldComplete方法執行;

執行效果:運行本例程序,你會發現,同步調用方法中,“完成了”這句話會與執行結果“Hello World”一起輸出,在webservice還沒執行完成的時候,小華不會打小明;
而異步調用方法中,“完成了”這句話先是輸出到文本框中,等了數秒之后,再顯示“Hello World”。這就是同步與異步調用webservice的區別了

如果需要在WebForm中異步調用,需要在頁面屬性中設置可以異步:Async=”true”

  

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM