TCP实验报告

《—计算机网络—》TCP通信实验报告姓名：班级：学号：指导老师：浙江理工大学信息电子学院二○一四年十二月一、实验目的、利用c#编写异步tcp通讯程序,掌握socket语句的用法二、实验内容TCP实现一对一单人聊天,编程实现一个聊天室系统。

该系统首先必须设立服务器，建立完成后必须建立与服务器的连接。

建立成功后可以接收客户端输入的信息。

该系统包括客户端和服务器端两部分。

用户通过客户端发送消息。

服务器端在收到消息后，显示在主界面上实验报告要求有实现过程的流程图，对主要的函数及其参数给予说明，要有实现过程的主要程序段，并对各段程序的功能及作用进行说明三、实验代码1.server端using System;using System.Collections.Generic;using ponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Threading.Tasks;using System.Windows.Forms;using ;using .Sockets;using System.IO;using System.Threading;namespace frmAsyncTcpServer{public partial class TCPServer : Form{// 申明变量private const int Port = 51388;private TcpListener tcpLister = null;private TcpClient tcpClient = null;IPAddress ipaddress;private NetworkStream networkStream = null;private BinaryReader reader;private BinaryWriter writer;// 申明委托// 显示消息private delegate void ShowMessage(string str);private ShowMessage showMessageCallback;// 显示状态private delegate void ShowStatus(string str);private ShowStatus showStatusCallBack;// 清空消息private delegate void ResetMessage();private ResetMessage resetMessageCallBack;public TCPServer(){InitializeComponent();// 显示消息showMessageCallback = new ShowMessage(showMessage);// 显示状态showStatusCallBack = new ShowStatus(showStatus);// 重置消息resetMessageCallBack = new ResetMessage(resetMessage); ipaddress = IPAddress.Loopback;tbxserverIp.Text = ipaddress.ToString();tbxPort.Text = Port.ToString();}// 显示消息private void showMessage(string str){lstbxMsgView.Items.Add(tcpClient.Client.RemoteEndPoint); lstbxMsgView.Items.Add(str);lstbxMsgView.TopIndex = lstbxMsgView.Items.Count - 1;}// 显示状态private void showStatus(string str){toolStripStatusInfo.Text = str;}// 清空消息private void resetMessage(){tbxMsg.Text = string.Empty;tbxMsg.Focus();}private void toolTip1_Popup(object sender, PopupEventArgs e){}private void TCPServer_Load(object sender, EventArgs e){}private void label1_Click(object sender, EventArgs e){}private void btnStart_Click(object sender, EventArgs e){tcpLister = new TcpListener(ipaddress, Port);tcpLister.Start();// 启动一个线程来接受请求Thread acceptThread = new Thread(acceptClientConnect);acceptThread.Start();}private void acceptClientConnect(){statusStripInfo.Invoke(showStatusCallBack, "正在监听");Thread.Sleep(1000);try{statusStripInfo.Invoke(showStatusCallBack, "等待连接");tcpClient = tcpLister.AcceptTcpClient();if (tcpLister != null){statusStripInfo.Invoke(showStatusCallBack, "接受到连接"); networkStream = tcpClient.GetStream();reader = new BinaryReader(networkStream);writer = new BinaryWriter(networkStream);}}catch{statusStripInfo.Invoke(showStatusCallBack, "停止监听");Thread.Sleep(1000);statusStripInfo.Invoke(showStatusCallBack, "就绪");}}private void btnStop_Click(object sender, EventArgs e){tcpLister.Stop();}private void btnClear_Click(object sender, EventArgs e){lstbxMsgView.Items.Clear();}private void btnReceive_Click(object sender, EventArgs e){statusStripInfo.Invoke(showStatusCallBack, "接受消息中");try{string receivemessage = reader.ReadString();lstbxMsgView.Invoke(showMessageCallback, receivemessage);StreamWriter wr = new StreamWriter(@"历史记录.txt", true,System.Text.Encoding.Default);for (int i = 0; i < lstbxMsgView.Items.Count; i++){wr.Write(lstbxMsgView.Items[i].ToString() + Environment.NewLine); }wr.Close();}catch{if (reader != null){reader.Close();}if (writer != null){writer.Close();}if (tcpClient != null){tcpClient.Close();}statusStripInfo.Invoke(showStatusCallBack, "断开了连接");// 重新开启一个线程等待新的连接Thread acceptThread = new Thread(acceptClientConnect);acceptThread.Start();}}private void btnSend_Click(object sender, EventArgs e){Thread sendThread = new Thread(SendMessage);sendThread.Start(tbxMsg.Text);}private void SendMessage(object state){statusStripInfo.Invoke(showStatusCallBack, "正在发送");try{writer.Write(state.ToString());Thread.Sleep(5000);writer.Flush();statusStripInfo.Invoke(showStatusCallBack, "完毕");tbxMsg.Invoke(resetMessageCallBack, null);lstbxMsgView.Invoke(showMessageCallback, state.ToString()); }catch{if (reader != null){reader.Close();}if (writer != null){writer.Close();}if (tcpClient != null){tcpClient.Close();}statusStripInfo.Invoke(showStatusCallBack, "断开了连接");// 重新开启一个线程等待新的连接Thread acceptThread = new Thread(acceptClientConnect);acceptThread.Start();}}private void button1_Click(object sender, EventArgs e){if (reader != null){reader.Close();}if (writer != null){writer.Close();}if (tcpClient != null){// 断开连接tcpClient.Close();}toolStripStatusInfo.Text = "断开连接";// 启动一个线程等待接受新的请求Thread acceptThread = new Thread(acceptClientConnect);acceptThread.Start();}private void button1_Click_1(object sender, EventArgs e){StreamReader file = new StreamReader(@"历史记录.txt", System.Text.Encoding.Default);string s = "";while (s != null){s = file.ReadLine();if (s != null && !s.Equals(""))lstbxMsgView.Items.Add(s);}file.Close();}}}2.client端using System;using System.Collections.Generic;using ponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Text;using System.Threading.Tasks;using System.Windows.Forms;using ;using .Sockets;using System.Threading;using System.IO;namespace frmAsyncTcpClient{public partial class frmAsyncTcpClient : Form{// 申明变量private TcpClient tcpClient = null;private NetworkStream networkStream = null;private BinaryReader reader;private BinaryWriter writer;// 申明委托// 显示消息private delegate void ShowMessage(string str);private ShowMessage showMessageCallback;// 显示状态private delegate void ShowStatus(string str);private ShowStatus showStatusCallBack;// 清空消息private delegate void ResetMessage();private ResetMessage resetMessageCallBack;public frmAsyncTcpClient(){InitializeComponent();// 显示消息showMessageCallback = new ShowMessage(showMessage);// 显示状态showStatusCallBack = new ShowStatus(showStatus);// 重置消息resetMessageCallBack = new ResetMessage(resetMessage);}private void showMessage(string str){lstbxMsgView.Items.Add(tcpClient.Client.RemoteEndPoint); lstbxMsgView.Items.Add(str);lstbxMsgView.TopIndex = lstbxMsgView.Items.Count - 1;}private void showStatus(string str){toolStripStatusInfo.Text = str;}// 清空消息private void resetMessage(){tbxMsg.Text = "";tbxMsg.Focus();}private void toolStripLabel1_Click(object sender, EventArgs e) {}private void textBox5_TextChanged(object sender, EventArgs e) {}private void statusStrip1_ItemClicked(object sender, ToolStripItemClickedEventArgs e){}private void frmAsyncTcpClient_Load(object sender, EventArgs e){}private void tbxSendCount_TextChanged(object sender, EventArgs e){}private void label1_Click(object sender, EventArgs e){}private void lstbxMsgView_SelectedIndexChanged(object sender, EventArgs e) {}private void btnConnect_Click(object sender, EventArgs e){// 通过一个线程发起请求,多线程Thread connectThread = new Thread(ConnectToServer);connectThread.Start();}private void ConnectToServer(){try{// 调用委托statusStripInfo.Invoke(showStatusCallBack, "正在连接...");if (tbxSrvIp.Text == string.Empty || tbxPort.Text == string.Empty) {MessageBox.Show("请先输入服务器的IP地址和端口号");}IPAddress ipaddress = IPAddress.Parse(tbxSrvIp.Text);tcpClient = new TcpClient();tcpClient.Connect(ipaddress, int.Parse(tbxPort.Text));// 延时操作Thread.Sleep(1000);if (tcpClient != null){statusStripInfo.Invoke(showStatusCallBack, "连接成功");networkStream = tcpClient.GetStream();reader = new BinaryReader(networkStream);writer = new BinaryWriter(networkStream);}}catch{statusStripInfo.Invoke(showStatusCallBack, "连接失败");Thread.Sleep(1000);statusStripInfo.Invoke(showStatusCallBack, "就绪");}}private void btnReceive_Click(object sender, EventArgs e){Thread receiveThread = new Thread(receiveMessage);receiveThread.Start();}private void receiveMessage(){statusStripInfo.Invoke(showStatusCallBack, "接受中");try{string receivemessage = reader.ReadString();lstbxMsgView.Invoke(showMessageCallback, receivemessage);StreamWriter wr = new StreamWriter(@"历史记录.txt", true,System.Text.Encoding.Default);for (int i = 0; i < lstbxMsgView.Items.Count; i++){wr.Write(lstbxMsgView.Items[i].ToString() + Environment.NewLine); }wr.Close();}catch{if (reader != null){reader.Close();}if (writer != null){writer.Close();}if (tcpClient != null){tcpClient.Close();}statusStripInfo.Invoke(showStatusCallBack, "断开了连接"); }}private void btnDisconnect_Click(object sender, EventArgs e){if (reader != null){reader.Close();}if (writer != null){writer.Close();}if (tcpClient != null){// 断开连接tcpClient.Close();}toolStripStatusInfo.Text = "断开连接";}private void btnSend_Click(object sender, EventArgs e){Thread sendThread = new Thread(SendMessage);sendThread.Start(tbxMsg.Text);}private void SendMessage(object state){statusStripInfo.Invoke(showStatusCallBack, "正在发送...");try{writer.Write(state.ToString());Thread.Sleep(5000);writer.Flush();statusStripInfo.Invoke(showStatusCallBack, "完毕");tbxMsg.Invoke(resetMessageCallBack, null);lstbxMsgView.Invoke(showMessageCallback, state.ToString()); }catch{if (reader != null){reader.Close();}if (writer != null){writer.Close();}if (tcpClient != null){tcpClient.Close();}statusStripInfo.Invoke(showStatusCallBack, "断开了连接"); }}private void btnClear_Click(object sender, EventArgs e){lstbxMsgView.Items.Clear();}private void button1_Click(object sender, EventArgs e){StreamReader file = new StreamReader(@"历史记录.txt",System.Text.Encoding.Default);string s = "";while (s != null){s = file.ReadLine();if (s != null && !s.Equals(""))lstbxMsgView.Items.Add(s);}file.Close();}}}}四、实验结果五、实验心得通过本次实验，我掌握了异步TCP通信的性质，学会了建立C#窗体程序并用socket进行tcp通讯的编程。