C#版C/S、CC局域网聊天、文件传输(源码与实验报告)
综合性设计实验
XXXX
- 实验要求
即时通讯程序
1.用户之间的同步/异步的即时文字通讯；
2.支持文件传输功能；
3.至少支持在局域网内实现基本文字通信功能 - 设计思路
- 创建主体框架：建立程序的主要界面后，系统自动生成界面的主要窗口生成代码。对于每个按钮的的代码段中，分别添加事件触发的处理代码。
- 处理好客户端与服务器之间的联系。
- 客户端可以和服务器直接通信，使用TCP协议，其中服务器可以与一个或者多个客户端同时通信、同时发生送一条消息至多个客户端。
- 客户端与客户端间的通信。客户端连接服务器后，服务器将所有在线客户的地址、端口等信息列表推送到客户端。客户端之间可以根据其他客户端的地址、端口号进行通信，使用UDP协议。
- 文件传输。使用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, "连接¨(R)服¤t务?器!^A成¨|功|");
NetworkStream networkStream = new NetworkStream(clientSocket);
userbr = new BinaryReader(networkStream);
userbw = new BinaryWriter(networkStream);
//向¨°服¤t务?器!^A发¤!é送¨a登`I?录?成¨|功|消?息!é
try
{
userbw.Write("login," + clientSocket.LocalEndPoint.ToString()
+ "," );
userbw.Flush();
}
catch
{
MessageBox.Invoke(dm, "发送失败^1" );
}
//接¨(R)收o?数oy据Y进?程¨not
Thread receiveThread = new Thread(ReceiveMessage);
receiveThread.IsBackground = true;
receiveThread.Start();
Thread.CurrentThread.Abort();
}
catch (Exception ex)
{
if (!ex.Message.Contains("中止线程"))
{
connectText.Invoke(dst, "连c?接¨(R)服¤t务?器!^A失o!ì败~a¨^1！ê?");
}
}
}
}
服务器部分：
private void ListenClientConnect()
{
SetTextDelegate dst = SetText;
while (true)
{
Socket client = serverSocket.Accept();
FSocket = client;
//监¨¤听noty到`I?一°?个?socket
//计?数oy加¨(R)1
label1.Invoke(dst, Convert.ToString(++count));
//接¨(R)收o?该?客¨a户!ì端?的`I?信?息!é
Thread receiveThread = new Thread(ReceiveMessage);
receiveThread.Start(client);
receiveThread.IsBackground = true;
}
}
文字通信核心代码：
客户端部分：
private void button1_Click(object sender, EventArgs e)//发¤!é送¨a到`I?服¤t务?器!^A
{
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!ì败~a¨^1");
}
MessageBox.Items.Add("向¨°服¤t务?器!^A发¤!é送¨a消?息!é：êo" + sendMessage);
}
public void ReceiveMessage()
{
AddMessageDelegate dm = AddMessage;//跨?进?程¨not委!yen托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, "新?用(R)?户!ì登`I?录?：êo" + splitString[1]);
}
else if (command.Equals("logout"))
{
MessageBox.Invoke(dm, splitString[1] + " 用(R)?户!ì退a?出?");
RemoveUserName(splitString[1]);
}
else
{
MessageBox.Invoke(dm, "接¨(R)收o?到`I?服¤t务?器!^A的`I?消?息!é：êo" + receiveString);
}
}
catch (Exception ex)
{
//关?闭`A?socket
MessageBox.Invoke(dm, ex.Message.ToString());
clientSocket.Shutdown(SocketShutdown.Both);
clientSocket.Close();
userbr.Close();
userbw.Close();
//重?新?连c?接¨(R)服¤t务?器!^A
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
{
//当`I!`A前!~a的`I?二t进?制?读¨c写!"a流c!^A
networkStream = new NetworkStream(myclientSocket);
userbr = new BinaryReader(networkStream);
userbw = new BinaryWriter(networkStream);
//收o?到`I?的`I?字'A?符¤?串"a?
receiveString = userbr.ReadString();
//判D断?前!~a缀'Ao：êo边`A?界?问¨o题nota
string[] splitstring = receiveString.Split(',');
string command = splitstring[0].ToLower();
if (command.Equals("login"))
{
MessageBox.Invoke(dm2, splitstring[1] + "登`I?录?成¨|功|");
//在¨^2listbox中D增?加¨(R)其?tcp端?口¨^2显?示o?，ê?然¨?后¨(R)把~a?生|¨^2成¨|的`I?ClientName加¨(R)入¨?List<>中D
IPBox.Invoke(d, myclientSocket, splitstring[2]);
//通a!§知a所¨'有(R)D的`I?客¨a户!ì端?
SendToAllClient(myclientSocket, receiveString);
}
else
{
//接¨(R)收o?正y常!ê信?息!é
MessageBox.Invoke(dm2, "接¨(R)收o?到`I?客¨a户!ì端?" + myclientSocket.RemoteEndPoint.ToString() + "的`I?消?息!é：êo" + receiveString);
}
}
catch (Exception)
{
//接¨(R)收o?数oy据Y过y程¨not中D，ê?客¨a户!ì端?退a?出?或¨°者?接¨(R)收o?错"a¨a误¨(R)！ê?
RemoveSocketDelegate drm = RemoveSocket;
//找¨°出?列cD表`A¨a中D的`I?客¨a户!ì端?并!é删|?除y掉`I?
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?出?了c?！ê?");
//通a!§知a所¨'有(R)D客¨a户!ì端?其?下?线?了c?
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!ì败~a¨^1" );
//throw;
}
}
文件传输核心代码：
发送端：
private void StartSend()
{
AddMessageDelegate dm = AddMessage;//跨?进?程¨not委!yen托aD
try
{
//创"a!"a建!§一°?个?文?件t对?象¨(R)
FileInfo EzoneFile = new FileInfo(this.textBox1.Text);
//打"a¨°开a文?件t流c!^A
FileStream EzoneStream = EzoneFile.OpenRead();
//包~a¨^1的`I?大"a¨(R)小?
int PacketSize = int.Parse(this.textBox6.Text);
//包~a¨^1的`I?数oy量c?
int PacketCount = (int)(EzoneStream.Length / ((long)PacketSize));
//this.textBox8.Text = PacketCount.ToString();
//this.progressBar1.Maximum = PacketCount;
//最'A?后¨(R)一°?个?包~a¨^1的`I?大"a¨(R)小?
int LastDataPacket = (int)(EzoneStream.Length - ((long)(PacketSize * PacketCount)));
//指?向¨°远?程¨not服¤t务?端?节¨^2点`I?
IPEndPoint ipep = new IPEndPoint(IPAddress.Parse(sip_B.Text.Trim()), 8890);
//创"a!"a建!§套not!'A接¨(R)字'A?
Socket client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//连c?接¨(R)到`I?发¤!é送¨a端?
client.Connect(ipep);
//发¤!é送¨a[文?件t名?]到`I?客¨a户!ì端?
ClientFile.SendVarData(client, System.Text.Encoding.Unicode.GetBytes(EzoneFile.Name));
//发¤!é送¨a[包~a¨^1的`I?大"a¨(R)小?]到`I?客¨a户!ì端?
ClientFile.SendVarData(client, System.Text.Encoding.Unicode.GetBytes(PacketSize.ToString()));
//发¤!é送¨a[包~a¨^1的`I?总'A¨^1数oy量c?]到`I?客¨a户!ì端?
ClientFile.SendVarData(client, System.Text.Encoding.Unicode.GetBytes(PacketCount.ToString()));
//发¤!é送¨a[最'A?后¨(R)一°?个?包~a¨^1的`I?大"a¨(R)小?]到`I?客¨a户!ì端?
ClientFile.SendVarData(client, System.Text.Encoding.Unicode.GetBytes(LastDataPacket.ToString()));
//数oy据Y包~a¨^1
byte[] data = new byte[PacketSize];
//开a始o?循-环!¤发¤!é送¨a数oy据Y包~a¨^1
for (int i = 0; i < PacketCount; i++)
{
//从"a¨(R)文?件t流c!^A读¨c取¨?数oy据Y并!é填not?充?数oy据Y包~a¨^1
EzoneStream.Read(data, 0, data.Length);
//发¤!é送¨a数oy据Y包~a¨^1
ClientFile.SendVarData(client, data);
//显?示o?发¤!é送¨a数oy据Y包~a¨^1的`I?个?数oy
//this.textBox10.Text = ((int)(i + 1)).ToString();
//进?度¨¨条not?值|`I的`I?显?示o?
// this.progressBar1.PerformStep();
}
//如¨?果?还1有(R)D多¨¤余(R)¨¤的`I?数oy据Y包~a¨^1,则¨°应(R)|该?发¤!é送¨a完a¨o毕`A?!
if (LastDataPacket != 0)
{
data = new byte[LastDataPacket];
EzoneStream.Read(data, 0, data.Length);
ClientFile.SendVarData(client, data);
//this.progressBar1.Value = this.progressBar1.Maximum;
}
//关?闭`A?套not!'A接¨(R)字'A?
client.Close();
//关?闭`A?文?件t流c!^A
EzoneStream.Close();
MessageBox.Invoke(dm, "发¤!é送¨a完a¨o毕`A?");
}
catch (Exception ex)
{
MessageBox.Invoke(dm, ex.ToString());
}
}
接收端：
private void StartReceive()
{
AddMessageDelegate dm2 = AddMessage;
//创"a!"a建!§一°?个?网a?络?端?点`I?
IPEndPoint ipep = new IPEndPoint(IPAddress.Any, int.Parse("8890"));
//MessageBox.Show(IPAddress.Any);
//创"a!"a建!§一°?个?套not!'A接¨(R)字'A?
Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//绑~a¨(R)定!§套not!'A接¨(R)字'A?到`I?端?口¨^2
server.Bind(ipep);
//开a始o?侦¨not听noty(并!é堵?塞¨?该?线?程¨not)
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对?话!~a框¨°中D包~a¨^1括¤!§一°?个?新?建!§目?录?的`I?按~a!"a钮lb¤
// 设|¨¨置?对?话!~a框¨°的`I?说|`I明!^A信?息!é
folderBrowserDialog1.Description = "请?选?择?保`A!ê存"a?目?录?";
if (folderBrowserDialog1.ShowDialog() == DialogResult.OK)
{
localFilePath = folderBrowserDialog1.SelectedPath;
//MessageBox.Invoke(dm, localFilePath);
// 在¨^2此"a?添not¨a加¨(R)代"a¨^2码?,选?择?的`I?路!¤径?为a folderBrowserDialog1.SelectedPath
AddMessageDelegate dm2 = AddMessage;
Socket client = FSocket;
//获?得`I?[文?件t名?]
string SendFileName = localFilePath + "\\" + System.Text.Encoding.Unicode.GetString(SeverFile.ReceiveVarData(client));
MessageBox.Invoke(dm2, "文?件t名?" + SendFileName);
//获?得`I?[包~a¨^1的`I?大"a¨(R)小?]
string bagSize = System.Text.Encoding.Unicode.GetString(SeverFile.ReceiveVarData(client));
MessageBox.Invoke(dm2, "包~a¨^1大"a¨(R)小?" + bagSize);
//获?得`I?[包~a¨^1的`I?总'A¨^1数oy量c?]
int bagCount = int.Parse(System.Text.Encoding.Unicode.GetString(SeverFile.ReceiveVarData(client)));
MessageBox.Invoke(dm2, "包~a¨^1的`I?总'A¨^1数oy量c?" + bagCount);
//获?得`I?[最'A?后¨(R)一°?个?包~a¨^1的`I?大"a¨(R)小?]
string bagLast = System.Text.Encoding.Unicode.GetString(SeverFile.ReceiveVarData(client));
MessageBox.Invoke(dm2, "最'A?后¨(R)一°?个?包~a¨^1的`I?大"a¨(R)小?" + bagLast);
//创"a!"a建!§一°?个?新?文?件t
FileStream MyFileStream = new FileStream(SendFileName, FileMode.Create, FileAccess.Write);
//已°?发¤!é送¨a包~a¨^1的`I?个?数oy
int SendedCount = 0;
while (true)
{
byte[] data = SeverFile.ReceiveVarData(client);
if (data.Length == 0)
{
break;
}
else
{
SendedCount++;
//将?接¨(R)收o?到`I?的`I?数oy据Y包~a¨^1写!"a入¨?到`I?文?件t流c!^A对?象¨(R)
MyFileStream.Write(data, 0, data.Length);
//显?示o?已°?发¤!é送¨a包~a¨^1的`I?个?数oy
}
}
//关?闭`A?文?件t流c!^A
MyFileStream.Close();
MessageBox.Invoke(dm2, "关?闭`A?文?件t流c!^A");
//关?闭`A?套not!'A接¨(R)字'A?
client.Close();
}
}
- 程序运行效果图
客户端：
服务器：
CS通信：
CC通信：
文件传输：
客户端选择要传输的文件“实验三”：
客户端发送文件：
服务器选择保存文件目录“d:\t\”：
服务器接收完毕：
文件传输完成：
4实验总结
因为之前学习过C#课程，所以使用C#来完成这次网络编程的综合性实验可谓是得心应手。在C#基本知识的运用上没有多大问题，难就难在对网络编程相关知识的理解上。
CS通信基本没有难点，就是双方通过TCP协议利用socket来通信。我觉得本实验的两个难点在于CC间通信和文件传输。
因为CC之间直接通信必须要有对方的地址和端口号，所以通过服务器为中介来获取，然后用UDP协议来通信。
在做文件传输时遇到了困难。因为一开始我把文件传输放在CS通信时使用的socket下面，所以造成了冲突，判别传输的内容上有很大困难，就是怎么分辨是传输文字信息、控制命令还是传输文件？后来我将文件传输分离开来，使用了一个新的socket、端口，问题就迎刃而解。
心得：不放弃、不气馁、一步步前进、一步步钻研。
