Web Service 小练习

2022-09-29 16:49:26

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

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

还是要工作压力驱使，不然也许这个一直对我来说是一个疑惑。工作中有这么一个任务就是通过接口去获取供应商的数据，还好已经有现成的了，我只要看懂，然后模仿做一个就可以了，不过也费了我不少时间。发现有两种方式：一是通过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, , 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是数据库中的一个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

码农公寓

相关文章