一切福田，不離方寸，從心而覓，感無不通。

C# UDP通信示例

大家好，这是我最近写了一个Udp通信的小程序，发表出来和大家共同学习，我希望和大家共同进步。

upd通信接受端：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
using System;
using System.Net;
using System.Net.Sockets;
 
namespace Zhty.Socket.UDPSocket
{
    public class UDP_Client
    {
        #region 属性
        private IPAddress _ClientAddress = IPAddress.Any;
        private int _ClientPort = 0;
        private byte[] _data = new byte[] { };
 
        public IPEndPoint Client
        {
 
            get { return new IPEndPoint(_ClientAddress, _ClientPort); }
            set
            {
                _ClientAddress = value.Address;
                _ClientPort = value.Port;
            }
 
        }
 
        public IPAddress ClientAddress
        {
            get
            {
                return _ClientAddress;
            }
            set
            {
                _ClientAddress = value;
 
            }
        }
 
        public int ClientPort
        {
            get { return _ClientPort; }
            set { _ClientPort = value; }
        }
        #endregion
 
        #region 方法
        public void SendMessage(byte[] message)
        {
            // Encode message per settings
            // Send the message
            _data = message;
            try
            {
                SendUDPMessage(_data);
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
 
        private int SendUDPMessage(Byte[] _data)
        {
            //' Create a UDP Server and send the message, then clean up
            UdpClient _UDPServer = null;
            int ReturnCode;
            try
            {
                _UDPServer = new UdpClient();
                ReturnCode = 0;
                _UDPServer.Connect(Client);
                ReturnCode = _UDPServer.Send(_data, _data.Length);
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                if (_UDPServer != null)
                {
                    _UDPServer.Close();
                }
            }
            return ReturnCode;
        }
        #endregion
 
    }
}

udp通信的发送端：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
using System.Net.Sockets;
using System.Net;
 
namespace Zhty.Socket.UDPSocket
{
    public class UDP_Server
    {
 
        private Thread _ThreadReceive;
        private int _ClientPort = 0;
        private string _Message = null;
 
        private UdpClient _UDPClient;
        private IPEndPoint _Server = new IPEndPoint(IPAddress.Any, 0);
        private int _BytesReceived = 0;
 
        #region 事件定义
        public delegate void OnReceivedDataHandler(object sender, DataReceivedEventArgs e);
        public event OnReceivedDataHandler OnRecivedData;
 
        public delegate void OnStateChangedHandler(object sender, ServerStateChangeEventArgs e);
        public event OnStateChangedHandler OnStateChanged;
        #endregion
 
        #region 属性
        int _bufferSize = 1024;
        public int BufferSize
        {
            get { return _bufferSize; }
            set { _bufferSize = value; }
        }
 
        public int BytesReceived
        {
            get { return _BytesReceived; }
 
        }
 
        public string Message
        {
            get { return _Message; }
        }
 
        public int ClientPort
        {
            get { return _ClientPort; }
            set { _ClientPort = value; }
        }
        #endregion
 
        #region 方法
        void DataReceiveProc()
        {
            //BeforeReceive(this,new EventArgs());
            _Message = "";
            byte[] data = new byte[BufferSize];
            try
            {
                data = _UDPClient.Receive(ref _Server);
 
                if (OnRecivedData != null)
                    OnRecivedData(this, new DataReceivedEventArgs(data));
                Thread.Sleep(100);
            }
            catch (Exception ex)
            {
                if (OnStateChanged != null)
                    OnStateChanged(this, new ServerStateChangeEventArgs(false));
                throw ex;
            }
            finally
            {
                InitializeThread();
            }
        }
 
        private void InitializeClient()
        {
            if (_UDPClient == null)
            {
                this._UDPClient = new UdpClient(ClientPort);
            }
        }
 
        private void InitializeThread()
        {
            try
            {
                _ThreadReceive = new Thread(new ThreadStart(DataReceiveProc));
                _ThreadReceive.Start();
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
 
        public void Start()
        {
            InitializeClient();
            InitializeThread();
        }
        #endregion
 
        public void Stop()
        {
            try
            {
                _ThreadReceive.Abort();
                if (_UDPClient != null)
                {
                    // ' Close the UDPClient and then force it to Nothing
                    _UDPClient.Close();
                    _UDPClient = null;
                }
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
 
        #region 析构方法
        ~UDP_Server()
        {
            Stop();
        }
        #endregion
    }
}

辅助类：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
using System;
using System.Collections.Generic;
using System.Text;
 
namespace Zhty.Socket.UDPSocket
{
    public class DataReceivedEventArgs : EventArgs
    {
        public DataReceivedEventArgs(byte[] data)
        {
            Data = data;
        }
 
        byte[] m_Data;
        public byte[] Data
        {
            get { return m_Data; }
            set { m_Data = value; }
        }
    }
 
    public class ServerStateChangeEventArgs : EventArgs
    {
        public ServerStateChangeEventArgs(bool state)
        {
            Running = state;
        }
 
        bool m_Running;
        public bool Running
        {
            get { return m_Running; }
            set { m_Running = value; }
        }
    }
}

 

 

转自：http://www.cnblogs.com/zhaotianyu001/articles/549259.html

Copyright © 2024 Longsheng All rights reserved