C#后台线程通过UDP发布信息到前台

目的

如何写一个前台WinForm，收集显示后台线程发布来的状态数据。

技术

UDP发送和接收

简明说明和范例，可以到微软doc搜索C# udpClient send。但是那个范例里面没有教你怎样在GUI线程显示。
阿里云cnblogs.com>>叶图的博客>>C# UDP 广播信息也有很大参考价值。本文UDP收发代码来自这个博客。

UDP发送

写了个小类。可以在后台线程调用。

using System.Text;
using System.Net.Sockets;
using System.Net;

namespace UDPTxRxExample
{
    class UDPBroadcaster
    {
        UdpClient udpClient;
        IPEndPoint clientIPEndPoint;

        public string TxMessage { set; get; }

        public UDPBroadcaster(int port)
        {
            TxMessage = "no message";
            udpClient = new UdpClient();
            clientIPEndPoint = new IPEndPoint(IPAddress.Broadcast, port);
        }

        public void Broadcast()
        {
            byte[] txBuffer = Encoding.UTF8.GetBytes(TxMessage);
            udpClient.Send(txBuffer, txBuffer.Length, clientIPEndPoint);
        }
    }
}

后台线程调用如下：

//init UDP broadcaster
UDPBroadcaster udpBC = new UDPBroadcaster(10288);

//后台引擎循环内部
//Json格式生成汇报数据文本，当然你真实的代码要用变量生成这个string
udpBC.TxMessage = "
{
	Var1:1.2,
	Var2:2.012
}"
udpBC.Broadcast();

接收

定义数据结构

        class UDPInfo
        {
            public double Var1{ get; set; }
            public double Var2{ get; set; }
         }

WinFORM代码

初始化

        UdpClient udpServer = new UdpClient(10288);
        IPEndPoint serverIPEndPoint = new IPEndPoint(IPAddress.Any, 10288);
        UDPInfo info = new UDPInfo;

启动Form就启动udpServer (实际上就是udpClient接收端)

udpServer.BeginReceive(UDPReceived, udpServer);

其中UDPReceived是一个回调方法，每次收到UDP包就调用：

        void UDPReceived(IAsyncResult iar)
        {
            udpServer = iar.AsyncState as UdpClient;
            byte[] rxBuffer = udpServer.EndReceive(iar, ref serverIPEndPoint);
            string rxMsg = Encoding.UTF8.GetString(rxBuffer).Trim();
			//这里是前台显示的重点，要用委托
            this.BeginInvoke(new Action(() =>
            {
                try
                {
                  //json解译信息
                    info = JsonConvert.DeserializeObject<RRSV2LibInfo>(rxMsg);
                    //***** 这里写显示到Form空间的代码 *****
                    
					//**********************************************
                }	
                catch (Exception es)
                {
                    //error handling here
                }
            }));            
            //再次启动接收UDP
            udpServer.BeginReceive(UDPReceived, udpServer);
        }