Web Service 小练习

     对于网站与网站之间数据互动，这是我的说法，不是专家说的，不要相信。应该有专业的说法。

     从他人的网站通过一个接口获取数据，这一直是我感到神奇的事，怎么实现的，一直萦绕于心，想要弄过究竟，怎么是实现的啊！不止一次在群里听到同样的提问。可惜每次我都没有深入探究，自己太懒惰了，不想动手实践，想找现成的，可惜也没有去找。

     还是要工作压力驱使，不然也许这个一直对我来说是一个疑惑。工作中有这么一个任务就是通过接口去获取供应商的数据，还好已经有现成的了，我只要看懂，然后模仿做一个就可以了，不过也费了我不少时间。发现有两种方式：一是通过xml，二是通过web service。我做的是用xml实现，而另外一种当时就没有深入去探究了。但是在我心里一直是一个结，我要试一试，实现它。于是有了今天的结果。一个小小实验。

   我是用asp.net 4.0实验的 两个项目，模拟两个网站。其实也包含了几个知识点：web Service，数据压缩，流数据等，dataset 与流的互转化。

  web Service 端代码，从数据库中获取数据，然后使用了压缩，流传递数据

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.Services;
using System.Data;
using System.Data.SqlClient;
using System.Text;
using System.IO;
using System.Runtime.Serialization.Formatters.Binary;
using System.Runtime.Serialization;
using System.IO.Compression;


namespace WebSiteTest
{
    /// <summary>
    /// WebServiceSend 的摘要说明
    /// </summary>
    [WebService(Namespace = "http://tempuri.org/")]
    [WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)]
    [System.ComponentModel.ToolboxItem(false)]
    // 若要允许使用 ASP.NET AJAX 从脚本中调用此 Web 服务，请取消对下行的注释。
    // [System.Web.Script.Services.ScriptService]
    public class WebServiceSend : System.Web.Services.WebService
    {

        [WebMethod]
        public string HelloWorld()
        {
            return "Hello World";
        }

        [WebMethod]
        public int add( int a, int b) 
        {
            return a + b;
        }

        //用流发送数据
        [WebMethod]
        public byte[] getdata(int id)
        {
            byte[] bArrayResult = null;
            string sqlstr = "select * from   BlogArticle where BlogId>" + id;
            DataSet ds=new DataSet();
            using (SqlConnection conn = new SqlConnection(connstr))
            {
                conn.Open();
                using (SqlCommand cmd = new SqlCommand())
                {
                    cmd.CommandText = sqlstr;
                    cmd.CommandType = CommandType.Text;
                    cmd.Connection = conn;
                    SqlDataAdapter dap = new SqlDataAdapter(cmd);
                    dap.Fill(ds);
                    ds.RemotingFormat = SerializationFormat.Binary;
                    MemoryStream ms = new MemoryStream();
                    IFormatter bf = new BinaryFormatter();
                    bf.Serialize(ms, ds);
                    bArrayResult = ms.ToArray();
                    ms.Close();
                    return Compress(bArrayResult);
                    //return dt.Rows[0]["BlogTitle"].ToString();
                }
            }

        }

        //[WebMethod]
        //public byte[] getgzipdata(int id)
        //{
        //    byte[] bArrayResult = null;
        //    string sqlstr = "select * from   BlogArticle where BlogId>" + id;
        //    DataSet ds = new DataSet();
        //    using (SqlConnection conn = new SqlConnection(connstr))
        //    {
        //        conn.Open();
        //        using (SqlCommand cmd = new SqlCommand())
        //        {
        //            cmd.CommandText = sqlstr;
        //            cmd.CommandType = CommandType.Text;
        //            cmd.Connection = conn;
        //            SqlDataAdapter dap = new SqlDataAdapter(cmd);
        //            dap.Fill(ds);
        //            ds.RemotingFormat = SerializationFormat.Binary;
                 
        //            MemoryStream ms = new MemoryStream();
        //            IFormatter bf = new BinaryFormatter();
        //            bf.Serialize(ms, ds);
        //            bArrayResult = ms.ToArray();
        //            ms.Close();
        //            return bArrayResult;
        //            //return dt.Rows[0]["BlogTitle"].ToString();
        //        }
        //    }
        //}
        //压缩流数据
        public static byte[] Compress(byte[] bytes)
        {
            using (MemoryStream ms = new MemoryStream())
            {
                GZipStream Compress = new GZipStream(ms, CompressionMode.Compress);

                Compress.Write(bytes, 0, bytes.Length);

                Compress.Close();

                return ms.ToArray();

            }
        }
        private static string connstr = "Data Source=.;Initial Catalog=mytest;Integrated Security=True";//数据库连接
       
    }
}

 压缩前数据大小如图片一

 压缩后数据大小如图片二

   接收端 代码，需要web引用

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Data;
using System.IO;
using System.Runtime.Serialization;
using System.Runtime.Serialization.Formatters.Binary;
using System.IO.Compression;


namespace WebReceivetest
{
    public partial class WebForm1 : System.Web.UI.Page
    {
        protected void Page_Load(object sender, EventArgs e)
        {

        }

        protected void btntest_Click(object sender, EventArgs e)
        {
            MyWebTest.WebServiceSend websend = new MyWebTest.WebServiceSend();
            int first = int.Parse(txtfirst.Text);
            int second = int.Parse(txtsecond.Text);
            int result = websend.add(first, second);
            labresult.Text = result.ToString();
            //string xx=websend.getdata(10);
            //labresult.Text = result.ToString() + "-----------" + xx;
            DataSet ds = BinaryToDataset(websend.getdata(151));//151是数据库中的一个id编号
            GridView1.DataSource = ds;
            GridView1.DataBind();
                
        }
        //流转换为dataset数据
        public DataSet BinaryToDataset(byte[] bUserData)
        {
            if (bUserData == null)
            {
                //MessageBox.Show("二进制数据流为空");
                //err = "";
                return null;
            }
            // 反序列化的过程
            MemoryStream ms = new MemoryStream(Decompress(bUserData));
            IFormatter bf = new BinaryFormatter();
            object obj = bf.Deserialize(ms);
            DataSet dsResult = (DataSet)obj;
            ms.Close();
            return dsResult;
        }

        //解压流数据
        public static byte[] Decompress(Byte[] bytes)
        {
            using (MemoryStream tempMs = new MemoryStream())
            {
                using (MemoryStream ms = new MemoryStream(bytes))
                {
                    GZipStream Decompress = new GZipStream(ms, CompressionMode.Decompress);

                    Decompress.CopyTo(tempMs);

                    Decompress.Close();

                    return tempMs.ToArray();
                }
            }
        }
    }
}

解压前数据大小如图片三

 压缩后数据大小如图片四

 

 通过这一次小实验，心中的疑惑完全消除了。实践——求真——消除疑惑。

参考：http://www.cnblogs.com/zhangzheny/archive/2007/06/16/785734.html

http://www.cnblogs.com/amylis_chen/archive/2012/11/06/2757808.html

http://www.cnblogs.com/qugangf/archive/2011/04/11/2012193.html