学步园

webservice服务端方法

1. using System;
2. using System.Collections.Generic;
3. using System.ComponentModel;
4. using System.Data;
5. using System.Drawing;
6. using System.Text;
7. using System.Windows.Forms;
9. using System.IO;
10. using System.IO.Compression;
11. using System.Data.SqlClient;
12. using System.Runtime.Serialization.Formatters.Binary;
14. namespace Test
15. {
16.     public partial class Form1 : Form
17.     {
18.         public Form1()
19.         {
20.             InitializeComponent();
21.         }
23.         private void BindDataSet(DataSet DS)
24.         {
25.             this.dataGridView1.DataSource = DS.Tables[0];
26.         }
29.         private void button1_Click(object sender, EventArgs e)
30.         {
31.             com.dzbsoft.www.DataSetService ds = new Test.com.dzbsoft.www.DataSetService();
32.             DateTime dtBegin = DateTime.Now;
33.             DataSet DS = ds.GetDataSet();
34.             this.label1.Text = string.Format("耗时：{0}", DateTime.Now - dtBegin);
35.             BindDataSet(DS);
36.         }
38.         private void button2_Click(object sender, EventArgs e)
39.         {
40.             com.dzbsoft.www.DataSetService ds = new Test.com.dzbsoft.www.DataSetService();
41.             DateTime dtBegin = DateTime.Now;
42.             byte[] buffer = ds.GetDataSetBytes();
43.             DataSet DS = ds.GetDataSet();
44.             BinaryFormatter ser = new BinaryFormatter();
45.             DataSet dataset = ser.Deserialize(new MemoryStream(buffer)) as DataSet;
46.             this.label2.Text = string.Format("耗时：{0}", DateTime.Now - dtBegin + "          " + buffer.Length.ToString());
47.             BindDataSet(DS);
48.         }
50.         private void button3_Click(object sender, EventArgs e)
51.         {
52.             com.dzbsoft.www.DataSetService ds = new Test.com.dzbsoft.www.DataSetService();
53.             DateTime dtBegin = DateTime.Now;
54.             byte[] buffer = ds.GetDataSetSurrogateBytes();
55.             BinaryFormatter ser = new BinaryFormatter();
56.             DataSet DS = ds.GetDataSet();
57.             DataSetSurrogate dss = ser.Deserialize(new MemoryStream(buffer)) as DataSetSurrogate;
58.             DataSet dataset = dss.ConvertToDataSet();
59.             this.label3.Text = string.Format("耗时：{0}", DateTime.Now - dtBegin + "          " + buffer.Length.ToString());
60.             BindDataSet(DS);
61.         }
63.         private void button4_Click(object sender, EventArgs e)
64.         {
65.             com.dzbsoft.www.DataSetService ds = new Test.com.dzbsoft.www.DataSetService();
66.             DateTime dtBegin = DateTime.Now;
67.             byte[] zipBuffer = ds.GetDataSetSurrogateZipBytes();
68.             byte[] buffer = UnZipClass.Decompress(zipBuffer);
69.             BinaryFormatter ser = new BinaryFormatter();
70.             DataSet DS = ds.GetDataSet();
71.             DataSetSurrogate dss = ser.Deserialize(new MemoryStream(buffer)) as DataSetSurrogate;
72.             DataSet dataset = dss.ConvertToDataSet();
73.             this.label4.Text = string.Format("耗时：{0}", DateTime.Now - dtBegin + "          " + zipBuffer.Length.ToString());
74.             BindDataSet(DS);
75.         }
79.     }
80. }

 

调用端：

1. using System;
2. using System.Data;
3. using System.Web;
4. using System.Collections;
5. using System.Web.Services;
6. using System.Web.Services.Protocols;
7. using System.ComponentModel;
9. using System.IO;
10. using System.IO.Compression;
11. using System.Data.SqlClient;
12. using System.Runtime.Serialization.Formatters.Binary;
15. namespace DataSetWebService
16. {
17.     /// <summary>
18.     /// Service1 的摘要说明
19.     /// </summary>
20.     [WebService(Namespace = "http://tempuri.org/")]
21.     [WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)]
22.     [ToolboxItem(false)]
23.     public class DataSetService : System.Web.Services.WebService
24.     {
26.         [WebMethod(Description="直接返回DataSet对象")]
27.         public DataSet GetDataSet()
28.         {
29.             //http://www.dzbsoft.com  XT_TEXT
30.             string sql = "select * from XT_TEXT";
31.             SqlConnection conn = new SqlConnection("Server=60.28.25.58;DataBase=s168593;user id=s168593;password=h0y+FeC*;");
32.             conn.Open();
33.             SqlDataAdapter dataAd = new SqlDataAdapter(sql, conn);
34.             DataSet DS = new DataSet("XT_TEXT");
35.             dataAd.Fill(DS);
36.             conn.Close();
37.             return DS;
38.         }
41.         [WebMethod(Description = "返回DataSet对象用Binary序列化后的字节数组")]
42.         public byte[] GetDataSetBytes()
43.         {
44.             DataSet DS = GetDataSet();
45.             BinaryFormatter ser = new BinaryFormatter();
46.             MemoryStream ms = new MemoryStream();
47.             ser.Serialize(ms, DS);
48.             byte[] buffer = ms.ToArray();
49.             return buffer;
50.         }
54.         [WebMethod(Description = "返回DataSetSurrogate对象用Binary序列化后的字节数组")]
55.         public byte[] GetDataSetSurrogateBytes()
56.         {
57.             DataSet DS = GetDataSet();
58.             DataSetSurrogate dss = new DataSetSurrogate(DS);
59.             BinaryFormatter ser = new BinaryFormatter();
60.             MemoryStream ms = new MemoryStream();
61.             ser.Serialize(ms, dss);
62.             byte[] buffer = ms.ToArray();
63.             return buffer;
64.         }
66.         [WebMethod(Description = "返回DataSetSurrogate对象用Binary序列化并ZIP压缩后的字节数组")]
67.         public byte[] GetDataSetSurrogateZipBytes()
68.         {
69.             DataSet DS = GetDataSet();
70.             DataSetSurrogate dss = new DataSetSurrogate(DS);
71.             BinaryFormatter ser = new BinaryFormatter();
72.             MemoryStream ms = new MemoryStream();
73.             ser.Serialize(ms, dss);
74.             byte[] buffer = ms.ToArray();
75.             byte[] Zipbuffer = Compress(buffer);
76.             return Zipbuffer;
77.         }
79.         public byte[] Compress(byte[] data)
80.         {
81.             MemoryStream ms = new MemoryStream();
82.             Stream zipStream = null;
83.             zipStream = new GZipStream(ms, CompressionMode.Compress, true);
84.             zipStream.Write(data, 0, data.Length);
85.             zipStream.Close();
86.             ms.Position = 0;
87.             byte[] compressed_data = new byte[ms.Length];
88.             ms.Read(compressed_data, 0, int.Parse(ms.Length.ToString()));
89.             return compressed_data;
90.         }
91.     }
92. }

调用的时候的解压缩方法：

 

 

1. using System;
2. using System.Collections.Generic;
3. using System.Text;
4. using System.IO;
5. using System.IO.Compression;
7. namespace Test
8. {
9.     public static class UnZipClass
10.     {
11.         /// <summary>
12.         /// Decompresses the specified data.
13.         /// </summary>
14.         /// <param name="data">The data.</param>
15.         /// <returns></returns>
16.         public static byte[] Decompress(byte[] data)
17.         {
18.             try
19.             {
20.                 MemoryStream ms = new MemoryStream(data);
21.                 Stream zipStream = null;
22.                 zipStream = new GZipStream(ms, CompressionMode.Decompress);
23.                 byte[] dc_data = null;
24.                 dc_data = EtractBytesFormStream(zipStream, data.Length);
25.                 return dc_data;
26.             }
27.             catch
28.             {
29.                 return null;
30.             }
31.         }
34.         public static byte[] EtractBytesFormStream(Stream zipStream, int dataBlock)
35.         {
36.             try
37.             {
38.                 byte[] data = null;
39.                 int totalBytesRead = 0;
40.                 while (true)
41.                 {
42.                     Array.Resize(ref data, totalBytesRead + dataBlock + 1);
43.                     int bytesRead = zipStream.Read(data, totalBytesRead, dataBlock);
44.                     if (bytesRead == 0)
45.                     {
46.                         break;
47.                     }
48.                     totalBytesRead += bytesRead;
49.                 }
50.                 Array.Resize(ref data, totalBytesRead);
51.                 return data;
52.             }
53.             catch
54.             {
55.                 return null;
56.             }
57.         }
58.     }
59. }