TCP UDP工具源代码
using System;using System.Collections.Generic;using System.ComponentModel;using System.Data;using System.Drawing;using System.Linq;using System.Net;using System.Net.Sockets;using System.Text;using System.Threading;using System.Threading.Tasks;using System.Windows.Forms;namespace NetWork{ public partial class Form1 : Form { public Form1() { InitializeComponent(); } IPAddress ip; IPEndPoint point = new IPEndPoint(IPAddress.Any,0); string protocol; Socket aimSocket; Socket mySocket; UdpClient RecUdpClient; //IPEndPoint remote; private void Form1_Load(object sender, EventArgs e)//初始化为UDP Server模式 { cobProtocol.SelectedIndex = 0; txtIP.Text = GetAddressIP(); Control.CheckForIllegalCrossThreadCalls = false; } string GetAddressIP() { string AddressIP = ""; foreach (IPAddress _IPAddress in Dns.GetHostEntry(Dns.GetHostName()).AddressList) { if (_IPAddress.AddressFamily.ToString() == "InterNetwork") { AddressIP = _IPAddress.ToString(); ip = _IPAddress;//设定全局的IP } } return AddressIP; } private void btnStart_Click(object sender, EventArgs e)//设置目标IP（Client），本地IP（Server） { try { if (protocol == "UDP Server") { aimSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); RecUdpClient = new UdpClient(new IPEndPoint(ip, Convert.ToInt32(txtPort.Text))); MessageBox.Show("UDP Server创建成功"); Thread thReceive = new Thread(USReceive); thReceive.IsBackground = true; thReceive.Start(); } else if (protocol == "UDP Client")//UPD客户端，目标IP和端口 调用Socket.SendTo { aimSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);//建立通信的Socket ip = IPAddress.Parse(txtIP.Text); point = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text)); MessageBox.Show("UDP Client设置成功"); Thread thReceive = new Thread(UCReceive); thReceive.IsBackground = true; thReceive.Start(); } else if (protocol == "TCP Server") { mySocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); point = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text));//绑定端口号 mySocket.Bind(point);//绑定监听端口 MessageBox.Show("TCP Server绑定成功"); mySocket.Listen(10);//等待连接是一个阻塞过程，创建线程来监听 Thread thReceive = new Thread(TSReceive); thReceive.IsBackground = true; thReceive.Start(); } else if (protocol == "TCP Client") { ip = IPAddress.Parse(txtIP.Text);//目标IP point = new IPEndPoint(ip, Convert.ToInt32(txtPort.Text));//目标端口 aimSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); aimSocket.Connect(point);//连接服务器 MessageBox.Show("连接成功"); Thread thReceive = new Thread(TCReceive); thReceive.IsBackground = true; thReceive.Start(); } } catch {} } private void cobProtocol_SelectedIndexChanged(object sender, EventArgs e) { //[0] UDP Server [1] UDP Client [2] TCP Server [3] TCP Client //此处设置标准位？？？ 然后为btnConnect做准备？ protocol = cobProtocol.SelectedItem.ToString(); if (protocol == "UPD Server") { lblIP.Text = "本地IP地址："; lblPort.Text = "本地端口号："; } else if (protocol == "UDP Client") { lblIP.Text = "服务器IP地址："; lblPort.Text = "服务器端口号："; } else if (protocol == "TCP Server") { lblIP.Text = "本地IP地址："; lblPort.Text = "本地端口号："; } else if (protocol == "TCP Client") { lblIP.Text = "服务器IP地址："; lblPort.Text = "服务器端口号："; } } private void btnSend_Click(object sender, EventArgs e) { try { byte[] buffer = Encoding.Default.GetBytes(txtSend.Text); aimSocket.SendTo(buffer, point); } catch { } } //TCP Server接收线程 void TSReceive() { aimSocket = mySocket.Accept();//服务端监听到的Socket为服务端发送数据的目标socket byte[] buffer = new byte[1024]; while (true) { try { int r = aimSocket.Receive(buffer);//接收到监听的Socket的数据 if (r == 0) { MessageBox.Show("连接断开"); break; } string strRec = Encoding.Default.GetString(buffer, 0, r); txtRec.AppendText(aimSocket.RemoteEndPoint.ToString() ":" strRec "\r\n"); } catch { } } } //TCP Client接收线程 void TCReceive() { byte[] buffer = new byte[1024]; while (true) { try { int r = aimSocket.Receive(buffer); if (r == 0) { MessageBox.Show("连接断开"); break; } string strRec = Encoding.Default.GetString(buffer, 0, r); txtRec.AppendText(aimSocket.RemoteEndPoint.ToString() ":" strRec "\r\n"); } catch { } } } //UDP Clinet接收线程 void UCReceive() { byte[] buffer = new byte[1024]; while (true) { try { IPEndPoint ss = new IPEndPoint(IPAddress.Any, 0); EndPoint Remote = (EndPoint)(ss); int r = aimSocket.ReceiveFrom(buffer, ref Remote);//接收目标IP Remote 发送过来的数 string strRec = Encoding.Default.GetString(buffer,0,r); txtRec.AppendText(Remote.ToString() ": " strRec "\r\n"); } catch { } } } //UDP Server接收线程 void USReceive() { while (true) { try { byte[] buffer = RecUdpClient.Receive(ref point); string strRec = Encoding.Default.GetString(buffer); txtRec.AppendText(point.ToString() ": " strRec "\r\n"); } catch { } } } }}
评论