C__Socket编程实例.pdf
/Socket基本编程/服务端：using System.Net;using System.Net.Sockets;using System.Text;using System.Threading;Thread mythread;Socket socket;/清理所有正在使用的资源。protected override void Dispose(bool disposing)try socket.Close();/释放资源mythread.Abort();/中止线程 catch if(disposing)if(components!=null)components.Dispose();base.Dispose(disposing);public static IPAddress GetServerIP()IPHostEntry ieh=Dns.GetHostByName(Dns.GetHostName();return ieh.AddressList0;private void BeginListen()IPAddress ServerIp=GetServerIP();IPEndPoint iep=new IPEndPoint(ServerIp,8000);socket=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);byte byteMessage=new byte100;this.label1.Text=iep.ToString();socket.Bind(iep);/do while(true)try socket.Listen(5);Socket newSocket=socket.Accept();newSocket.Receive(byteMessage);string sTime=DateTime.Now.ToShortTimeString();string msg=sTime+:+Message from:;msg+=newSocket.RemoteEndPoint.ToString()+Encoding.Default.GetString(byteMessage);this.listBox1.Items.Add(msg);catch(SocketException ex)this.label1.Text+=ex.ToString();/while(byteMessage!=null);/开始监听private void button1_Click(object sender,System.EventArgs e)try mythread=new Thread(new ThreadStart(BeginListen);mythread.Start();catch(System.Exception er)MessageBox.Show(er.Message,完成,MessageBoxButtons.OK,MessageBoxIcon.Stop);/客户端：using System.Net;using System.Net.Sockets;using System.Text;private void button1_Click(object sender,System.EventArgs e)BeginSend();private void BeginSend()string ip=this.txtip.Text;string port=this.txtport.Text;IPAddress serverIp=IPAddress.Parse(ip);int serverPort=Convert.ToInt32(port);IPEndPoint iep=new IPEndPoint(serverIp,serverPort);byte byteMessage;Socket socket=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);socket.Connect(iep);byteMessage=Encoding.ASCII.GetBytes(textBox1.Text);socket.Send(byteMessage);socket.Shutdown(SocketShutdown.Both);socket.Close();/基于 TCP协议的发送和接收端/TCP 协议的接收端using System.Net.Sockets;/使用到 TcpListen 类using System.Threading;/使用到线程using System.IO;/使用到 StreamReader类int port=8000;/定义侦听端口号private Thread thThreadRead;/创建线程，用以侦听端口号，接收信息private TcpListener tlTcpListen;/侦听端口号private bool blistener=true;/设定标示位，判断侦听状态private NetworkStream nsStream;/创建接收的基本数据流private StreamReader srRead;private System.Windows.Forms.StatusBar statusBar1;private System.Windows.Forms.Button button1;private System.Windows.Forms.ListBox listBox1;/从网络基础数据流中读取数据private TcpClient tcClient;private void Listen()try tlTcpListen=new TcpListener(port);/以 8000端口号来初始化TcpListener实例tlTcpListen.Start();/开始监听statusBar1.Text=正在监听 ;tcClient=tlTcpListen.AcceptTcpClient();/通过 TCP连接请求nsStream=tcClient.GetStream();/获取用以发送、接收数据的网络基础数据流srRead=new StreamReader(nsStream);/以得到的网络基础数据流来初始化StreamReader 实例statusBar1.Text=已经连接！;while(blistener)/循环侦听 string sMessage=srRead.ReadLine();/从网络基础数据流中读取一行数据if(sMessage=STOP)/判断是否为断开TCP连接控制码 tlTcpListen.Stop();/关闭侦听nsStream.Close();/释放资源srRead.Close();statusBar1.Text=连接已经关闭！;thThreadRead.Abort();/中止线程return;string sTime=DateTime.Now.ToShortTimeString();/获取接收数据时的时间listBox1.Items.Add(sTime+sMessage);catch(System.Security.SecurityException)MessageBox.Show(侦听失败！,错误);/开始监听private void button1_Click(object sender,System.EventArgs e)thThreadRead=new Thread(new ThreadStart(Listen);thThreadRead.Start();/启动线程button1.Enabled=false;/清理所有正在使用的资源。protected override void Dispose(bool disposing)try tlTcpListen.Stop();/关闭侦听nsStream.Close();srRead.Close();/释放资源thThreadRead.Abort();/中止线程 catch if(disposing)if(components!=null)components.Dispose();base.Dispose(disposing);/TCP 协议的发送端using System.Net.Sockets;/使用到 TcpListen 类using System.Threading;/使用到线程using System.IO;/使用到 StreamWriter类using System.Net;/使用 IPAddress 类、IPHostEntry类等private StreamWriter swWriter;/用以向网络基础数据流传送数据private NetworkStream nsStream;/创建发送数据的网络基础数据流private TcpClient tcpClient;private System.Windows.Forms.Button button1;private System.Windows.Forms.TextBox textBox1;private System.Windows.Forms.Button button2;private System.Windows.Forms.TextBox textBox2;private System.Windows.Forms.StatusBar statusBar1;private System.Windows.Forms.Label label1;private System.Windows.Forms.Label label2;/通过它实现向远程主机提出TCP连接申请private bool tcpConnect=false;/定义标识符，用以表示TCP连接是否建立/连接private void button1_Click(object sender,System.EventArgs e)IPAddress ipRemote;try ipRemote=IPAddress.Parse(textBox1.Text);catch/判断给定的 IP 地址的合法性 MessageBox.Show(输入的 IP 地址不合法！,错误提示！);return;IPHostEntry ipHost;try ipHost=Dns.Resolve(textBox1.Text);catch/判断 IP 地址对应主机是否在线 MessageBox.Show(远程主机不在线！,错误提示！);return;string sHostName=ipHost.HostName;try TcpClient tcpClient=new TcpClient(sHostName,8000);/对远程主机的8000 端口提出 TCP连接申请nsStream=tcpClient.GetStream();/通过申请，并获取传送数据的网络基础数据流swWriter=new StreamWriter(nsStream);/使用获取的网络基础数据流来初始化 StreamWriter 实例button1.Enabled=false;button2.Enabled=true;tcpConnect=true;statusBar1.Text=已经连接！;catch MessageBox.Show(无法和远程主机 8000 端口建立连接！,错误提示！);return;/发送private void button2_Click(object sender,System.EventArgs e)if(textBox2.Text!=)swWriter.WriteLine(textBox2.Text);/刷新当前数据流中的数据swWriter.Flush();else MessageBox.Show(发送信息不能为空！,错误提示！);/清理所有正在使用的资源。protected override void Dispose(bool disposing)if(tcpConnect)swWriter.WriteLine(STOP);/发送控制码swWriter.Flush();/刷新当前数据流中的数据nsStream.Close();/清除资源swWriter.Close();if(disposing)if(components!=null)components.Dispose();base.Dispose(disposing);
