综合性设计实验
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, "连接¨?服¤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();
}
}
- 程序运行效果图
客户端：
服务器：
CS通信：
CC通信：
文件传输：
客户端选择要传输的文件“实验三”：
客户端发送文件：
服务器选择保存文件目录“d:\t\”：
服务器接收完毕：
文件传输完成：
4实验总结
因为之前学习过C#课程，所以使用C#来完成这次网络编程的综合性实验可谓是得心应手。在C#基本知识的运用上没有多大问题，难就难在对网络编程相关知识的理解上。
CS通信基本没有难点，就是双方通过TCP协议利用socket来通信。我觉得本实验的两个难点在于CC间通信和文件传输。
因为CC之间直接通信必须要有对方的地址和端口号，所以通过服务器为中介来获取，然后用UDP协议来通信。
在做文件传输时遇到了困难。因为一开始我把文件传输放在CS通信时使用的socket下面，所以造成了冲突，判别传输的内容上有很大困难，就是怎么分辨是传输文字信息、控制命令还是传输文件？后来我将文件传输分离开来，使用了一个新的socket、端口，问题就迎刃而解。
心得：不放弃、不气馁、一步步前进、一步步钻研。