基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：78630559

本次赞助数额为： 4 元　

支付宝支付

微信支付

   源码介绍

---

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.IO.Ports;
using System.IO;
using System.Diagnostics;
using IP;


namespace BYJ
{
    public partial class Form1 : Form
    {
        Socket mysocket;
        Socket myserver;
        IPAddress ip;
        IPEndPoint point = new IPEndPoint(IPAddress.Any, 0);
        Thread thReceive;
        UdpClient RecUdpClient;
        string filename;
        SerialPort myport = new SerialPort();
        string[] a = new string[5];
        int size = 1024;
        byte[] buffer = new byte[1024*1024];
        BinaryReader br;
        FileStream fs;

      System.Windows.Forms.Timer  timer1 = new System.Windows.Forms.Timer();
      //  MyTcpServer myserver;
        Form2 f = new Form2();
        
        public Form1()
        {
            InitializeComponent();
            this.MaximizeBox = false;
            timer1.Tick  = new EventHandler(button_send_Click);
            timer1.Interval = 1000;
            comboBox1_type.Items.AddRange(new object[]{
            "TCP服务端","TCP客户端","UDP服务端","UDP客户端","串口"
            });
            textBox1_IP.Text = "192.168.10.1";
            textBox2_Port.Text = "8080";
            comboBox1_type.SelectedIndex = 4;
            myport.DataReceived  = Port_DataReceived;
            a[0] = "COM1";
            a[1] = "9600";
            a[2] = "N";
            a[3] = "8";
            a[4] = "1"; 
        }


        void TSReceive()
        {
            mysocket = myserver.Accept();//服务端监听到的Socket为服务端发送数据的目标socket
            while (true)
            {
                try
                {
                    int r = mysocket.Receive(buffer);//接收到监听的Socket的数据
                    if (checkBox4.Checked == true)//接收文件
                    {
                        fs.Write(buffer, 0, r);
                        fs.Close();
                    }

                    if (checkBox1.Checked == true)//16进制
                    {
                        buffer = change(buffer);
                        r *= 2;
                    }
                    if (r == 0)
                    {
                        MessageBox.Show("连接断开");
                        break;
                    }
                    string strRec = Encoding.Default.GetString(buffer, 0, r);
                    textBox2_recv.AppendText(strRec   "\r\n");
                 //   textBox2_recv.AppendText(mysocket.RemoteEndPoint.ToString()   ":"   strRec   "\r\n");
                }
                catch
                { }
            }
        }
      
        void TCReceive()
        {
            while (true)
            {
                try
                {
                      int r = mysocket.Receive(buffer);
                      if (checkBox4.Checked == true)//接收文件
                    {
                        fs.Write(buffer, 0, r);
                        fs.Close();
                    }

                    if (checkBox1.Checked == true)//16进制
                    {
                        buffer = change(buffer);
                        r *= 2;
                    }
                    if (r == 0)
                    {
                        MessageBox.Show("连接断开");
                        break;
                    }
                    string strRec = Encoding.Default.GetString(buffer, 0, r);
                    textBox2_recv.AppendText(strRec   "\r\n");
                 //   textBox2_recv.AppendText(mysocket.RemoteEndPoint.ToString()   ":"   strRec   "\r\n");
                }
                catch
                { }
            }
        }


        //UDP Clinet接收线程
        void UCReceive()
        {
            while (true)
            {
                try
                {
                    IPEndPoint ss = new IPEndPoint(IPAddress.Any, 0);
                    EndPoint Remote = (EndPoint)(ss);
                    int r = mysocket.ReceiveFrom(buffer, ref Remote);//接收目标IP Remote 发送过来的数
                    if (checkBox4.Checked == true)//接收文件
                    {
                        fs.Write(buffer, 0, r);
                        fs.Close();
                    }

                    if (checkBox1.Checked == true)//16进制
                    {
                        buffer = change(buffer);
                        r *= 2;
                    }
                    string strRec = Encoding.Default.GetString(buffer, 0, r);
                    textBox2_recv.AppendText(strRec   "\r\n");
                 //   textBox2_recv.AppendText(Remote.ToString() ":" strRec   "\r\n");
                }
                catch
                { }
            }
        }
        //UDP Server接收线程
        void USReceive()
        {
            while (true)
            {
                try
                {

                    buffer = RecUdpClient.Receive(ref point);
                    int r = buffer.Length;
                    if (checkBox4.Checked == true)//接收文件
                    {
                        fs.Write(buffer, 0, r);
                        fs.Close();
                    }
                 
                    if (checkBox1.Checked == true)//16进制
                    {
                        buffer = change(buffer);
                    }
                    else
                    {  }

                    string strRec = Encoding.Default.GetString(buffer);
                    textBox2_recv.AppendText(strRec   "\r\n");
                  //  textBox2_recv.AppendText(point.ToString()   ": "   strRec   "\r\n");
                }
                catch
                { }
            }
        }

        private void button1_Click(object sender, EventArgs e)
        {
          int port = Int32.Parse(textBox2_Port.Text);
          ip = IPAddress.Parse(textBox1_IP.Text);
            switch (comboBox1_type.SelectedIndex)
            {
                case 0://TCP服务端
                    myserver = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                    point = new IPEndPoint(ip, Convert.ToInt32(textBox2_Port.Text));//绑定端口号
                    
                    if (button1.Text == "断开")
                    {
                        myserver.Close();
                        button1.Text = "连接";
                        comboBox1_type.Enabled = true;
                    }
                    else
                    {
                        try
                        {
                            myserver.Bind(point);//绑定监听端口
                            myserver.Listen(10);
                            thReceive = new Thread(TSReceive);
                            thReceive.IsBackground = true;
                            thReceive.Start();
                            button1.Text = "断开";
                            comboBox1_type.Enabled = false;
                        }
                        catch (SocketException ex)
                        {
                            MessageBox.Show(ex.Message);
                        }
                    }
                    break;
                case 1://TCP客户端
                    mysocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            
                    if(button1.Text=="断开")
                    {
                        mysocket.Close();
                        button1.Text = "连接";
                        comboBox1_type.Enabled = true;
                    }
                    else
                    {
                        try
                        {
                            mysocket.Connect(new IPEndPoint(ip, port));
                            thReceive = new Thread(TCReceive);
                            thReceive.IsBackground = true;
                            thReceive.Start();
                            button1.Text = "断开";
                            comboBox1_type.Enabled = false;
                        }
                        catch (SocketException ex)
                        {
                            MessageBox.Show(ex.Message);
                        }  
                    }
                   
                    break;
                case 2://UDP服务端
                          if (button1.Text == "断开")
                    {
                        mysocket.Close();
                        button1.Text = "连接";
                        comboBox1_type.Enabled = true;
                    }
                    else
                    {
                        try
                        {
                            mysocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
                            ip = IPAddress.Parse(textBox1_IP.Text);
                
                            RecUdpClient = new UdpClient(new IPEndPoint(ip, Convert.ToInt32(textBox2_Port.Text)));

                            thReceive = new Thread(USReceive);
                            thReceive.IsBackground = true;
                            thReceive.Start();
                            button1.Text = "断开";
                            comboBox1_type.Enabled = false;
                        }
                        catch (SocketException ex)
                        {
                            MessageBox.Show(ex.Message);
                        }
                    }
                    break;
                
                case 3://UDP客户端
                    if (button1.Text == "断开")
                    {
                        mysocket.Close();
                        button1.Text = "连接";
                        comboBox1_type.Enabled = true;
                    }
                    else
                    {
                        try
                        {
                            mysocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
                            ip = IPAddress.Parse(textBox1_IP.Text);
                            point = new IPEndPoint(ip, Convert.ToInt32(textBox2_Port.Text));
                            thReceive = new Thread(UCReceive);
                            thReceive.IsBackground = true;
                            thReceive.Start();
                            button1.Text = "断开";
                            comboBox1_type.Enabled = false;
                        }
                        catch (SocketException ex)
                        {
                            MessageBox.Show(ex.Message);
                        }
                    }
                    break;

                case 4://串口
                 if(button1.Text =="打开串口")
                 {
                     openPort(myport);
                 }
                 else
                 {
                     if (myport.IsOpen)
                     {
                         myport.Close();
                         button1.Text = "打开串口";
                     }
                 }
                 break;
            }

        }

        public void openPort(SerialPort SP)
        {
            SP.PortName = a[0];
            SP.BaudRate = Convert.ToInt32(a[1]);
            string parity = a[2];
            if (parity == "N")
            {
                SP.Parity = Parity.None;
            }
            else if (parity == "E")
            {
                SP.Parity = Parity.Even;
            }
            else if (parity == "O")
            {
                SP.Parity = Parity.Odd;
            }
            float f = Convert.ToSingle(a[4].Trim());
            if (f == 1)
                SP.StopBits = StopBits.One;
            else if (f == 1.5)
                SP.StopBits = StopBits.OnePointFive;
            else if (f == 2)
                SP.StopBits = StopBits.Two;
            else
                SP.StopBits = StopBits.One;

            SP.DataBits = Convert.ToInt32(a[3]);

            try
            {
                SP.Open();
                button1.Text = "关闭串口";
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }

        }

        private void comboBox1_type_SelectedIndexChanged(object sender, EventArgs e)
        {
            if(comboBox1_type.SelectedIndex==4)
            {
                textBox1_IP.Enabled = false;
                textBox2_Port.Enabled = false;
                button2.Enabled = true;
                checkBox4.Enabled = false;
                checkBox5.Enabled = false;
            }
            else
            {
                textBox1_IP.Text = GetIP.GetLocalIP();
                textBox1_IP.Enabled = true;
                textBox2_Port.Enabled = true;
                button2.Enabled = false;

                checkBox4.Enabled = true;
                checkBox5.Enabled = true;
            }

            switch(comboBox1_type.SelectedIndex)
            {
                case 0:
                    button1.Text = "监听";
                    break;
                case 1:
                    button1.Text = "连接";
                    break;
                case 2:
                    button1.Text = "监听";
                    break;
                case 3:
                    button1.Text = "连接";
                    break;
                case 4:
                    button1.Text = "打开串口";
                    break;

            }
        }

        private static byte[] strToToHexByte(string hexString)
        {
            hexString = hexString.Replace(" ", "");
            if ((hexString.Length % 2) != 0)
            {
                int len = hexString.Length - 1;
                hexString = hexString.Insert(len, "1");
            }
            byte[] returnBytes = new byte[hexString.Length / 2];
            for (int i = 0; i < returnBytes.Length; i  )
            {
                returnBytes[i] = Convert.ToByte(hexString.Substring(i * 2, 2), 16);
                if (i == returnBytes.Length - 1)
                {
                    returnBytes[i] -= 0x10;
                }
            }
            return returnBytes;
        }
        void Port_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
            string s=null;
            byte[] buf = null;
            try
            {
                do  //确保数据接收完整----用myport.ReadExisting(s)会出现中文乱码现象
                {
                    int count = myport.BytesToRead;
                    if (count <= 0)
                        break;
                    byte[] readBuffer = new byte[count];

                    Application.DoEvents();
                    myport.Read(readBuffer, 0, count);
                    s  = System.Text.Encoding.Default.GetString(readBuffer);

                } while (myport.BytesToRead > 0);

                if (checkBox1.Checked == true)
                {
                    byte[] temp = Encoding.Default.GetBytes(s);
                    buf = change(temp);
                    s = Encoding.Default.GetString(buf, 0, buf.Length);
                }
                textBox2_recv.AppendText(s   "\n");
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
        }


        byte[] change(byte[] inbuf)//将ASCII替换成16进制
        {
            byte[] outbuf = new byte[inbuf.Length * 2];
            int i = 0, j=0,len = inbuf.Length;
            byte uctemp; 

            for (i = 0; i < len;i   )
            {
              uctemp= (byte)(inbuf[i] & 0xf0);
              uctemp = (byte)(uctemp >> 4);
                if(uctemp>9)
                {
                    uctemp  = 0x37;
                }
                else
                {
                    uctemp  = 0x30;
                }
                outbuf[j  ] = uctemp;
                uctemp = (byte)(inbuf[i] & 0x0f);
                if (uctemp > 9)
                {
                    uctemp  = 0x37;
                }
                else
                {
                    uctemp  = 0x30;
                }
                outbuf[j  ] = uctemp;

            }
                return outbuf;
        }

        private void button_send_Click(object sender, EventArgs e)
        {
            int len=0;

            byte[] buf = null;
            if (checkBox2.Checked == true)//16进制发送
            {
                byte[] temp = Encoding.Default.GetBytes(textBox1_send.Text);
                buf = change(temp);
                len = buf.Length;
            }
            else//ASCII发送
            {
                buf = Encoding.Default.GetBytes(textBox1_send.Text);
                 len = buf.Length;
            }

            if (comboBox1_type.SelectedIndex != 4)
            {
                try
                {
                    if (checkBox5.Checked == true)//发送文件
                    {
                        //将文件转换成二进制流进行发送
                        System.IO.FileStream fs =new System.IO.FileStream(filename,FileMode.Open,FileAccess.Read);
                        br = new BinaryReader(fs, Encoding.UTF8);
                        br.Read(buffer, 0, size);
                        mysocket.BeginSend(buffer, 0, size, SocketFlags.None,new AsyncCallback(EndSendFile), null);
                    }
                    else
                    {
                        mysocket.SendTo(buf, point);
                    }
                }
                catch (Exception ex)
                {
                    MessageBox.Show(ex.Message);
                }
            }
            else
            {
                try
                {
                    myport.Write(buf, 0, len);
                }
                catch (Exception ex)
                {
                    MessageBox.Show(ex.Message);
                }
            }
        
        }

        private void EndSendFile(IAsyncResult AR)
        {
            int i = 0;
            mysocket.EndSend(AR);
            //判断文件是否读完，没读完继续读到缓冲区
            if ((i = br.Read(buffer, 0, size)) != 0)
            {
                mysocket.BeginSend(buffer, 0, size, SocketFlags.None, new AsyncCallback(EndSendFile), null);
            }
        }

        private void button2_Click(object sender, EventArgs e)
        {
            f.StartPosition = FormStartPosition.CenterParent;//在窗口1中央显示
            f.ShowDialog();//弹出Form2串口参数设置窗口
            if (f.DialogResult == DialogResult.OK)
            {
                
                 a = f.str;//返回串口参数
            }
        }

        private void checkBox3_CheckedChanged(object sender, EventArgs e)
        {
            if(checkBox3.Checked ==true)//若选中则开启定时器，进行数据连发
            {
                timer1.Start();
            }
            else
            {
                timer1.Stop();
            }
        }

        private void checkBox4_CheckedChanged(object sender, EventArgs e)
        {
            SaveFileDialog sfd = new SaveFileDialog();
            //弹出文件保存选择框
            if (sfd.ShowDialog() == System.Windows.Forms.DialogResult.OK)
            {
                //创建文件流
                fs = new FileStream(sfd.FileName, FileMode.OpenOrCreate);
            }
        }

        private void checkBox5_CheckedChanged(object sender, EventArgs e)//选择要发送的文件
        {
            if (checkBox5.Checked == true)
            {
                OpenFileDialog file = new OpenFileDialog();
                file.ShowDialog();
                if (file.FileName.Length > 0)
                {
                    this.textBox1_send.Text = file.FileName;
                    filename = file.FileName;
                    textBox1_send.Enabled = false;
                }
                else
                {
                    checkBox5.Checked = false;
                }
            }
            else
            {
                textBox1_send.Clear();
                textBox1_send.Enabled = true;
            }
        }

    }
}