1)如果“数据条数”定义是:客户端发送数据帧的数量,那么,服务器每当收到一次客户端的数据帧,计数就加1;例如,客户端A连续发送了“你好”,“我在这里”两条信息,服务器的计数就应该增加2;
2)服务器可以接收来自多个客户端的数据,可以分别统计每个客户端数据条数,也可以统计所以客户端数据总的条数。
针对上面两个需求,实现起来大致框架如下:
1)定义一个Dictionary<string, int>num,用来计数
Dictionary<string, int> num= new Dictionary<string, int>()其中,泛型参数string用于表示客户端;int用于计数
2)每当服务器接收到来自客户端数据后,可以获得客户端的IPEndPoint clientEP,将clientEP转换成字符串,作为Dictionary 的键值,用来标识客户端
string client = clientEP.ToString()if(!num.ContainsKey(client))
{
//在集合中添加一个客户端计数项
num.Add(client, 0)
}
//数据条数加1
num[client]++
3)分别统计并显示每个客户的数据条件
foreach( var c in num){
Console.WriteLine("客户端{0},总数{1}", c.Key, c.Value)
}
4)统计并显示服务器接收到所有客户端数据条数的总数
var qry = from c in num.Values select cConsole.WriteLine("接收总数{0}", qry.Sum())
接收到的数据是byte[]数组格式的,需要进行一步简单的转换。如果你第一步接收已经做完了,那么可能这步转换就省了byte[] byts=new byte[1024*1024*2];//定义接收数组,大小为2m根据需要,一般设置为1就够了,因为简单接收,不会有太大数据量的。
int length=socket.Receive(byts, 0, byts.Length, SocketFlags.None);//开始接收数据,并将接收到数据放到byts数组中。它的返回值为一个整型,是指接收数据的数量
if(length>0)
{
string msg = System.Text.Encoding.UTF8.GetString(byts, 0, r)
}
OK,到这步,你应该就会了吧,此时拿到的msg就是接收到回来的字符串了。然后启动数据库连接,将msg写入对应的表就可以了。
Receive的返回值是接收的字节数,当是0时表示传送结束,否则循环接收缓冲区不用太大,8k或64k看情况
Byte[] RecvBytes = new Byte[1024*8]
int iBytes = 1
string strAllHtml = ""
while (iBytes >0)
{
iBytes = conn.Receive(RecvBytes, RecvBytes.Length, 0)
strAllHtml += Encoding.UTF8.GetString(RecvBytes, 0, iBytes)
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)