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))
{
极光KVM创立于2018年,主要经营美国洛杉矶CN2机房、CeRaNetworks机房、中国香港CeraNetworks机房、香港CMI机房等产品。其中,洛杉矶提供CN2 GIA、CN2 GT以及常规BGP直连线路接入。从名字也可以看到,VPS产品全部是基于KVM架构的。极光KVM也有明确的更换IP政策,下单时选择“IP保险计划”多支付10块钱,可以在服务周期内免费更换一次IP,当然也可以不选择,...
【双十二】兆赫云:全场vps季付六折优惠,低至50元/季,1H/1G/30M/20G数据盘/500G流量/洛杉矶联通9929商家简介:兆赫云是一家国人商家,成立2020年,主要业务是美西洛杉矶联通9929线路VPS,提供虚拟主机、VPS和独立服务器。VPS采用KVM虚拟架构,线路优质,延迟低,稳定性强。是不是觉得黑五折扣力度不够大?还在犹豫徘徊中?这次为了提前庆祝双十二,特价推出全场季付六折优惠。...
buyvm正式对外开卖第四个数据中心“迈阿密”的块存储服务,和前面拉斯维加斯、纽约、卢森堡一样,依旧是每256G硬盘仅需1.25美元/月,最大支持10T硬盘。配合buyvm自己的VPS,1Gbps带宽、不限流量,在vps上挂载块存储之后就可以用来做数据备份、文件下载、刷BT等一系列工作。官方网站:https://buyvm.net支持信用卡、PayPal、支付宝付款,支付宝付款用的是加元汇率,貌似...