C#版C/S、CC局域网聊天、文件传输(源码与实验报告)

综合性设计实验

XXXX

1. 实验要求
   即时通讯程序
   1.用户之间的同步/异步的即时文字通讯；
   2.支持文件传输功能；
   3.至少支持在局域网内实现基本文字通信功能
2. 设计思路
3. 创建主体框架：建立程序的主要界面后，系统自动生成界面的主要窗口生成代码。对于每个按钮的的代码段中，分别添加事件触发的处理代码。
4. 处理好客户端与服务器之间的联系。
5. 客户端可以和服务器直接通信，使用TCP协议，其中服务器可以与一个或者多个客户端同时通信、同时发生送一条消息至多个客户端。
6. 客户端与客户端间的通信。客户端连接服务器后，服务器将所有在线客户的地址、端口等信息列表推送到客户端。客户端之间可以根据其他客户端的地址、端口号进行通信，使用UDP协议。
7. 文件传输。使用TCP协议来进行文件传输。将一个文件分块，在传输的时候先传送文件的分块信息，也就是传输的次数。接收端收到文件分块信息后就表示和发送端同步了文件的信息，然后进行文件传输。文件传输使用的是独自的Socket，有独立的端口，是和CS间通信使用的Socket不同，所以不会相互影响。

CS建立连接核心代码：

客户端部分：

private void ClientConnect()

{

AddMessageDelegate dm = AddMessage;//跨进程委托

SetTextDelegate dst = SetText;

SetClientTextDelegate dct = SetClientText;

//连接clientSocket

while (true)

{

try

{

clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

clientSocket.Connect(new IPEndPoint(sip, 8889));

fSocket = clientSocket;

myport = clientSocket.LocalEndPoint.ToString().Split(':')[1];

//显示客户端

currentClientText.Invoke(dct, clientSocket.LocalEndPoint.ToString());

//连接成提示

MessageBox.Invoke(dm, "连接服务器成功");

connectText.Invoke(dst, "连接¨?服¤t务?器??成¨|功|");

NetworkStream networkStream = new NetworkStream(clientSocket);

userbr = new BinaryReader(networkStream);

userbw = new BinaryWriter(networkStream);

//向¨°服¤t务?器??发¤?é送¨a登ì?录?成¨|功|消?息?é

try

{

userbw.Write("login," + clientSocket.LocalEndPoint.ToString()

+ "," );

userbw.Flush();

}

catch

{

MessageBox.Invoke(dm, "发送失败1" );

}

//接¨?收o?数oy据Y进?程¨?

Thread receiveThread = new Thread(ReceiveMessage);

receiveThread.IsBackground = true;

receiveThread.Start();

Thread.CurrentThread.Abort();

}

catch (Exception ex)

{

if (!ex.Message.Contains("中止线程"))

{

connectText.Invoke(dst, "连￠?接¨?服¤t务?器??失o?ì败?¨1！ê?");

}

}

}

}

服务器部分：

private void ListenClientConnect()

{

SetTextDelegate dst = SetText;

while (true)

{

Socket client = serverSocket.Accept();

FSocket = client;

//监¨¤听?y到ì?一°?个?socket

//计?数oy加¨?1

label1.Invoke(dst, Convert.ToString(++count));

//接¨?收o?该?客¨a户?ì端?的ì?信?息?é

Thread receiveThread = new Thread(ReceiveMessage);

receiveThread.Start(client);

receiveThread.IsBackground = true;

}

}

文字通信核心代码：

客户端部分：

private void button1_Click(object sender, EventArgs e)//发¤?é送¨a到ì?服¤t务?器??

{

if (clientSocket.Connected == false)

return;

//通a?§过yclientSocket发¤?é送¨a数oy据Y

string sendMessage = textBox.Text;

try

{

userbw.Write(sendMessage);

userbw.Flush();

}

catch

{

MessageBox.Items.Add("发¤?é送¨a失o?ì败?¨1");

}

MessageBox.Items.Add("向¨°服¤t务?器??发¤?é送¨a消?息?é：êo" + sendMessage);

}

public void ReceiveMessage()

{

AddMessageDelegate dm = AddMessage;//跨?进?程¨?委?￥托aD

while (true)

{

try

{

receiveString = userbr.ReadString();

string[] splitString = receiveString.Split(',');

string command = splitString[0].ToLower();

if (command.Equals("login"))

{

//receiveBox.Invoke(dm, receiveString);

AddOnline(splitString[1]);

clientName = new ClientName(splitString[1]);

clientNameList.Add(clientName);

MessageBox.Invoke(dm, "新?用??户?ì登ì?录?：êo" + splitString[1]);

}

else if (command.Equals("logout"))

{

MessageBox.Invoke(dm, splitString[1] + " 用??户?ì退a?出?");

RemoveUserName(splitString[1]);

}

else

{

MessageBox.Invoke(dm, "接¨?收o?到ì?服¤t务?器??的ì?消?息?é：êo" + receiveString);

}

}

catch (Exception ex)

{

//关?闭à?socket

MessageBox.Invoke(dm, ex.Message.ToString());

clientSocket.Shutdown(SocketShutdown.Both);

clientSocket.Close();

userbr.Close();

userbw.Close();

//重?新?连￠?接¨?服¤t务?器??

Thread mythread2 = new Thread(ClientConnect);

mythread2.IsBackground = true;

mythread2.Start();

break;

}

}

}

服务器部分：

private void ReceiveMessage(Object cliensocket)

{

Socket myclientSocket = (Socket)cliensocket;

AddMessageDelegate dm2 = AddMessage;

SetTextDelegate dst = SetText;

AddSocketDelegate d = AddSocket;

while (true)

{

try

{

//当ì?à前??的ì?二t进?制?读¨￠写??流￠??

networkStream = new NetworkStream(myclientSocket);

userbr = new BinaryReader(networkStream);

userbw = new BinaryWriter(networkStream);

//收o?到ì?的ì?字á?符¤?串??

receiveString = userbr.ReadString();

//判D断?前??缀áo：êo边à?界?问¨o题?a

string[] splitstring = receiveString.Split(',');

string command = splitstring[0].ToLower();

if (command.Equals("login"))

{

MessageBox.Invoke(dm2, splitstring[1] + "登ì?录?成¨|功|");

//在¨2listbox中D增?加¨?其?tcp端?口¨2显?示o?，ê?然¨?后¨?把??生|¨2成¨|的ì?ClientName加¨?入¨?List<>中D

IPBox.Invoke(d, myclientSocket, splitstring[2]);

//通a?§知a所¨′有?D的ì?客¨a户?ì端?

SendToAllClient(myclientSocket, receiveString);

}

else

{

//接¨?收o?正y常?ê信?息?é

MessageBox.Invoke(dm2, "接¨?收o?到ì?客¨a户?ì端?" + myclientSocket.RemoteEndPoint.ToString() + "的ì?消?息?é：êo" + receiveString);

}

}

catch (Exception)

{

//接¨?收o?数oy据Y过y程¨?中D，ê?客¨a户?ì端?退a?出?或¨°者?接¨?收o?错?¨a误¨?！ê?

RemoveSocketDelegate drm = RemoveSocket;

//找¨°出?列￠D表à¨a中D的ì?客¨a户?ì端?并?é删|?除y掉ì?

foreach (ClientName useritem in clientNameList)

{

if (myclientSocket == useritem.clientSocket)

clientName = useritem;

}

if (IPBox.Items.Contains(myclientSocket.RemoteEndPoint.ToString()))

IPBox.Invoke(drm, clientName.clientSocket, clientName.name);

MessageBox.Invoke(dm2, myclientSocket.RemoteEndPoint.ToString() + "退a?出?了￠?！ê?");

//通a?§知a所¨′有?D客¨a户?ì端?其?下?线?了￠?

SendToAllClient(myclientSocket, "logout," + myclientSocket.RemoteEndPoint.ToString());

myclientSocket.Shutdown(SocketShutdown.Both);

myclientSocket.Close();

userbr.Close();

userbw.Close();

label1.Invoke(dst, Convert.ToString(--count));

break;

}

}

}

private void SendToClient(Socket user, BinaryWriter userbw, string message)

{

try

{

userbw.Write(message);

userbw.Flush();

}

catch (Exception)

{

//receiveBox.Items.Add("向¨°"+user.RemoteEndPoint.ToString()+"发¤?é送¨a消?息?é失o?ì败?¨1" );

//throw;

}

}

文件传输核心代码：

发送端：

private void StartSend()

{

AddMessageDelegate dm = AddMessage;//跨?进?程¨?委?￥托aD

try

{

//创???建?§一°?个?文?件t对?象¨?

FileInfo EzoneFile = new FileInfo(this.textBox1.Text);

//打?¨°开a文?件t流￠??

FileStream EzoneStream = EzoneFile.OpenRead();

//包?¨1的ì?大?¨?小?

int PacketSize = int.Parse(this.textBox6.Text);

//包?¨1的ì?数oy量￠?

int PacketCount = (int)(EzoneStream.Length / ((long)PacketSize));

//this.textBox8.Text = PacketCount.ToString();

//this.progressBar1.Maximum = PacketCount;

//最á?后¨?一°?个?包?¨1的ì?大?¨?小?

int LastDataPacket = (int)(EzoneStream.Length - ((long)(PacketSize * PacketCount)));

//指?向¨°远?程¨?服¤t务?端?节¨2点ì?

IPEndPoint ipep = new IPEndPoint(IPAddress.Parse(sip_B.Text.Trim()), 8890);

//创???建?§套??á接¨?字á?

Socket client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

//连￠?接¨?到ì?发¤?é送¨a端?

client.Connect(ipep);

//发¤?é送¨a[文?件t名?]到ì?客¨a户?ì端?

ClientFile.SendVarData(client, System.Text.Encoding.Unicode.GetBytes(EzoneFile.Name));

//发¤?é送¨a[包?¨1的ì?大?¨?小?]到ì?客¨a户?ì端?

ClientFile.SendVarData(client, System.Text.Encoding.Unicode.GetBytes(PacketSize.ToString()));

//发¤?é送¨a[包?¨1的ì?总á¨1数oy量￠?]到ì?客¨a户?ì端?

ClientFile.SendVarData(client, System.Text.Encoding.Unicode.GetBytes(PacketCount.ToString()));

//发¤?é送¨a[最á?后¨?一°?个?包?¨1的ì?大?¨?小?]到ì?客¨a户?ì端?

ClientFile.SendVarData(client, System.Text.Encoding.Unicode.GetBytes(LastDataPacket.ToString()));

//数oy据Y包?¨1

byte[] data = new byte[PacketSize];

//开a始o?循-环?¤发¤?é送¨a数oy据Y包?¨1

for (int i = 0; i < PacketCount; i++)

{

//从?¨?文?件t流￠??读¨￠取¨?数oy据Y并?é填??充?数oy据Y包?¨1

EzoneStream.Read(data, 0, data.Length);

//发¤?é送¨a数oy据Y包?¨1

ClientFile.SendVarData(client, data);

//显?示o?发¤?é送¨a数oy据Y包?¨1的ì?个?数oy

//this.textBox10.Text = ((int)(i + 1)).ToString();

//进?度¨¨条??值|ì的ì?显?示o?

// this.progressBar1.PerformStep();

}

//如¨?果?还1有?D多¨¤余?¨¤的ì?数oy据Y包?¨1,则¨°应?|该?发¤?é送¨a完a¨o毕à?!

if (LastDataPacket != 0)

{

data = new byte[LastDataPacket];

EzoneStream.Read(data, 0, data.Length);

ClientFile.SendVarData(client, data);

//this.progressBar1.Value = this.progressBar1.Maximum;

}

//关?闭à?套??á接¨?字á?

client.Close();

//关?闭à?文?件t流￠??

EzoneStream.Close();

MessageBox.Invoke(dm, "发¤?é送¨a完a¨o毕à?");

}

catch (Exception ex)

{

MessageBox.Invoke(dm, ex.ToString());

}

}

接收端：

private void StartReceive()

{

AddMessageDelegate dm2 = AddMessage;

//创???建?§一°?个?网a?络?端?点ì?

IPEndPoint ipep = new IPEndPoint(IPAddress.Any, int.Parse("8890"));

//MessageBox.Show(IPAddress.Any);

//创???建?§一°?个?套??á接¨?字á?

Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

//绑?¨?定?§套??á接¨?字á?到ì?端?口¨2

server.Bind(ipep);

//开a始o?侦¨?听?y(并?é堵?塞¨?该?线?程¨?)

server.Listen(10);

while (true)

{

try

{

Socket client = server.Accept();

FSocket = client;

Thread TempThread = new Thread(new ThreadStart(this.Create));

TempThread.SetApartmentState(ApartmentState.STA);

TempThread.Start();

}

catch (Exception ex)

{

MessageBox.Invoke(dm2, ex);

}

}

}

public void Create()

{

string localFilePath = null;

FolderBrowserDialog folderBrowserDialog1 = new FolderBrowserDialog();

folderBrowserDialog1.ShowNewFolderButton = true;// 允¨o许¨a在¨2对?话??框¨°中D包?¨1括¤?§一°?个?新?建?§目?录?的ì?按???钮￡¤

// 设|¨¨置?对?话??框¨°的ì?说|ì明??信?息?é

folderBrowserDialog1.Description = "请?选?择?保à?ê存??目?录?";

if (folderBrowserDialog1.ShowDialog() == DialogResult.OK)

{

localFilePath = folderBrowserDialog1.SelectedPath;

//MessageBox.Invoke(dm, localFilePath);

// 在¨2此??添?¨a加¨?代?¨2码?,选?择?的ì?路?¤径?为a folderBrowserDialog1.SelectedPath

AddMessageDelegate dm2 = AddMessage;

Socket client = FSocket;

//获?得ì?[文?件t名?]

string SendFileName = localFilePath + "\\" + System.Text.Encoding.Unicode.GetString(SeverFile.ReceiveVarData(client));

MessageBox.Invoke(dm2, "文?件t名?" + SendFileName);

//获?得ì?[包?¨1的ì?大?¨?小?]

string bagSize = System.Text.Encoding.Unicode.GetString(SeverFile.ReceiveVarData(client));

MessageBox.Invoke(dm2, "包?¨1大?¨?小?" + bagSize);

//获?得ì?[包?¨1的ì?总á¨1数oy量￠?]

int bagCount = int.Parse(System.Text.Encoding.Unicode.GetString(SeverFile.ReceiveVarData(client)));

MessageBox.Invoke(dm2, "包?¨1的ì?总á¨1数oy量￠?" + bagCount);

//获?得ì?[最á?后¨?一°?个?包?¨1的ì?大?¨?小?]

string bagLast = System.Text.Encoding.Unicode.GetString(SeverFile.ReceiveVarData(client));

MessageBox.Invoke(dm2, "最á?后¨?一°?个?包?¨1的ì?大?¨?小?" + bagLast);

//创???建?§一°?个?新?文?件t

FileStream MyFileStream = new FileStream(SendFileName, FileMode.Create, FileAccess.Write);

//已°?发¤?é送¨a包?¨1的ì?个?数oy

int SendedCount = 0;

while (true)

{

byte[] data = SeverFile.ReceiveVarData(client);

if (data.Length == 0)

{

break;

}

else

{

SendedCount++;

//将?接¨?收o?到ì?的ì?数oy据Y包?¨1写??入¨?到ì?文?件t流￠??对?象¨?

MyFileStream.Write(data, 0, data.Length);

//显?示o?已°?发¤?é送¨a包?¨1的ì?个?数oy

}

}

//关?闭à?文?件t流￠??

MyFileStream.Close();

MessageBox.Invoke(dm2, "关?闭à?文?件t流￠??");

//关?闭à?套??á接¨?字á?

client.Close();

}

}

1. 程序运行效果图

客户端：

服务器：

CS通信：

CC通信：

文件传输：

客户端选择要传输的文件“实验三”：

客户端发送文件：

服务器选择保存文件目录“d:\t\”：

服务器接收完毕：

文件传输完成：

4实验总结

因为之前学习过C#课程，所以使用C#来完成这次网络编程的综合性实验可谓是得心应手。在C#基本知识的运用上没有多大问题，难就难在对网络编程相关知识的理解上。

CS通信基本没有难点，就是双方通过TCP协议利用socket来通信。我觉得本实验的两个难点在于CC间通信和文件传输。

因为CC之间直接通信必须要有对方的地址和端口号，所以通过服务器为中介来获取，然后用UDP协议来通信。

在做文件传输时遇到了困难。因为一开始我把文件传输放在CS通信时使用的socket下面，所以造成了冲突，判别传输的内容上有很大困难，就是怎么分辨是传输文字信息、控制命令还是传输文件？后来我将文件传输分离开来，使用了一个新的socket、端口，问题就迎刃而解。

心得：不放弃、不气馁、一步步前进、一步步钻研。