UDP通信

【实例截图】

【核心代码】

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.Threading;//有线程这个很重要
using System.Net;       //声明网络
using System.Net.Sockets;//声明UDP通信

namespace udp
{
    public partial class Form1 : Form
    {
        static Socket client;//定义SOCKET 为CLIENT
        //声明3个线程
        Thread t1;
        Thread t2;
        Thread t3;
        public Form1()
        {
            InitializeComponent();
        }
         
        private void Form1_Load(object sender, EventArgs e)
        {   
        }
        public class myclass  //全局变量
        {
            public static string  DT100="";           
            public static Int64 Dt110 = 0;
             public static bool Sm100;
            public static int Tix0;
      
        }            
        private void button2_Click(object sender, EventArgs e)//手动打开
        {
            t1 = new Thread(new ThreadStart(ReciveMsg)); //固定写法
            t2 = new Thread(new ThreadStart(sendMsg));
            t3 = new Thread(new ThreadStart(sendMsg2));
            t1.Priority = ThreadPriority.Highest; //设置优先级
            t2.Priority = ThreadPriority.AboveNormal;
            t3.Priority = ThreadPriority.BelowNormal;
           client = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);//开启通信
            client.Bind(new IPEndPoint(IPAddress.Parse("192.168.0.103"), 6000));//绑定端口号和IP这是本机的
                 
            t1.Start();
            t2.Start();
            t3.Start();   
            //下面这句代码，解决：线程间操作无效: 从不是创建控件
            Control.CheckForIllegalCrossThreadCalls = false;   
        }
        static void ReciveMsg()//1接收线程这个线程不知道为什么不能用FOM窗体控件
        {

            /*
              while (true)//不是循环就做不了线程
              {             
                  EndPoint point = new IPEndPoint(IPAddress.Any, 0);//用来保存发送方的ip和端口号
                  byte[] buffer = new byte[1024];
                  int length = client.ReceiveFrom(buffer, ref point);//接收数据报
                  string message = Encoding.UTF8.GetString(buffer, 0, length);
                  //  Console.WriteLine(point.ToString()   message);          
             
                  myclass.DT100 = message;//接收的数据给变量
               //  Thread.Sleep(3);//挂起时间
              }
             */

        }        
        static void sendMsg()//2发送线程
        {
            //不想自动发，就可以不写代码
            
        }     
        private void sendMsg2()//3线程
        {
            for (bool i = false; i == false; )//这样可以一直运行
            {
                EndPoint point = new IPEndPoint(IPAddress.Any, 0);//用来保存发送方的ip和端口号
                byte[] buffer = new byte[1024];
                int length = client.ReceiveFrom(buffer, ref point);//接收数据报
                string message = Encoding.UTF8.GetString(buffer, 0, length);
                textBox6.Text = message;
               // textBox6.Text = myclass.DT100;//用线程收
            }
        }
        private void button1_Click(object sender, EventArgs e)//发送按钮
        {
            try
            {              
                EndPoint point = new IPEndPoint(IPAddress.Parse("192.168.0.106"), 6000);//绑定端口号和IP这是对方的
               string msg = textBox5.Text ;
               client.SendTo(Encoding.UTF8.GetBytes(msg), point);                          
            }
            catch
            {               
            }
        }

        private void timer1_Tick(object sender, EventArgs e)
        {
          //  textBox6.Text = myclass.DT100;//用时间接收
          
        }

        private void Form1_FormClosing(object sender, FormClosingEventArgs e)
        {
            //退出界面，关闭线程
            t1.Abort();
            t2.Abort();
            t3.Abort();
        }              
    }
        
       
    }