《CTCP实现多个客户端与服务端数据与文件的传输.doc》由会员分享,可在线阅读,更多相关《CTCP实现多个客户端与服务端数据与文件的传输.doc(19页珍藏版)》请在课桌文档上搜索。
1、-C#菜鸟做这个东东竟然花了快三天的时间了,真是菜,菜,菜下面是我用C#写的 一个简单的TCP通信,主要的功能有:1 多个客户端与效劳器间的数据交流2可以实现群发的功能3客户端与效劳端可以进展文件的传输主要用到的知识: TCP里的 socket 、 多线程 Thread 、下面的是界面:下面分别是效劳端和客户端的代码,如假设借用,请标明出处效劳端代码:csharp view plaincopyprint?using System; using System.Collections.Generic; using System.ComponentModel; using System.Data;
2、using System.Drawing; using System.Linq; using System.Te*t; using System.Windows.Forms; using System.Net.Sockets; using System.Net; / IP,IPAddress, IPEndPoint,端口等; using System.Threading; using System.IO; namespace _11111 public partial class frm_server : Form public frm_server() InitializeComponent
3、(); Te*tBo*.CheckForIllegalCrossThreadCalls = false; Thread threadWatch = null; / 负责监听客户端连接请求的 线程; Socket socketWatch = null; Dictionary dict = new Dictionary(); Dictionary dictThread = new Dictionary(); private void btnBeginListen_Click(object sender, EventArgs e) / 创立负责监听的套接字,注意其中的参数; socketWatch
4、= new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); / 获得文本框中的IP对象; IPAddress address = IPAddress.Parse(t*tIp.Te*t.Trim(); / 创立包含ip和端口号的网络节点对象; IPEndPoint endPoint = new IPEndPoint(address, int.Parse(t*tPort.Te*t.Trim(); try / 将负责监听的套接字绑定到唯一的ip和端口上; socketWatch.Bind(endPoin
5、t); catch (SocketE*ception se) MessageBo*.Show(异常:+se.Message); return; / 设置监听队列的长度; socketWatch.Listen(10); / 创立负责监听的线程; threadWatch = new Thread(WatchConnecting); threadWatch.IsBackground = true; threadWatch.Start(); ShowMsg(效劳器启动监听成功!); / / / 监听客户端请求的方法; / void WatchConnecting() while (true) / 持续
6、不断的监听客户端的连接请求; / 开场监听客户端连接请求,Accept方法会阻断当前的线程; Socket sokConnection = socketWatch.Accept(); / 一旦监听到一个客户端的请求,就返回一个与该客户端通信的 套接字; / 想列表控件中添加客户端的IP信息; lbOnline.Items.Add(sokConnection.RemoteEndPoint.ToString(); / 将与客户端连接的 套接字 对象添加到集合中; dict.Add(sokConnection.RemoteEndPoint.ToString(), sokConnection); Sh
7、owMsg(客户端连接成功!); Thread thr = new Thread(RecMsg); thr.IsBackground = true; thr.Start(sokConnection); dictThread.Add(sokConnection.RemoteEndPoint.ToString(), thr); / 将新建的线程 添加 到线程的集合中去。 void RecMsg(object sokConnectionparn) Socket sokClient = sokConnectionparn as Socket; while (true) / 定义一个2M的缓存区; by
8、te arrMsgRec = new byte1024 * 1024 * 2; / 将承受到的数据存入到输入 arrMsgRec中; int length = -1; try length = sokClient.Receive(arrMsgRec); / 接收数据,并返回数据的长度; catch (SocketE*ception se) ShowMsg(异常: + se.Message); / 从 通信套接字 集合中删除被中断连接的通信套接字; dict.Remove(sokClient.RemoteEndPoint.ToString(); / 从通信线程集合中删除被中断连接的通信线程对象;
9、 dictThread.Remove(sokClient.RemoteEndPoint.ToString(); / 从列表中移除被中断的连接IP lbOnline.Items.Remove(sokClient.RemoteEndPoint.ToString(); break; catch (E*ception e) ShowMsg(异常: + e.Message); / 从 通信套接字 集合中删除被中断连接的通信套接字;dict.Remove(sokClient.RemoteEndPoint.ToString(); / 从通信线程集合中删除被中断连接的通信线程对象; dictThread.Re
10、move(sokClient.RemoteEndPoint.ToString(); / 从列表中移除被中断的连接IP lbOnline.Items.Remove(sokClient.RemoteEndPoint.ToString(); break; if (arrMsgRec0 = 0) / 表示接收到的是数据; string strMsg = System.Te*t.Encoding.UTF8.GetString(arrMsgRec,1, length-1);/ 将承受到的字节数据转化成字符串; ShowMsg(strMsg); if (arrMsgRec0 = 1) / 表示接收到的是文件
11、; SaveFileDialog sfd = new SaveFileDialog(); if (sfd.ShowDialog(this) = System.Windows.Forms.DialogResult.OK) / 在上边的 sfd.ShowDialog 的括号里边一定要加上 this 否则就不会弹出 另存为 的对话框,而弹出的是本类的其他窗口,这个一定要注意!【解释:加了this的sfd.ShowDialog(this),“另存为窗口的指针才能被SaveFileDialog的对象调用,假设不加thisSaveFileDialog 的对象调用的是本类的其他窗口了,当然不弹出“另存为窗口
12、。】 string fileSavePath = sfd.FileName;/ 获得文件保存的路径; / 创立文件流,然后根据路径创立文件; using (FileStream fs = new FileStream(fileSavePath, FileMode.Create) fs.Write(arrMsgRec, 1, length - 1); ShowMsg(文件保存成功: + fileSavePath); void ShowMsg(string str) t*tMsg.AppendTe*t(str + rn); / 发送消息 private void btnSend_Click(obj
13、ect sender, EventArgs e) string strMsg = 效劳器 + rn + - + t*tMsgSend.Te*t.Trim() + rn; byte arrMsg = System.Te*t.Encoding.UTF8.GetBytes(strMsg); / 将要发送的字符串转换成Utf-8字节数组;byte arrSendMsg=new bytearrMsg.Length+1; arrSendMsg0 = 0; / 表示发送的是消息数据 Buffer.BlockCopy(arrMsg, 0, arrSendMsg, 1, arrMsg.Length); stri
14、ng strKey = ; strKey = lbOnline.Te*t.Trim(); if (string.IsNullOrEmpty(strKey) / 判断是不是选择了发送的对象; MessageBo*.Show(请选择你要发送的好友!); else dictstrKey.Send(arrSendMsg);/ 解决了 sokConnection是局部变量,不能再本函数中引用的问题; ShowMsg(strMsg); t*tMsgSend.Clear(); / / 群发消息 / / / 消息 private void btnSendToAll_Click(object sender, E
15、ventArgs e) string strMsg = 效劳器 + rn + - + t*tMsgSend.Te*t.Trim() + rn; byte arrMsg = System.Te*t.Encoding.UTF8.GetBytes(strMsg); / 将要发送的字符串转换成Utf-8字节数组; using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Te
16、*t;using System.Windows.Forms;using System.Net.Sockets;using System.Net; / IP,IPAddress, IPEndPoint,端口等;using System.Threading;using System.IO;namespace _11111 public partial class frm_server : Form public frm_server() InitializeComponent(); Te*tBo*.CheckForIllegalCrossThreadCalls = false; Thread th
17、readWatch = null; / 负责监听客户端连接请求的 线程; Socket socketWatch = null; Dictionary dict = new Dictionary(); Dictionary dictThread = new Dictionary(); private void btnBeginListen_Click(object sender, EventArgs e) / 创立负责监听的套接字,注意其中的参数; socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, Pr
18、otocolType.Tcp); / 获得文本框中的IP对象; IPAddress address = IPAddress.Parse(t*tIp.Te*t.Trim(); / 创立包含ip和端口号的网络节点对象; IPEndPoint endPoint = new IPEndPoint(address, int.Parse(t*tPort.Te*t.Trim(); try / 将负责监听的套接字绑定到唯一的ip和端口上; socketWatch.Bind(endPoint); catch (SocketE*ception se) MessageBo*.Show(异常:+se.Message)
19、; return; / 设置监听队列的长度; socketWatch.Listen(10); / 创立负责监听的线程; threadWatch = new Thread(WatchConnecting); threadWatch.IsBackground = true; threadWatch.Start(); ShowMsg(效劳器启动监听成功!); / / / 监听客户端请求的方法; / void WatchConnecting() while (true) / 持续不断的监听客户端的连接请求; / 开场监听客户端连接请求,Accept方法会阻断当前的线程; Socket sokConne
20、ction = socketWatch.Accept(); / 一旦监听到一个客户端的请求,就返回一个与该客户端通信的 套接字; / 想列表控件中添加客户端的IP信息; lbOnline.Items.Add(sokConnection.RemoteEndPoint.ToString(); / 将与客户端连接的 套接字 对象添加到集合中; dict.Add(sokConnection.RemoteEndPoint.ToString(), sokConnection); ShowMsg(客户端连接成功!); Thread thr = new Thread(RecMsg); thr.IsBackgr
21、ound = true; thr.Start(sokConnection); dictThread.Add(sokConnection.RemoteEndPoint.ToString(), thr); / 将新建的线程 添加 到线程的集合中去。 void RecMsg(object sokConnectionparn) Socket sokClient = sokConnectionparn as Socket; while (true) / 定义一个2M的缓存区; byte arrMsgRec = new byte1024 * 1024 * 2; / 将承受到的数据存入到输入 arrMsgR
22、ec中; int length = -1; try length = sokClient.Receive(arrMsgRec); / 接收数据,并返回数据的长度; catch (SocketE*ception se) ShowMsg(异常: + se.Message); / 从 通信套接字 集合中删除被中断连接的通信套接字; dict.Remove(sokClient.RemoteEndPoint.ToString(); / 从通信线程集合中删除被中断连接的通信线程对象; dictThread.Remove(sokClient.RemoteEndPoint.ToString(); / 从列表中
23、移除被中断的连接IP lbOnline.Items.Remove(sokClient.RemoteEndPoint.ToString(); break; catch (E*ception e) ShowMsg(异常: + e.Message); / 从 通信套接字 集合中删除被中断连接的通信套接字; dict.Remove(sokClient.RemoteEndPoint.ToString(); / 从通信线程集合中删除被中断连接的通信线程对象; dictThread.Remove(sokClient.RemoteEndPoint.ToString(); / 从列表中移除被中断的连接IP lb
24、Online.Items.Remove(sokClient.RemoteEndPoint.ToString(); break; if (arrMsgRec0 = 0) / 表示接收到的是数据; string strMsg = System.Te*t.Encoding.UTF8.GetString(arrMsgRec,1, length-1);/ 将承受到的字节数据转化成字符串; ShowMsg(strMsg); if (arrMsgRec0 = 1) / 表示接收到的是文件; SaveFileDialog sfd = new SaveFileDialog(); if (sfd.ShowDial
25、og(this) = System.Windows.Forms.DialogResult.OK) / 在上边的 sfd.ShowDialog 的括号里边一定要加上 this 否则就不会弹出 另存为 的对话框,而弹出的是本类的其他窗口,这个一定要注意!【解释:加了this的sfd.ShowDialog(this),“另存为窗口的指针才能被SaveFileDialog的对象调用,假设不加thisSaveFileDialog 的对象调用的是本类的其他窗口了,当然不弹出“另存为窗口。】 string fileSavePath = sfd.FileName;/ 获得文件保存的路径; / 创立文件流,然后
26、根据路径创立文件; using (FileStream fs = new FileStream(fileSavePath, FileMode.Create) fs.Write(arrMsgRec, 1, length - 1); ShowMsg(文件保存成功: + fileSavePath); void ShowMsg(string str) t*tMsg.AppendTe*t(str + rn); / 发送消息 private void btnSend_Click(object sender, EventArgs e) string strMsg = 效劳器 + rn + - + t*tMs
27、gSend.Te*t.Trim() + rn; byte arrMsg = System.Te*t.Encoding.UTF8.GetBytes(strMsg); / 将要发送的字符串转换成Utf-8字节数组; byte arrSendMsg=new bytearrMsg.Length+1; arrSendMsg0 = 0; / 表示发送的是消息数据 Buffer.BlockCopy(arrMsg, 0, arrSendMsg, 1, arrMsg.Length); string strKey = ; strKey = lbOnline.Te*t.Trim(); if (string.IsNu
28、llOrEmpty(strKey) / 判断是不是选择了发送的对象; MessageBo*.Show(请选择你要发送的好友!); else dictstrKey.Send(arrSendMsg);/ 解决了 sokConnection是局部变量,不能再本函数中引用的问题; ShowMsg(strMsg); t*tMsgSend.Clear(); / / 群发消息 / / / 消息 private void btnSendToAll_Click(object sender, EventArgs e) string strMsg = 效劳器 + rn + - + t*tMsgSend.Te*t.T
29、rim() + rn; byte arrMsg = System.Te*t.Encoding.UTF8.GetBytes(strMsg); / 将要发送的字符串转换成Utf-8字节数组;csharp view plaincopyprint?csharp view plaincopyprint? byte arrSendMsg = new bytearrMsg.Length + 1; / 上次写的时候把这一段给弄掉了,实在是抱歉哈 用来标识发送是数据而不是文件,如果没有这一段的客户端就接收不到消息了 arrSendMsg0 = 0; / 表示发送的是消息数据 Buffer.BlockCopy(a
30、rrMsg, 0, arrSendMsg, 1, arrMsg.Length); byte arrSendMsg = new bytearrMsg.Length + 1; / 上次写的时候把这一段给弄掉了,实在是抱歉哈 用来标识发送是数据而不是文件,如果没有这一段的客户端就接收不到消息了 arrSendMsg0 = 0; / 表示发送的是消息数据 Buffer.BlockCopy(arrMsg, 0, arrSendMsg, 1, arrMsg.Length);csharp view plaincopyprint?foreach (Socket s in dict.Values) s.Send
31、(arrMsg); ShowMsg(strMsg); t*tMsgSend.Clear(); ShowMsg( 群发完毕); / 选择要发送的文件 private void btnSelectFile_Click_1(object sender, EventArgs e) OpenFileDialog ofd = new OpenFileDialog(); ofd.InitialDirectory = D:; if (ofd.ShowDialog() = System.Windows.Forms.DialogResult.OK) t*tSelectFile.Te*t = ofd.FileNam
32、e; / 文件的发送 private void btnSendFile_Click_1(object sender, EventArgs e) if (string.IsNullOrEmpty(t*tSelectFile.Te*t) MessageBo*.Show(请选择你要发送的文件!); else / 用文件流翻开用户要发送的文件; using (FileStream fs = new FileStream(t*tSelectFile.Te*t, FileMode.Open) string fileName=System.IO.Path.GetFileName(t*tSelectFile.
33、Te*t); string fileE*tension=System.IO.Path.GetE*tension(t*tSelectFile.Te*t); string strMsg = 我给你发送的文件为: +fileName+fileE*tension+rn; byte arrMsg = System.Te*t.Encoding.UTF8.GetBytes(strMsg); / 将要发送的字符串转换成Utf-8字节数组; byte arrSendMsg = new bytearrMsg.Length + 1; arrSendMsg0 = 0; / 表示发送的是消息数据 Buffer.Bloc
34、kCopy(arrMsg, 0, arrSendMsg, 1, arrMsg.Length); bool fff = true; string strKey = ; strKey = lbOnline.Te*t.Trim(); if (string.IsNullOrEmpty(strKey) / 判断是不是选择了发送的对象; MessageBo*.Show(请选择你要发送的好友!); else dictstrKey.Send(arrSendMsg);/ 解决了 sokConnection是局部变量,不能再本函数中引用的问题; byte arrFile = new byte1024 * 1024
35、 * 2; int length = fs.Read(arrFile, 0, arrFile.Length); / 将文件中的数据读到arrFile数组中; byte arrFileSend = new bytelength + 1; arrFileSend0 = 1; / 用来表示发送的是文件数据; Buffer.BlockCopy(arrFile, 0, arrFileSend, 1, length); / 还有一个 CopyTo的方法,但是在这里不适合; 当然还可以用for循环自己转化; / sockClient.Send(arrFileSend);/ 发送数据到效劳端; dictstr
36、Key.Send(arrFileSend);/ 解决了 sokConnection是局部变量,不能再本函数中引用的问题; t*tSelectFile.Clear(); t*tSelectFile.Clear(); foreach (Socket s in dict.Values) s.Send(arrMsg); ShowMsg(strMsg); t*tMsgSend.Clear(); ShowMsg( 群发完毕); / 选择要发送的文件 private void btnSelectFile_Click_1(object sender, EventArgs e) OpenFileDialog ofd = new OpenFileDialog(); ofd