服务器端WebService程序using System.Runtime.Serialization.Formatters.Binary;
using System.IO;
using System.IO.Compression;
using System.Data.sqlClient;
………
public class Service1 : System.Web.Services.WebService
{
[WebMethod(Description = "直接返回 DataSet 对象。")]
public DataSet GetnorthwindDataSet()
{
string sql = "SELECT * FROM DB";
sqlConnection conn = new sqlConnection("Server=60.28.25.58;DataBase=s168593;user id=s168593;password=*****;");
conn.open();
sqlDataAdapter dataadapter = new sqlDataAdapter(sql, conn);
DataSet ds = new DataSet();
dataadapter.Fill(ds, "DB");
conn.Close();
return ds;
}
[WebMethod(Description = "返回 DataSet 对象用 Binary 序列化后的字节数组。")]
public byte[] GetDataSetBytes()
{
DataSet dataSet = GetnorthwindDataSet();
BinaryFormatter ser = new BinaryFormatter();
MemoryStream ms = new MemoryStream();
ser.Serialize(ms, dataSet);
byte[] buffer = ms.ToArray();
return buffer;
}
[WebMethod(Description = "返回 DataSetSurrogate 对象用 Binary 序列化后的字节数组。")]
public byte[] GetDataSetSurrogateBytes()
{
DataSet dataSet = GetnorthwindDataSet();
DataSetSurrogate dss = new DataSetSurrogate(dataSet);
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 dataSet = GetnorthwindDataSet();
DataSetSurrogate dss = new DataSetSurrogate(dataSet);
BinaryFormatter ser = new BinaryFormatter();
MemoryStream ms = new MemoryStream();
ser.Serialize(ms, dss);
byte[] buffer = ms.ToArray();
byte[] zipBuffer = Compress(buffer);
return zipBuffer;
}
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, int.Parse(ms.Length.ToString()));
return compressed_data;
}
catch
{
return null;
}
}
}
using System.IO;
using System.IO.Compression;
using System.Data.sqlClient;
………
public class Service1 : System.Web.Services.WebService
{
[WebMethod(Description = "直接返回 DataSet 对象。")]
public DataSet GetnorthwindDataSet()
{
string sql = "SELECT * FROM DB";
sqlConnection conn = new sqlConnection("Server=60.28.25.58;DataBase=s168593;user id=s168593;password=*****;");
conn.open();
sqlDataAdapter dataadapter = new sqlDataAdapter(sql, conn);
DataSet ds = new DataSet();
dataadapter.Fill(ds, "DB");
conn.Close();
return ds;
}
[WebMethod(Description = "返回 DataSet 对象用 Binary 序列化后的字节数组。")]
public byte[] GetDataSetBytes()
{
DataSet dataSet = GetnorthwindDataSet();
BinaryFormatter ser = new BinaryFormatter();
MemoryStream ms = new MemoryStream();
ser.Serialize(ms, dataSet);
byte[] buffer = ms.ToArray();
return buffer;
}
[WebMethod(Description = "返回 DataSetSurrogate 对象用 Binary 序列化后的字节数组。")]
public byte[] GetDataSetSurrogateBytes()
{
DataSet dataSet = GetnorthwindDataSet();
DataSetSurrogate dss = new DataSetSurrogate(dataSet);
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 dataSet = GetnorthwindDataSet();
DataSetSurrogate dss = new DataSetSurrogate(dataSet);
BinaryFormatter ser = new BinaryFormatter();
MemoryStream ms = new MemoryStream();
ser.Serialize(ms, dss);
byte[] buffer = ms.ToArray();
byte[] zipBuffer = Compress(buffer);
return zipBuffer;
}
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, int.Parse(ms.Length.ToString()));
return compressed_data;
}
catch
{
return null;
}
}
}
客户端WebService程序
private void button1_Click(object sender, EventArgs e) { com.dzbsoft.www.Service1 ds = new com.dzbsoft.www.Service1(); 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; } } }版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。