监听c tcp实现多个客户端与服务端数据与文件的传输

文件传输加速  时间:2021-01-12  阅读:()

C#菜鸟做这个东东竟然花了快三天的时间了 真是菜菜菜下面是我用C#写的一个简单的TCP通信 主要的功能有

1 多个客户端与服务器间的数据交流

2可以实现群发的功能

3客户端与服务端可以进行文件的传输

主要用到的知识 TCP里的 socket 、 、 、 多线程Thread 、 、 、

下面的是界面

下面分别是服务端和客户端的代码如若借用 请标明出处~~~服务端代码

[csharp]view plaincopyprint?using System;using System.Col lections.Generic;using System.ComponentModel ;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Windows.Forms;using System.Net.Sockets;using System.Net;//IP IPAddress, IPEndPoint 端口等using System.Threading;using System.IO;namespace_11111

{publ ic partial class frm_server :Form

{publ icfrm_server()

{

Initial izeComponent();

TextBox.CheckForIl legalCrossThreadCal ls=false;

}

Thread threadWatch=nul l ;// 负责监听客户端连接请求的线程

Socket socketWatch=nul l ;

Dictionary<string,Socket>dict=new Dictionary<string,Socket>();

Dictionary<string,Thread>dictThread=new Dictionary<string,Thread>();private void btnBeginListen_Cl ick(object sender,EventArgs e)

{

//创建负责监听的套接字 注意其中的参数socketWatch = new Socket(AddressFami ly.InterNetwork, SocketType.Stream,ProtocolType.Tcp);

//获得文本框中的IP对象

IPAddress address=IPAddress.Parse(txtIp.Text.Trim());

//创建包含ip和端口号的网络节点对象

IPEndPoint endPoint=new IPEndPoint(address, int.Parse(txtPort.Text.Trim()));t ry

{

//将负责监听的套接字绑定到唯一的ip和端口上socketWatch.Bind(endPoint);

}catch(SocketException se)

{

MessageBox.Show("异常 "+se.Message);return;

}

//设置监听队列的长度socketWatch.Li sten(10);

//创建负责监听的线程threadWatch=new Thread(WatchConnecting);threadWatch.IsBackground=true;threadWatch.Start();

ShowMsg("服务器启动监听成功 ");

//}

}

///<summary>

///监听客户端请求的方法

///</summary>voidWatchConnecting()

{while(true)//持续不断的监听客户端的连接请求

{

//开始监听客户端连接请求 Accept方法会阻断当前的线程

Socket sokConnection=socketWatch.Accept();//一旦监听到一个客户端的请求就返回一个与该客户端通信的套接字

//想列表控件中添加客户端的IP信息lbOnline.Items.Add(sokConnection.RemoteEndPoint.ToString());

//将与客户端连接的套接字对象添加到集合中dict.Add(sokConnection.RemoteEndPoint.ToString(), sokConnection);

ShowMsg("客户端连接成功 ");

Thread thr=new Thread(RecMsg);thr.IsBackground=true;thr.Start(sokConnection);dictThread.Add(sokConnection.RemoteEndPoint.ToString(), thr); //将新建的线程 添加到线程的集合中去。

}

}void RecMsg(object sokConnectionparn)

{

Socket sokCl ient=sokConnectionparn as Socket;while(true)

{

//定义一个2M的缓存区byte[]arrMsgRec=new byte[1024*1024*2];

//将接受到的数据存入到输入arrMsgRec中int length=-1 ;t ry

{length=sokCl ient.Receive(arrMsgRec);//接收数据 并返回数据的长度

}catch(SocketException se)

{

ShowMsg("异常 "+se.Message);

//从通信套接字 集合中删除被中断连接的通信套接字dict.Remove(sokClient.RemoteEndPoint.ToString());

//从通信线程集合中删除被中断连接的通信线程对象dictThread.Remove(sokClient.RemoteEndPoint.ToString());

//从列表中移除被中断的连接IP lbOnline.Items.Remove(sokClient.RemoteEndPoint.ToString());break;

}catch(Exception e)

{

ShowMsg("异常 "+e.Message);

//从通信套接字 集合中删除被中断连接的通信套接字dict.Remove(sokClient.RemoteEndPoint.ToString());

//从通信线程集合中删除被中断连接的通信线程对象dictThread.Remove(sokClient.RemoteEndPoint.ToString());

//从列表中移除被中断的连接IP lbOnline.Items.Remove(sokClient.RemoteEndPoint.ToString());break;

}if(arrMsgRec[0]==0)//表示接收到的是数据

{string strMsg= System.Text.Encoding.UTF8.GetString(arrMsgRec,1, length-1);//将接受到的字节数据转化成字符串

ShowMsg(strMsg);

}if(arrMsgRec[0]==1)//表示接收到的是文件

{

SaveFi leDialog sfd=new SaveFi leDialog();if(sfd.ShowDialog(this)==System.Windows.Forms.DialogResult.OK)

{//在上边的 sfd.ShowDialog  的括号里边一定要加上this否则就不会弹出 另存为 的对话框 而弹出的是本类的其他窗口  这个一定要注意   【解释 加了 this 的sfd.ShowDialog(this)  “另存为”窗口的指针才能被SaveFi leDialog 的对象调用 若不加thisSaveFi leDialog的对象调用的是本类的其他窗口了 当然不弹出“另存为”窗口。】stringfi leSavePath=sfd.Fi leName;//获得文件保存的路径

//创建文件流 然后根据路径创建文件using(Fi leStream fs=new Fi leStream(fileSavePath,Fi leMode.Create))

{fs.Write(arrMsgRec, 1, length- 1);

ShowMsg("文件保存成功 "+fi leSavePath);

}

}

}

}

}void ShowMsg(string str)

{txtMsg.AppendText(str+"\r\n");

}

//发送消息

private void btnSend_Cl ick(object sender,EventArgs e)

{string strMsg="服务器"+"\r\n"+" -->"+txtMsgSend.Text.Trim()+"\r\n";byte[] arrMsg= System.Text.Encoding.UTF8.GetBytes(strMsg); //将要发送的字符串转换成Utf-8字节数组byte[]arrSendMsg=new byte[arrMsg.Length+1];arrSendMsg[0]=0;//表示发送的是消息数据

Buffer.BlockCopy(arrMsg,0,arrSendMsg, 1,arrMsg.Length);string strKey="";strKey=lbOnline.Text.Trim();if(string.IsNullOrEmpty(strKey))//判断是不是选择了发送的对象

{

MessageBox.Show("请选择你要发送的好友   ");

}else

{dict[strKey].Send(arrSendMsg);//解决了 sokConnection是局部变量不能再本函数中引用的问题

ShowMsg(strMsg);txtMsgSend.Clear();

}

}

///<summary>

///群发消息

///</summary>

///<param name="sender"></param>

///<param name="e">消息</param>private void btnSendToAl l_Cl ick(object sender,EventArgs e)

{string strMsg="服务器"+"\r\n"+" -->"+txtMsgSend.Text.Trim()+"\r\n";byte[] arrMsg= System.Text.Encoding.UTF8.GetBytes(strMsg); //将要发送的字符串转换成Utf-8字节数组using System;using System.Col lections.Generic;using System.ComponentModel ;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Windows.Forms;using System.Net.Sockets;using System.Net; //IP IPAddress, IPEndPoint 端口等using System.Threading;

using System.IO;namespace_11111

{publ ic partial class frm_server :Form

{publ icfrm_server()

{

Initial izeComponent();

TextBox.CheckForIl legalCrossThreadCal ls=false;

}

Thread threadWatch=nul l ;// 负责监听客户端连接请求的线程

Socket socketWatch=nul l ;

Dictionary<string,Socket>dict=new Dictionary<string,Socket>();

Dictionary<string,Thread>dictThread=new Dictionary<string,Thread>();private void btnBeginListen_Cl ick(object sender,EventArgs e)

{

//创建负责监听的套接字 注意其中的参数socketWatch=new Socket(AddressFami ly.InterNetwork, SocketType.Stream,ProtocolType.Tcp);

//获得文本框中的IP对象

IPAddress address=IPAddress.Parse(txtIp.Text.Trim());

//创建包含ip和端口号的网络节点对象

IPEndPoint endPoint = new IPEndPoint(address,int.Parse(txtPort.Text.Trim()));t ry

{

//将负责监听的套接字绑定到唯一的ip和端口上socketWatch.Bind(endPoint);

}catch(SocketException se)

{

MessageBox.Show("异常 "+se.Message);return;

}

//设置监听队列的长度socketWatch.Li sten(10);

//创建负责监听的线程threadWatch=new Thread(WatchConnecting);threadWatch.IsBackground=true;threadWatch.Start();

ShowMsg("服务器启动监听成功 ");

//}

}

///<summary>

///监听客户端请求的方法

///</summary>voidWatchConnecting()

{while(true) //持续不断的监听客户端的连接请求

{

//开始监听客户端连接请求 Accept方法会阻断当前的线程

Socket sokConnection=socketWatch.Accept(); //一旦监听到一个客户端的请求 就返回一个与该客户端通信的套接字

//想列表控件中添加客户端的IP信息lbOnline.Items.Add(sokConnection.RemoteEndPoint.ToString());

//将与客户端连接的套接字对象添加到集合中dict.Add(sokConnection.RemoteEndPoint.ToString(), sokConnection);

ShowMsg("客户端连接成功 ");

Thread thr=new Thread(RecMsg);thr.IsBackground=true;thr.Start(sokConnection);dictThread.Add(sokConnection.RemoteEndPoint.ToString(), thr); //将新建的线程添加到线程的集合中去。

}

}void RecMsg(object sokConnectionparn)

{

Socket sokCl ient=sokConnectionparn as Socket;while(true)

{

//定义一个2M的缓存区byte[]arrMsgRec=new byte[1024*1024*2];

//将接受到的数据存入到输入 arrMsgRec中int length=-1 ;t ry

{length=sokCl ient.Receive(arrMsgRec);//接收数据 并返回数据的长度

}catch(SocketException se)

{

ShowMsg("异常 "+se.Message);

//从通信套接字 集合中删除被中断连接的通信套接字dict.Remove(sokClient.RemoteEndPoint.ToString());

//从通信线程集合中删除被中断连接的通信线程对象dictThread.Remove(sokClient.RemoteEndPoint.ToString());

//从列表中移除被中断的连接IP lbOnline.Items.Remove(sokClient.RemoteEndPoint.ToString());break;

}catch(Exception e)

{

ShowMsg("异常 "+e.Message);

//从通信套接字 集合中删除被中断连接的通信套接字dict.Remove(sokClient.RemoteEndPoint.ToString());

//从通信线程集合中删除被中断连接的通信线程对象dictThread.Remove(sokClient.RemoteEndPoint.ToString());

//从列表中移除被中断的连接IP lbOnline.Items.Remove(sokClient.RemoteEndPoint.ToString());break;

}if(arrMsgRec[0]==0) //表示接收到的是数据

{string strMsg =System.Text.Encoding.UTF8.GetString(arrMsgRec,1, length-1);//将接受到的字节数据转化成字符串

ShowMsg(strMsg);

}if(arrMsgRec[0]==1)//表示接收到的是文件

{

SaveFi leDialog sfd=new SaveFi leDialog();if (sfd.ShowDialog(this) ==System.Windows.Forms.DialogResult.OK)

{//在上边的sfd.ShowDialog  的括号里边一定要加上this否则就不会弹出 另存为 的对话框而弹出的是本类的其他窗口 这个一定要注意  【解释加了 this的sfd.ShowDialog(this)  “另存为”窗口的指针才能被SaveFi leDialog的对象调用若不加thisSaveFi leDialog的对象调用的是本类的其他窗口了当然不弹出“另存为”窗口。】string fi leSavePath=sfd.Fi leName;//获得文件保存的路径

//创建文件流 然后根据路径创建文件using (Fi leStream fs = new Fi leStream(fi leSavePath,Fi leMode.Create))

{

LOCVPS洛杉矶CN2线路KVM上线,洛杉矶/香港云地/香港邦联7折

LOCVPS发来了新的洛杉矶CN2线路主机上线通知,基于KVM架构,目前可与香港云地、香港邦联机房XEN架构主机一起适用7折优惠码,优惠后最低美国洛杉矶CN2线路KVM架构2GB内存套餐月付38.5元起。LOCPVS是一家成立较早的国人VPS服务商,目前提供洛杉矶MC、洛杉矶C3、和香港邦联、香港沙田电信、香港大埔、日本东京、日本大阪、新加坡、德国和荷兰等机房VPS主机,基于KVM或者XEN架构。...

PQS彼得巧 年中低至38折提供台湾彰化HiNet线路VPS主机 200M带宽

在六月初的时候有介绍过一次来自中国台湾的PQS彼得巧商家(在这里)。商家的特点是有提供台湾彰化HiNet线路VPS主机,起步带宽200M,从带宽速率看是不错的,不过价格也比较贵原价需要300多一个月,是不是很贵?当然懂的人可能会有需要。这次年中促销期间,商家也有提供一定的优惠。比如月付七折,年付达到38折,不过年付价格确实总价格比较高的。第一、商家优惠活动年付三八折优惠:PQS2021-618-C...

DMIT:美国cn2 gia线路vps,高性能 AMD EPYC/不限流量(Premium Unmetered),$179.99/月起

DMIT怎么样?DMIT最近动作频繁,前几天刚刚上架了日本lite版VPS,正在酝酿上线日本高级网络VPS,又差不多在同一时间推出了美国cn2 gia线路不限流量的美国云服务器,不过价格太过昂贵。丐版只有30M带宽,月付179.99美元 !!目前,美国云服务器已经有个4个套餐,分别是,Premium(cn2 gia线路)、Lite(普通直连)、Premium Secure(带高防的cn2 gia线...

文件传输加速为你推荐
主机租用电脑租赁多少钱一天,电脑租赁,优易租0元押金域名注册商最具权威的域名注册商免费虚拟主机空间免费的虚拟主机空间有没有ip代理地址代理ip地址是怎么来的?ip代理地址IP代理什么意思?虚拟主机申请个人虚拟主机怎么申请?php虚拟空间怎样修改php虚拟空间单个文件上传大小限制万网虚拟主机如何购买万网的虚拟主机?jsp虚拟主机java虚拟主机空间怎么选择,国内jsp虚拟主机比较稳定,现在java项目做好后需要推荐一下吧西安虚拟主机西部数码虚拟主机怎么样,西部数码云主机怎么样
便宜虚拟主机 私服服务器租用 免费linux主机 日本私人vps vps虚拟服务器 域名备案批量查询 域名备案只选云聚达 服务器配置技术网 hostmaster vps.net 新加坡服务器 sugarsync shopex空间 双11抢红包攻略 华为云主机 镇江联通宽带 免费防火墙 台湾谷歌 如何建立邮箱 web服务器搭建 更多