news 2026/7/16 16:46:25

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/7/16 4:09:52

Auto-Subtitle完整教程:5分钟学会为视频添加智能字幕

Auto-Subtitle完整教程&#xff1a;5分钟学会为视频添加智能字幕 【免费下载链接】auto-subtitle Automatically generate and overlay subtitles for any video. 项目地址: https://gitcode.com/gh_mirrors/au/auto-subtitle 在视频内容日益重要的今天&#xff0c;字幕…

作者头像 李华
网站建设 2026/7/14 21:42:42

5个简单步骤:掌握Visual Studio许可证到期日期的管理秘诀

5个简单步骤&#xff1a;掌握Visual Studio许可证到期日期的管理秘诀 【免费下载链接】VSCELicense PowerShell module to get and set Visual Studio Community Edition license expiration date in registry 项目地址: https://gitcode.com/gh_mirrors/vs/VSCELicense …

作者头像 李华
网站建设 2026/7/16 5:45:06

正交实验设计在软件测试用例生成中的应用研究

在软件测试领域&#xff0c;测试用例设计的效率与覆盖率直接决定产品质量保障水平。面对多参数、多水平的复杂测试场景&#xff0c;传统穷举法测试成本高昂&#xff0c;而随机抽样法又难以保证覆盖度。正交实验设计&#xff08;Orthogonal Experimental Design&#xff09;作为…

作者头像 李华
网站建设 2026/7/14 3:14:38

17、Unix Shell编程:临时文件、数据读写与环境变量详解

Unix Shell编程:临时文件、数据读写与环境变量详解 1. 电话簿程序操作与临时文件问题 在进行电话簿操作时,会有如下选项供用户选择: 1. 查找某人 2. 向电话簿添加某人 3. 从电话簿中移除某人 例如,当用户输入错误选择(如输入 0)时,会提示选择错误,需重新选择。若…

作者头像 李华
网站建设 2026/7/14 1:44:09

校园实验室|基于springboot + vue校园实验室管理系统(源码+数据库+文档)

校园实验室管理 目录 基于springboot vue校园实验室管理系统 一、前言 二、系统功能演示 三、技术选型 四、其他项目参考 五、代码参考 六、测试参考 七、最新计算机毕设选题推荐 八、源码获取&#xff1a; 基于springboot vue校园实验室管理系统 一、前言 博主介绍…

作者头像 李华