糯米玩PC: UDP Server(一)

UDP Server 程式碼(一)

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.IO;
  
namespace jge_UdpServer
{
    /// <summary>
    /// 事件委派宣告
    /// </summary>
    public delegate void UdpEventHandler(object sender, UdpEventArgs e);
  
    public class UDP_Server
    {
        /// <summary>
        /// 非同步接收資料的回呼
        /// </summary>
        private void EndRecvCallBack(IAsyncResult result)
        {
            try
            {
                /*傳回非同步物件*/
                Socket mResultSocket = result.AsyncState as Socket;
  
                /*呼叫 EndReceiveFrom 非同步接收*/
                int mRecvBytes = mResultSocket.EndReceiveFrom(result, ref mRemotePoint);
  
                /*將資料置入Stream */
                Stream mStream = BytesToStream(mRecvBuffer, mRecvBytes);
  
                /* Invoke */
                ((System.Windows.Forms.Form)mOwner).Invoke(
                    mSetUdpReceivedDlg, 
                    mStream, 
                    ((IPEndPoint)mRemotePoint).Address.ToString()
                  ); //.. List<byte>
  
            }
            catch (Exception ex)
            {
                //((System.Windows.Forms.Form)m_Owner).Invoke(m_SetUdpReceivedDlg, ex.Message); //??????
            }
            finally
            {
                /*重新呼叫非同步接收*/
                mSocketServer.BeginReceiveFrom(
                    mRecvBuffer, 
                    0, 
                    mRecvBuffer.Length, 
                    SocketFlags.None, 
                    ref mRemotePoint, 
                    new AsyncCallback(EndRecvCallBack), 
                    mSocketServer
                  );
            }
  
        }
  
        /// <summary>
        /// 將 Byte陣列 轉為 Stream
        /// </summary>
        /// <returns>Stream</returns>
        public static Stream BytesToStream(byte[] bytes)
        {
            Stream stream = new MemoryStream(bytes);
            return stream;
        }
  
        public static Stream BytesToStream(byte[] bytes, int Length)
        {
            Stream stream = new MemoryStream(bytes, 0, Length);
            return stream;
        }
        /// <summary>
        /// 將 Stream 轉為 Byte陣列
        /// </summary>
        public static byte[] StreamToBytes(Stream stream)
        {
            byte[] bytes = new byte[stream.Length];
            stream.Read(bytes, 0, bytes.Length);
  
            /*將 stream 指針指向開頭*/
            stream.Seek(0, SeekOrigin.Begin);
            return bytes;
        }
  
        /// <summary>
        /// 委派處理函式
        /// </summary>
        private void OnUdpReceivedText(Stream msg, string ip)
        {
            UdpEventArgs e = new UdpEventArgs(msg, ip);
  
            if (UdpReceived != null) //. 當事件變數不為 null 則執行之
            {
                UdpReceived(this, e);
            }
        }
  
        /// <summary>
        /// 委派宣告
        /// </summary>
        private delegate void SetUdpReceived(Stream msg, string ip);        
        
        /// <summary>
        /// 委派欄位
        /// </summary>
        private SetUdpReceived mSetUdpReceivedDlg;
        /// <summary>
        /// 本機端 Socket物件
        /// </summary>
        private Socket mSocketServer = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
        /// <summary>
        /// 接收資料的緩衝區
        /// </summary>
        private byte[] mRecvBuffer=new byte[10240];
        /// <summary>
        /// 初始化遠端IP和 Port端點物件
        /// </summary>
        private EndPoint mRemotePoint = new IPEndPoint(IPAddress.Any, 0);
        /// <summary>
        /// 儲存擁有者
        /// </summary>
        private object mOwner;
        /// <summary>
        /// UDP Received 事件
        /// </summary>
        public event UdpEventHandler UdpReceived; 
  
        /// <summary>
        /// 建構式
        /// </summary>
        public UDP_Server(object Owner, int APort)
        {
            mOwner = Owner;
  
            /*初始化Sockt物件*/
            mSocketServer = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
  
            /*指定要以機器上所有的網路介面,開啟的 Port*/
            IPEndPoint mIPPoint = new IPEndPoint(IPAddress.Any, APort);
  
            /*繫結 IP 和 Port 資訊*/
            mSocketServer.Bind(mIPPoint);
  
            /*設定委派處理函式*/
            mSetUdpReceivedDlg = OnUdpReceivedText;
  
            //..啟動非同步接受資料
            mSocketServer.BeginReceiveFrom(
                mRecvBuffer, 
                0, 
                mRecvBuffer.Length, 
                SocketFlags.None, 
                ref mRemotePoint, 
                new AsyncCallback(EndRecvCallBack), 
                mSocketServer
              );
        }
  
    }
  
    /// <summary>
    /// 定義專用事件參數類別
    /// </summary>
    public class UdpEventArgs:EventArgs
    {
        private string mIP;
        private Stream mMSG = new MemoryStream();
  
        public UdpEventArgs(Stream msg, string ip)
        {
            MSG = msg;
            IP = ip;
        }
  
        public string IP
        {
            get { return mIP; }
            private set { mIP = value; }
        }
  
        public Stream MSG
        {
            get { return mMSG; }
            private set { mMSG = value; }
        }
    }
  
    
}

使用該 Class

   1: int iPort = 5168;
   2: UDP_Server udpADAM;

啟動UDP封包接收伺服

   1: udpADAM = new UDP_Server(this, iPort);    // 建立物件
   2: udpADAM.UdpReceived += onUdpReceived;    // 串接事件

事件程式

#region UDP Server 事件 
private void onUdpReceived(object sender, UdpEventArgs e)
{
   
    byte[] bytes = UDP_Server.StreamToBytes(e.MSG);
    // .....
}

糯米玩PC

異世界

2012年5月22日星期二

UDP Server(一)

沒有留言:

張貼留言

異世界

2012年5月22日 星期二

UDP Server(一)

沒有留言:

張貼留言

2012年5月22日星期二