Code
1为解决UDP传输中的可靠性和流量控制，参照TCP协议里面的滑动窗口协议写了一个流量控制的东东。还不完善，而且传输速度也不理想（单线程时外网速度才100多K/秒）。
2
3接收端目前还没做窗口控制，因为感觉接收端做不做都无所谓。。^_^
4
5usingSystem;
6usingSystem.Text;
7usingSystem.Collections;
8
9namespacescutnetTalkClient
10{
11///<summary>
12///消息分片类，用于对消息进行封包、解包。对每个数据拆分为定长（最后一个可能小于定长）的数据段，并存在一个以序列编号为key的Hashtable中。
13///主要用于对较大的图片信息进行拆包、封包
14///</summary>
15
16[System.Serializable]
17publicclassMsgSlice
18{
19publicstaticlongSLICE_MAX_LENGTH=1100;//数据片最大长度
20privatelongsliceId;//片唯一编号
21privateboolsliceEnd=false;//是否最后一片
22privatelongsliceIndex=0;//片在整个消息中的索引
23privatebyte[]sliceContent;//片内容
24publicboolisSimple=false;
25
26publicMsgSlice()
27{
28}
29
30publicMsgSlice(byte[]msg,boolisEnd,longid,longindex)
31{
32if(msg==null||msg.Length==0)
33{
34return;
35}
36this.sliceEnd=isEnd;
37this.sliceContent=msg;
38this.sliceId=id;
39this.sliceIndex=index;
40}
41
42//对二进制数据进行分片，并返回分片的Hashtable
43publicstaticHashtablesplitMsg(byte[]msg)
44{
45if(msg==null||msg.Length==0)
46{
47returnnull;
48}
49longlen=msg.Length;
50if(len<=MsgSlice.SLICE_MAX_LENGTH)
51{
52Hashtableh=newHashtable();
53h.Add((long)0,newMsgSlice(msg,true,1,(long)0));
54returnh;
55}
56longsliceNum=1;
57if(len%MsgSlice.SLICE_MAX_LENGTH==0)
58{
59sliceNum=len/MsgSlice.SLICE_MAX_LENGTH;
60}
61else
62{
63sliceNum=len/MsgSlice.SLICE_MAX_LENGTH+1;
64}
65Hashtablems=newHashtable();
66longid=1;
67longi=0;
68for(;i<sliceNum-1;i++)
69{
70byte[]tByte=MsgSlice.byteCopy(msg,i*MsgSlice.SLICE_MAX_LENGTH,MsgSlice.SLICE_MAX_LENGTH);
71ms.Add(i,newMsgSlice(tByte,false,id,i));
72}
73byte[]teByte=MsgSlice.byteCopy(msg,i*MsgSlice.SLICE_MAX_LENGTH,MsgSlice.SLICE_MAX_LENGTH);
74ms.Add(i,newMsgSlice(teByte,true,id,i));
75returnms;
76}
77
78//对字符串进行分片（重载）,并返回分片Hashtable
79publicstaticHashtablesplitMsg(stringmsg)
80{
81returnMsgSlice.splitMsg(System.Text.ASCIIEncoding.UTF8.GetBytes(msg));
82}
83
84//对分片数据进行重组
85publicstaticbyte[]uniteMsg(Hashtableh)
86{
87byte[]result=null;
88for(inti=0;i<h.Count;i++)
89{
90if(h[(long)i]!=null)
91{
92result=MsgSlice.byteAdd(result,((MsgSlice)h[(long)i]).sliceContent);
93Console.WriteLine("加入数据"+i);
94}
95else
96{
97Console.WriteLine("忽略空数据"+i);
98}
99}
100returnresult;
101}
102
103publicstaticbyte[]byteAdd(byte[]bt1,byte[]bt2)
104{
105if(bt1==null)
106{
107returnbt2;
108}
109if(bt2==null)
110{
111returnbt1;
112}
113
114longlen1=bt1.Length;
115longlen2=bt2.Length;
116
117byte[]result=newbyte[len1+len2];
118bt1.CopyTo(result,0);
119
120for(longi=0;i<len2;i++)
121{
122result[len1+i]=bt2[i];
123}
124returnresult;
125}
126
127publicstaticbyte[]byteCopy(byte[]source,longindex,longlen)
128{
129byte[]dest;
130if(index<0)
131{
132returnnull;
133}
134longsLen=source.Length;
135if(sLen<index+len)
136{
137dest=newbyte[sLen-index];
138}
139else
140{
141dest=newbyte[len];
142}
143longi=0;
144for(;i<dest.Length;i++)
145{
146dest[i]=source[index+i];
147}
148returndest;
149}
150
151publiclonggetSliceIndex()
152{
153returnthis.sliceIndex;
154}
155
156publiclonggetSliceId()
157{
158returnthis.sliceId;
159}
160
161publicboolisEndSlice()
162{
163returnthis.sliceEnd;
164}
165
166publicbyte[]getSliceContent()
167{
168returnthis.sliceContent;
169}
170
171/*
172[STAThread]
173staticvoidMain(string[]args)
174{
175System.Collections.Hashtablehashtable=newHashtable();
176
177stringa="--0123456789我－的－地－盘－我－作－猪--";
178//byte[]b=ASCIIEncoding.UTF8.GetBytes(a);
179Hashtablems=MsgSlice.splitMsg(a);
180byte[]b=MsgSlice.uniteMsg(ms);
181Console.WriteLine(System.Text.ASCIIEncoding.UTF8.GetString(b)+a.Length+"=="+b.Length);
182Console.ReadLine();
183}
184*/
185}
186}
187 优质内容筛选与推荐>>
1、VBScript 内置函数
2、shell 变量
3、修改 Spring Boot 默认页面
4、排序算法的稳定性及其汇总
5、iOS 微信支付SDK与微信友盟分享两者同时集成时，出现的问题与解决之路。