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

Daily Archives: 2011年6月4日

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

龙生   04 Jun 2011
View Details

C#UDP通信 | C#UDP广播

Internet协议族中有支持无连接的传输协议，即UDP协议。UDP协议提供了一种方法来发送经过封装的IP数据报，而且不必建立连接就 可以发送这些IP数据报。 服务器端：

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
using System;
using System.Collections.Generic;
using System.Text;
using System.Net;
using System.Net.Sockets;
 
namespace UDPServer
{
    class Program
    {
        static void Main(string[] args)
        {
            int recv;
            byte[] data = new byte[1024];
 
            //构建TCP 服务器
 
            //得到本机IP，设置TCP端口号        
            IPEndPoint ipep = new IPEndPoint(IPAddress.Any, 8001);
            Socket newsock = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
 
            //绑定网络地址
            newsock.Bind(ipep);
 
            Console.WriteLine("This is a Server, host name is {0}", Dns.GetHostName());
 
            //等待客户机连接
            Console.WriteLine("Waiting for a client");
 
            //得到客户机IP
            IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0);
            EndPoint Remote = (EndPoint)(sender);
            recv = newsock.ReceiveFrom(data, ref Remote);
            Console.WriteLine("Message received from {0}: ", Remote.ToString());
            Console.WriteLine(Encoding.ASCII.GetString(data, 0, recv));
 
            //客户机连接成功后，发送欢迎信息
            string welcome = "Welcome ! ";
 
            //字符串与字节数组相互转换
            data = Encoding.ASCII.GetBytes(welcome);
 
            //发送信息
            newsock.SendTo(data, data.Length, SocketFlags.None, Remote);
            while (true)
            {
                data = new byte[1024];
                //发送接受信息
                recv = newsock.ReceiveFrom(data, ref Remote);
                Console.WriteLine(Encoding.ASCII.GetString(data, 0, recv));
                newsock.SendTo(data, recv, SocketFlags.None, Remote);
            }
        }
 
    }
}

    客户端：

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
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
 
namespace UDPClient
{
    class Program
    {
        static void Main(string[] args)
        {
            byte[] data = new byte[1024];
            string input, stringData;
 
            //构建TCP 服务器
 
            Console.WriteLine("This is a Client, host name is {0}", Dns.GetHostName());
 
            //设置服务IP，设置TCP端口号
            IPEndPoint ipep = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8001);
 
            //定义网络类型，数据连接类型和网络协议UDP
            Socket server = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
 
            string welcome = "Hello! ";
            data = Encoding.ASCII.GetBytes(welcome);
            server.SendTo(data, data.Length, SocketFlags.None, ipep);
            IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0);
            EndPoint Remote = (EndPoint)sender;
 
            data = new byte[1024];
            //对于不存在的IP地址，加入此行代码后，可以在指定时间内解除阻塞模式限制
            //server.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReceiveTimeout, 100);
            int recv = server.ReceiveFrom(data, ref Remote);
            Console.WriteLine("Message received from {0}: ", Remote.ToString());
            Console.WriteLine(Encoding.ASCII.GetString(data, 0, recv));
            while (true)
            {
                input = Console.ReadLine();
                if (input == "exit")
                    break;
                server.SendTo(Encoding.ASCII.GetBytes(input), Remote);
                data = new byte[1024];
                recv = server.ReceiveFrom(data, ref Remote);
                stringData = Encoding.ASCII.GetString(data, 0, recv);
                Console.WriteLine(stringData);
            }
            Console.WriteLine("Stopping Client.");
            server.Close();
        }
 
    }
}

    MSDN 实例

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
// This constructor arbitrarily assigns the local port number.
UdpClient udpClient = new UdpClient(11000);
    try{
         udpClient.Connect("www.contoso.com ", 11000);
 
         // Sends a message to the host to which you have connected.
         Byte[] sendBytes = Encoding.ASCII.GetBytes("Is anybody there?");
     
         udpClient.Send(sendBytes, sendBytes.Length);
 
         // Sends a message to a different host using optional hostname and port parameters.
         UdpClient udpClientB = new UdpClient();
         udpClientB.Send(sendBytes, sendBytes.Length, "AlternateHostMachineName", 11000);
 
         //IPEndPoint object will allow us to read datagrams sent from any source.
         IPEndPoint RemoteIpEndPoint = new IPEndPoint(IPAddress.Any, 0);
 
         // Blocks until a message returns on this socket from a remote host.
         Byte[] receiveBytes = udpClient.Receive(ref RemoteIpEndPoint);
         string returnData = Encoding.ASCII.GetString(receiveBytes);
  
         // Uses the IPEndPoint object to determine which of these two hosts responded.
         Console.WriteLine("This is the message you received " +
                                      returnData.ToString());
         Console.WriteLine("This message was sent from " +
                                     RemoteIpEndPoint.Address.ToString() +
                                     " on their port number " +
                                     RemoteIpEndPoint.Port.ToString());
 
          udpClient.Close();
          udpClientB.Close();
         
          } 
       catch (Exception e ) {
                  Console.WriteLine(e.ToString());
        }

Microsoft Visual Studio 2005/.NET Framework 2.0 同时提供下列产品的其他版本： •.NET Framework 3.0 •Microsoft Visual Studio 2008/.NET Framework 3.5 .NET Framework 类库UdpClient 成员 提供用户数据报 (UDP) 网络服务。 下表列出了由 UdpClient 类型公开的成员。 公共构造函数 名称  说明 UdpClient  已重载。初始化 UdpClient 类的新实例。 公共属性 （请参见 受保护的属性 ）   名称  说明 Available  获取从网络接收的可读取的数据量。 Client  获取或设置基础网络 Socket。 DontFragment  获取或设置 Boolean 值，指定 UdpClient 是否允许对 Internet 协议 (IP) 数据报进行分段。 EnableBroadcast  获取或设置 Boolean 值，指定 UdpClient 是否可以发送或接收广播数据包。 ExclusiveAddressUse  获取或设置 Boolean 值，指定 UdpClient 是否只允许一个客户端使用端口。 MulticastLoopback  获取或设置 Boolean 值，指定是否将输出多路广播数据包传递给发送应用程序。 Ttl  获取或设置一个值，指定由 UdpClient 发送的 Internet […]

龙生   04 Jun 2011
View Details

Copyright © 2025 Longsheng All rights reserved