Socket网络编程学习笔记(5)发送和接收实体类数据.doc

《Socket网络编程学习笔记(5)发送和接收实体类数据.doc》由会员分享，可在线阅读，更多相关《Socket网络编程学习笔记(5)发送和接收实体类数据.doc（11页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、Socket网络编程学习笔记（5）：发送和接收实体类数据 在前面讲述的篇幅中，发送的都是文本信息，我们只要通过Encoding中的几个方法把文本转化成二进制数组就可以利用Socket来传输了，这对于一些基本的信息传输能够得到满足，但对于一些复杂的消息交流，则有些“吃力”。我们有时候会把一些信息封闭在一个类中，如果Socket能够传送类对象，那么一些复杂的问题能够通过面向对象来解决了，即方便又安全。大家都知道，要想在网络上传输信息，必须要经过序列化才行，所以在传送类对象时，首选必须对该类对象进行序列化，才能够在网络上进行传输。序列化类对象有三种序列化方法：1、Xml序列化2、Binary序列化3

2、、Soap序列化这几种序列化方法，运用方法相类似，只不过用到的类不一样。在这里也不一一讲述了，有兴趣的朋友可以到网上搜一搜，相信会有不少的收获。这里主要讲一下利用Soap序列化来传送消息。1、首先我们先来建立一个实体类，用来做消息的载体类对象1usingSystem;2usingSystem.Collections.Generic;3usingSystem.Text;45namespacesbwConsole67Serializable8publicclassSocketData910privateOperateType_operateType;11privateOperateInfo_ope

3、rateInfo;12privatestring_connString;13privatestring_clientIP;14privatestring_serverIP;1516/*/17/指令传输数据18/19/指令类型20/指令信息21/ASP数据库连接字符串22/子服务器IP23/ASP服务器IP24publicSocketData(OperateTypeoperateType,OperateInfooperateInfo,25stringconnString,stringclientIP,stringserverIP)2627_operateType=operateType;28_o

4、perateInfo=operateInfo;29_connString=connString;30_clientIP=clientIP;31_serverIP=serverIP;323334/*/35/指令类型36/37publicOperateTypeOperateType3839getreturn_operateType;40set_operateType=value;4142/*/43/指令信息44/45publicOperateInfoOperateInfo4647getreturn_operateInfo;48set_operateInfo=value;4950/*/51/ASP数

5、据库连接字符串52/53publicstringConnString5455getreturn_connString;56set_connString=value;5758/*/59/子服务器IP60/61publicstringClientIP6263getreturn_clientIP;64set_clientIP=value;6566/*/67/ASP服务器IP68/69publicstringServerIP7071getreturn_serverIP;72set_serverIP=value;73747576/*/77/指令类型78/79publicenumOperateType80

6、81/*/82/网站操作83/84Web=0,85/*/86/升级87/88Upgrade,89/*/90/迁移91/92Transfer939495/*/96/指令信息97/98publicenumOperateInfo99100/*/101/发送102/103Send=0,104/*/105/出错106/107Error,108/*/109/成功110/111Success,112/*/113/重发114/115SendAgain1161171182、发送前先把类对象进行Soap序列化消息发送方法1publicstaticvoidSend(NetworkStreamns,SocketDat

7、asd)23IFormatterformatter=newSoapFormatter();4MemoryStreammem=newMemoryStream();56formatter.Serialize(mem,sd);7bytedata=mem.GetBuffer();8intmemsize=(int)mem.Length;9bytesize=BitConverter.GetBytes(memsize);10ns.Write(size,0,4);11ns.Write(data,0,memsize);12ns.Flush();13mem.Close();14这里利用IFormatter for

8、matter = new SoapFormatter(); MemoryStream mem = new MemoryStream(); formatter.Serialize(mem, sd);对类对象sd进行序列化。在这里还有一个细节值得一提，那就是消息边界问题的处理，这里是利用发送消息的长度方法来实现。代码如下：1intmemsize=(int)mem.Length;2bytesize=BitConverter.GetBytes(memsize);3ns.Write(size,0,4);通过BitConverter.GetBytes()方法可以把数据类型转化为二进制数组，从而可以在网络上

9、传送，所以在接收的时候先接收消息长度，再通过该长度来循环读取完整的消息。3、接收消息接收消息方法1publicstaticSocketDataReceive(NetworkStreamns)23MemoryStreammem=newMemoryStream();4SocketDatasd;5bytedata=newbyte4;6intrevc=ns.Read(data,0,4);7intsize=BitConverter.ToInt32(data,0);8intoffset=0;910if(size0)1112while(size0)1314data=newbyte1024;15revc=ns

10、.Read(data,offset,size);16mem.Write(data,offset,revc);17offset+=revc;18size-=revc;192021IFormatterformatter=newSoapFormatter();22mem.Position=0;23sd=(SocketData)formatter.Deserialize(mem);24mem.Close();2526else2728sd=null;2930returnsd;31通过sd = (SocketData)formatter.Deserialize(mem);还原数据为类对象，就可以对此类对象

11、进行访问了。用Xml序列化或用二进制序列化也是类似，只不过把序列化的方法改一下就可以了，一般来说用二进制序列化得到的数据最小，占用带宽也最小，而用xml和Soap来序列化，都是序列化为Xml格式，所以数据比较大，占用带宽比较大。但用xml或Soap序列化，兼容性高，可以兼容不同系统之间的通信，而二进制不行。可以说各有利弊，可以根据实际情况来选择哪一种序列化。该篇暂时就写到这里了，文字有点乱，请见谅。源码下载：/Files/licongjie/SocketTest4.rarSocket网络编程学习笔记（6）：使用线程池提高性能 在前几篇介绍中，不论是服务端的侦听还是客户端的连接都是通过新建一个线

12、程去执行特定功能的。在这种情况下，一量有一个新客户端需要连接，则又得创建新的线程，而当程序创建新线程时，往往需要大量的内部开销，这对程序的性能有一定的影响。在.NET库中提供了一种方法，可以避免一些开销。而在Socket通讯中还有另一种访求那就是异步Socket，我不知道用这种方式的性能如何，在这里且不管这种形式，主要来看一下用线程池解决问题。Windows操作系允许用户维持一池“预先建立的”线程，这个线程池为应用程序中指定的方法提供工作线索。一个线程控制线程池的操作，并用应用程序可以分配附加的线程进行处理。在默认情况下，在线程池中有25个预处理线程，用这种方式可以满足一些小应用。如果要为线程

13、池中的线程注册一个代表，则用下面的格式：ThreadPool.QueueUserWorkItem(new WaitCallback(Counter);其中QueueUserWorkItem是ThreadPool类的一个静态方法；而Counter参数代表运行在线程中的方法，在这要注意的是该Counter方法必须包含一个object 参数，这个在下面的例子中有体现；另外，处Thread对象不一样，代表一旦放置在线程池查询中上，将被处理，不需要其他的方法启动该项工作；当主程序线程退出，所有的线程池线程都将终止，主线程不会等待线程池线程结束。下面我们来看看怎么样运用到我上面讲的例子中去：原有线程调用：clientThread = new Thread(new ThreadStart(ReceiveData);clientThread.Start();用线程池只要一句就可以了:ThreadPool.QueueUserWorkItem(new WaitCallback(ReceiveData);其它具体的请下载源码。源码下载：/Files/licongjie/SocketTest3.rar