TCP UDP工具源代码

【实例简介】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
                { }
            }
        }
    }
}