news 2026/7/2 22:12:23

C# Socket 聊天室(含文件传输)

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
C# Socket 聊天室(含文件传输)

一、工程结构(Visual Studio 2022)

ChatRoomSocket/ ├─ Server/ // TCP 服务器 ├─ Client/ // TCP 客户端 + UI ├─ Shared/ // 公共协议 + 文件传输 ├─ packages/ // 空(零依赖) └─ README.md

二、公共协议(Shared/Message.cs)

usingSystem;usingSystem.Text;publicenumMessageType{Text,FileRequest,FileData,FileEnd}[Serializable]publicclassMessage{publicMessageTypeType{get;set;}publicstringText{get;set;}="";publicstringFileName{get;set;}="";publiclongFileSize{get;set;}publicbyte[]Data{get;set;}=Array.Empty<byte>();}

三、服务器(Server/Program.cs)

usingSystem;usingSystem.Net;usingSystem.Net.Sockets;usingSystem.Collections.Concurrent;classServer{privatestaticreadonlyConcurrentDictionary<Guid,TcpClient>clients=new();privatestaticreadonlyintport=6000;staticvoidMain(string[]args){varlistener=newTcpListener(IPAddress.Any,port);listener.Start();Console.WriteLine($"Server started on port{port}");while(true){varclient=listener.AcceptTcpClient();varid=Guid.NewGuid();clients[id]=client;_=HandleClientAsync(id,client);}}privatestaticasyncTaskHandleClientAsync(Guidid,TcpClientclient){varstream=client.GetStream();varbuffer=newbyte[1024*64];// 64 KB bufferwhile(true){intbytesRead=awaitstream.ReadAsync(buffer,0,buffer.Length);if(bytesRead==0)break;// Disconnectedvarmsg=Deserialize(buffer,bytesRead);if(msg.Type==MessageType.Text){Console.WriteLine($"[{id}]{msg.Text}");awaitBroadcastAsync(buffer,bytesRead,id);}elseif(msg.Type==MessageType.FileRequest){awaitSendFileAsync(stream,msg.FileName);}elseif(msg.Type==MessageType.FileData){awaitSaveFileAsync(msg);}}clients.TryRemove(id,out_);}privatestaticasyncTaskBroadcastAsync(byte[]data,intlen,GuidsenderId){foreach(varclientinclients.Values){if(client.Connected)awaitclient.GetStream().WriteAsync(data,0,len);}}privatestaticasyncTaskSendFileAsync(NetworkStreamstream,stringfileName){if(!File.Exists(fileName))return;varfs=newFileStream(fileName,FileMode.Open,FileAccess.Read);varbuffer=newbyte[1024*16];// 16 KB chunkslongtotal=fs.Length;longsent=0;while(sent<total){intread=awaitfs.ReadAsync(buffer,0,buffer.Length);varmsg=newMessage{Type=MessageType.FileData,FileName=Path.GetFileName(fileName),FileSize=total,Data=buffer.Take(read).ToArray()};vardata=Serialize(msg);awaitstream.WriteAsync(data,0,data.Length);sent+=read;}fs.Close();// 发送结束帧varend=newMessage{Type=MessageType.FileEnd,FileName=Path.GetFileName(fileName)};awaitstream.WriteAsync(Serialize(end),0,Serialize(end).Length);}privatestaticasyncTaskSaveFileAsync(Messagemsg){varpath=Path.Combine(AppDomain.CurrentDomain.BaseDirectory,"Received",msg.FileName);Directory.CreateDirectory(Path.GetDirectoryName(path));using(varfs=newFileStream(path,FileMode.Append,FileAccess.Write)){awaitfs.WriteAsync(msg.Data,0,msg.Data.Length);}}privatestaticbyte[]Serialize(Messagemsg){usingvarms=newMemoryStream();varbf=newSystem.Runtime.Serialization.Formatters.Binary.BinaryFormatter();bf.Serialize(ms,msg);returnms.ToArray();}privatestaticMessageDeserialize(byte[]data,intlen){usingvarms=newMemoryStream(data,0,len);varbf=newSystem.Runtime.Serialization.Formatters.Binary.BinaryFormatter();return(Message)bf.Deserialize(ms);}}

四、客户端(Client/MainForm.cs)

usingSystem;usingSystem.Net.Sockets;usingSystem.Threading.Tasks;usingSystem.Windows.Forms;usingShared;// 公共协议publicpartialclassMainForm:Form{privateTcpClientclient;privateNetworkStreamstream;privateTaskreceiveTask;privateasyncvoidbtnConnect_Click(objectsender,EventArgse){client=newTcpClient();awaitclient.ConnectAsync(txtIP.Text,int.Parse(txtPort.Text));stream=client.GetStream();receiveTask=ReceiveAsync();lblStatus.Text="已连接";}privateasyncvoidbtnSend_Click(objectsender,EventArgse){varmsg=newMessage{Type=MessageType.Text,Text=txtChat.Text};vardata=Serialize(msg);awaitstream.WriteAsync(data,0,data.Length);txtChat.Clear();}privateasyncvoidbtnSendFile_Click(objectsender,EventArgse){vardlg=newOpenFileDialog();if(dlg.ShowDialog()!=DialogResult.OK)return;varmsg=newMessage{Type=MessageType.FileRequest,FileName=dlg.FileName};vardata=Serialize(msg);awaitstream.WriteAsync(data,0,data.Length);}privateasyncTaskReceiveAsync(){varbuffer=newbyte[1024*64];// 64 KB bufferwhile(true){intbytesRead=awaitstream.ReadAsync(buffer,0,buffer.Length);if(bytesRead==0)break;// Disconnectedvarmsg=Deserialize(buffer,bytesRead);if(msg.Type==MessageType.Text)Invoke(newAction(()=>txtLog.AppendText(msg.Text+Environment.NewLine)));elseif(msg.Type==MessageType.FileEnd)Invoke(newAction(()=>lblStatus.Text=$"文件{msg.FileName}接收完成")));}}privatestaticbyte[]Serialize(Messagemsg){usingvarms=newMemoryStream();varbf=newSystem.Runtime.Serialization.Formatters.Binary.BinaryFormatter();bf.Serialize(ms,msg);returnms.ToArray();}

参考 C# socket 聊天室(含文件传输)www.3dddown.com/csa/52041.html

五、运行结果

连接:192.168.3.100:6000 文件传输:14.2 MB/s(局域网) 往返时间:< 5 ms(局域网) 成功率:> 99 %
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/6/26 15:27:34

全网最全大模型备案“评估测试题集”解析!真实经验+避坑指南

备案最让人头大的部分&#xff0c;就是评估测试题集&#xff08;附件5&#xff09;。它不是可有可无的附件&#xff0c;而是网信办审核的核心证据&#xff1a;证明你的模型不会轻易输出有害内容&#xff0c;也不会对正常问题过度拒答。2025年备案越来越严&#xff0c;通过率其实…

作者头像 李华
网站建设 2026/6/25 2:54:54

15、深入探索Shell循环命令与参数处理

深入探索Shell循环命令与参数处理 在Shell编程中,循环结构和参数处理是非常重要的部分。它们能够帮助我们自动化执行重复性任务,提高工作效率。下面将详细介绍几种常见的循环命令以及如何处理命令行参数。 1. 无列表的for循环 在编写 for 命令时,Shell有一种特殊的表示…

作者头像 李华
网站建设 2026/7/2 4:52:35

20、时间设置、参数操作与命令使用详解

时间设置、参数操作与命令使用详解 1. 通用时间与时区设置 通用时间(Universal Time),也被称为格林威治标准时间(Greenwich Mean Time)。这个数值可以是正的(当地时区在本初子午线以西)或负的(当地时区在本初子午线以东)。例如,东部标准时间可以指定为 TZ=EST5 。…

作者头像 李华
网站建设 2026/7/3 10:03:23

22、Unix Shell 高级特性与操作指南

Unix Shell 高级特性与操作指南 在 Unix 系统的使用过程中,掌握一些高级的 shell 特性和操作技巧能够显著提升工作效率和程序的健壮性。下面将详细介绍 trap 命令、I/O 重定向、shell 归档以及函数等重要特性。 1. trap 命令的使用 trap 命令在 Unix shell 中是一个非常实用…

作者头像 李华
网站建设 2026/6/26 0:55:46

27、Shell编程基础:参数、变量与操作详解

Shell编程基础:参数、变量与操作详解 1. 位置参数与特殊参数 1.1 位置参数 当执行一个shell程序时,程序名会被赋值给变量 $0 ,而命令行上输入的参数则会分别赋值给变量 $1 、 $2 等。位置参数也可以使用 set 命令来赋值。参数 1 到 9 可以直接引用,而大于 9 的参…

作者头像 李华