前言
最近在學習C# Socket相關的知識，學習之余，動手做了一個簡單的局域網聊天器，有萌生做這個的想法，主要是由于之前家里兩臺電腦之間想要傳輸檔案十分麻煩，需要借助QQ，微信或者其他第三方應用，基本都要登錄，而且可能傳輸的檔案還有大小限制，壓縮問題，所以本聊天器的首要目標就是解決這兩個問題，做到使用方便（雙擊啟動即用），傳檔案無限制，
廢話不多說，先上圖，S-Chat是服務端，C-Chat是客戶端，兩者除了客戶端首次啟動后需要設定一下連接的IP地址外，無其他區別，操作與界面都完全相同，對于用戶來說，基本不用在意誰是服務端誰是客戶端，
編碼
服務端監聽介面
服務端主要負責開啟監聽執行緒，等待客戶端接入
public void StartListen()
{
// 創建Socket物件 new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)
Socket socket = GetSocket();
// 將套接字與IPEndPoint系結
socket.Bind(this.GetIPEndPoint());
// 開啟監聽 僅支持一個連接
socket.Listen(1);
// 開啟執行緒等待客戶端接入，避免堵塞
Thread acceptThread = new Thread(new ThreadStart(TryAccept));
acceptThread.IsBackground = true;
acceptThread.Start();
}
public void TryAccept()
{
Socket socket = GetSocket();
while (true)
{
try
{
Socket connectedSocket = socket.Accept()
this.ConnectedSocket = connectedSocket;
OnConnect(); // 連接成功回呼
this.StartReceive(); // 開始接收執行緒
break;
}
catch (Exception e)
{
}
}
}
客戶端連接介面
客戶端主要負責開啟連接執行緒，每隔2秒，自動嘗試連接服務端
public void StartConnect()
{
Thread connectThread = new Thread(new ThreadStart(TryConnect));
connectThread.IsBackground = true;
connectThread.Start();
}
public void TryConnect()
{
Socket socket = GetSocket();
while (true)
{
try
{
socket.Connect(this.GetIPEndPoint());
this.ConnectedSocket = socket;
OnConnect(); // 連接成功回呼
this.StartReceive();
break;
}
catch (Exception e)
{
Thread.Sleep(TryConnectInterval); // 指定間隔后重新嘗試連接
}
}
}
文字發送，檔案發送，接收文字，接收檔案等通用介面主要實作在ChatBase類中，是服務端與客戶端的共同父類，
文字發送介面
發送資料的第一位表示發送資訊的型別，0表示字串文字，1表示檔案
然后獲取待發送字串的長度，使用long型別表示，占用8個位元組
共發送的位元組資料可以表示為頭部（型別 + 字串位元組長度，共9個位元組）+ 實際字串位元組資料
public bool Send(string msg)
{
if (ConnectedSocket != null && ConnectedSocket.Connected)
{
byte[] buffer = UTF8.GetBytes(msg);
byte[] len = BitConverter.GetBytes((long)buffer.Length);
byte[] content = new byte[1 + len.Length + buffer.Length];
content[0] = (byte)ChatType.Str; // 發送資訊型別，字串
Array.Copy(len, 0, content, 1, len.Length); // 字串位元組長度
Array.Copy(buffer, 0, content, 1 + len.Length, buffer.Length); // 實際字串位元組資料
try
{
ConnectedSocket.Send(content);
return true;
}
catch (Exception e)
{
}
}
return false;
}
檔案發送介面
與字串發送相同的頭部可以表示為（型別 + 檔案長度，共9個位元組）
還需要再加上待發送的檔案名的長度，與檔案名位元組資料
共發送的位元組資料可以表示為頭部（型別 + 檔案長度，共9個位元組）+ 檔案名頭部（檔案名長度 + 檔案名位元組資料）+ 實際檔案資料
public bool SendFile(string path)
{
if (ConnectedSocket != null && ConnectedSocket.Connected)
{
try
{
FileInfo fi = new FileInfo(path);
byte[] len = BitConverter.GetBytes(fi.Length);
byte[] name = UTF8.GetBytes(fi.Name);
byte[] nameLen = BitConverter.GetBytes(name.Length);
byte[] head = new byte[1 + len.Length + nameLen.Length + name.Length];
head[0] = (byte)ChatType.File; // 加上資訊發送型別
Array.Copy(len, 0, head, 1, len.Length); // 加上檔案長度
Array.Copy(nameLen, 0, head, 1 + len.Length, nameLen.Length); // 加上檔案名長度
Array.Copy(name, 0, head, 1 + len.Length + nameLen.Length, name.Length); // 加上檔案名位元組資料
ConnectedSocket.SendFile(
path,
head,
null,
TransmitFileOptions.UseDefaultWorkerThread
);
return true;
}
catch(Exception e)
{
}
}
return false;
}
資訊接收介面（文字與檔案）
主要是決議接收到的位元組資料，根據字串或檔案的型別進行處理
public void Receive()
{
if (ConnectedSocket != null)
{
while (true)
{
try
{
// 讀取公共頭部
byte[] head = new byte[9];
ConnectedSocket.Receive(head, head.Length, SocketFlags.None);
int len = BitConverter.ToInt32(head, 1);
if (head[0] == (byte) ChatType.Str)
{
// 接收字串
byte[] buffer = new byte[len];
ConnectedSocket.Receive(buffer, len, SocketFlags.None);
OnReceive(ChatType.Str, UTF8.GetString(buffer));
}
else if(head[0] == (byte)ChatType.File)
{
// 接收檔案
if (!Directory.Exists(dirName))
{
Directory.CreateDirectory(dirName);
}
// 讀取檔案名資訊
byte[] nameLen = new byte[4];
ConnectedSocket.Receive(nameLen, nameLen.Length, SocketFlags.None);
byte[] name = new byte[BitConverter.ToInt32(nameLen, 0)];
ConnectedSocket.Receive(name, name.Length, SocketFlags.None);
string fileName = UTF8.GetString(name);
// 讀取檔案內容并寫入
int readByte = 0;
int count = 0;
byte[] buffer = new byte[1024 * 8];
string filePath = Path.Combine(dirName, fileName);
if (File.Exists(filePath))
{
File.Delete(filePath);
}
using (FileStream fs = new FileStream(filePath, FileMode.Append, FileAccess.Write))
{
while (count != len)
{
int readLength = buffer.Length;
if(len - count < readLength)
{
readLength = len - count;
}
readByte = ConnectedSocket.Receive(buffer, readLength, SocketFlags.None);
fs.Write(buffer, 0, readByte);
count += readByte;
}
}
OnReceive(ChatType.File, fileName);
}
else
{
// 未知型別
}
}
catch (Exception e)
{
}
}
}
}
使用
-
第一次使用，客戶端需要設定待連接的IP地址，之后再啟動會自動連接
-
雙擊服務端exe啟動，點擊
設定，查看IP地址項
-
雙擊客戶端exe啟動，點擊
設定，在IP地址項，輸入服務端查看到的IP地址
-
-
設定成功后，等待大約一兩秒，應用cion變成綠色，即表示連接成功，可以正常發送文字和檔案了
-
可以點擊
選擇檔案（支持選擇多個檔案），發送檔案 -
支持直接拖拽檔案到輸入框，發送檔案
-
支持Ctrl+Enter快捷鍵發送
-
接收到的檔案自動存放在exe所在目錄的ChatFiles檔案夾下
注意事項
- 客戶端服務端需要在同一個局域網下才能實作連接
- 服務端IP地址是不支持修改的，自動讀取本機的IP地址
原始碼
- 完整代碼放在GitHub上，點擊查看
- 預編譯好的可運行exe程式，在倉庫的Release目錄，也可以直接通過百度云下載，提取碼
v4pe
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/61605.html
標籤：C#
下一篇：Lambda運算式