Socket 打洞

Client：

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Threading;
using System.Net;
using System.Net.Sockets;

namespace TestClient
{
    public partial class Chat : Form
    {
        //以下是客户端到服务器端的消息开头
        const string LOGININ  = "10"   ;//请求登陆的消息|||消息形式:10+自己的用户名
        const string LOGINOUT  = "11"  ;//请求登出的消息|||消息形式:11+自己的用户名
        const string GETULIST  = "12"  ;//请求获得在线用户列表|||消息形式:12+自己的用户名
        const string P2PCONN  = "13"   ;//请求P2P连接的消息|||消息形式:13+自己的用户名+对方的用户名
        const string HOLDLINE = "14";//保持连接.|||消息开式:14+自己的用户名
        const string LOGINADD = "15";//新用户登录
        const string LOGINREMOVE = "16";//用户登出
        //以下是服务器到客户端的消息开头
        const string HVUSER = "20";//用户名已存在
        const string GETUSER = "21";//在线用户列表|||消息格式:21+用户名+EP
        const string MAKHOLD = "22";//打洞命令|||消息格式:22+IP
        const string LOGINOK = "23";//登陆成功
        const string SERVCLS = "24";//服务器关闭
        const string MSGEND = "25";//‘消息结束  
        const string CHATMSGALL = "26";//发送给所有人
        //以下是客户端到客户端的消息开头
        const string HOLDOK = "30"    ;//打洞成功
        const string CHATMSG = "31"   ;//聊天消息
        const string CHTMSGEND = "32" ;//聊天消息发送成功

private string userName;
        public string UserName
        {
            private get { return userName; }
            set { userName = value; }
        }
        private IPEndPoint serverEP;
        public IPEndPoint ServerEP
        {
            set
            {
                serverEP = value;
            }
            private get
            {
                return serverEP;
            }
        }

Socket clientSocket;
        public Socket ClientSocket
        {
            private get { return clientSocket; }
            set { clientSocket = value; }
        }

int getUrecCount;

//和服务器保持连接连接时用到的byte数组
        byte[] holdBytes;
        List<string> OLUserName;
        List<IPEndPoint> OLUserEP;
        //为保持在线状态弄得
        TimerCallback timerDelegate;
        bool msgSendEnd = false;//消息是否发送成功,若发送成功,则会返回结束消息
        private ManualResetEvent getUDone;//用来阻塞请求好友名单的线程,等待接收好友名单
        private ManualResetEvent chatDone;//用来阻塞发送聊天消息时的线程        
        private ManualResetEvent holdDone;//用来阻塞打洞时的线程        
        private ManualResetEvent sendDone ;//用来阴塞发送消息的线程.等待收到回送的确认消息

//监听的线程
        Thread thListen;        
        delegate void myMethodDelegate(ref byte[] myInData);//登陆时用的事件
        delegate void TextChangedMelegate(string text);//给textbox1赋值用到的委托
        delegate void ComboboxBindDelegate();//用户绑定combobox的委托

static bool testHold = false;
        static bool testChat = false;
        //用户列表的数据源
        DataTable dt;
        //上一条消息
        string lastMsg = "";

public Chat()
        {
            InitializeComponent();
        }

private void Chat_Load(object sender, EventArgs e)
        {
            Login login = new Login();
            login.StartPosition = FormStartPosition.CenterParent;
            login.Tag = this;
            login.ShowDialog();   
            thListen = new Thread(new ThreadStart(this.Listen));
            thListen.IsBackground = true;
            thListen.Start();
        }

public void LoadInit()
        {            
            //timerDelegate = new TimerCallback(Holdonline);
            //holdBytes = Encoding.Unicode.GetBytes(HOLDLINE + UserName);
            ////登陆成功后.用一个timer,每隔50秒向服务器发送消息,保持在线状态跟在主机注册的端口
            //System.Threading.Timer timer = new System.Threading.Timer(timerDelegate, null, 10000, 10000);
            //登陆成功后.用一个timer,每隔50秒向服务器发送消息,保持在线状态跟在主机注册的端口
            System.Windows.Forms.Timer timer = new System.Windows.Forms.Timer();
            timer.Tick += new EventHandler(Holdonline);
            timer.Interval = 50000;
            timer.Start();

//请求在线名单
            this.Text = "正在获取在线名单,请稍后....";
            bool getUbool = false;
            //while (getUbool == false)
            //{
            //    //getUbool = GetU();
            //    //if (getUbool == false)
            //    //{
            //    //    if (MessageBox.Show("是否重试?", "是否重试", MessageBoxButtons.YesNo) == DialogResult.Yes)
            //    //    {
            //    //        getUbool = false;
            //    //    }
            //    //    else
            //    //    {
            //    //        getUbool = true;
            //    //    }
            //    //}
            //}
        }

private bool GetU()
        {
            getUDone = new ManualResetEvent(false);
            byte[] getUbytes = Encoding.Unicode.GetBytes(GETULIST);
            ClientSocket.SendTo(getUbytes, ServerEP);
            byte[] data = new byte[4056];
            string comStr = Encoding.Unicode.GetString(data, 0, 4);
            myMethodDelegate GUrecv = new myMethodDelegate(RecvGetU);
            GUrecv.BeginInvoke(ref data, null, null);
            getUDone.WaitOne(30000, true);
            string recvStr = Encoding.Unicode.GetString(data, 0, 4);
            if (recvStr == comStr)
            {
                MessageBox.Show("服务器超时.或取好友名单失败!!");
                return false;
            }
            string test = Encoding.Unicode.GetString(data);
            if (Encoding.Unicode.GetString(data, 0, 4) == GETUSER)
            {
                GetUserList(data, getUrecCount);
                this.comboBox1.Invoke(new ComboboxBindDelegate(ShowUserList));
                //ShowUserList();
                return true;
            }
            else
            {
                MessageBox.Show("服务器未知错误,获取在线名单失败!!");
                return false;
            }
        }

/// <summary>
        /// 显示在线用户
        /// </summary>
        private void ShowUserList()
        {
            lock (OLUserName)
            {
                dt = new DataTable();
                dt.Columns.Add("Name");
                dt.Columns.Add("IP");
                DataRow dr1 = dt.NewRow();
                dr1["Name"] = "所有人";
                dt.Rows.Add(dr1);
                this.comboBox1.DataSource = dt;
                this.comboBox1.ValueMember = "IP";
                this.comboBox1.DisplayMember = "Name";
                for (int i = 0; i < OLUserName.Count; i++)
                {
                    if (OLUserName[i] != "")
                    {
                        DataRow dr = dt.NewRow();
                        dr["Name"] = OLUserName[i];
                        dr["IP"] = OLUserEP[i];
                        dt.Rows.Add(dr);
                    }
                }
            }
        }

/// <summary>
        /// 处理收到的在线用户信息
        /// </summary>
        /// <param name="userInfobytes"></param>
        /// <param name="reccount"></param>
        private void GetUserList(byte[] userInfobytes, int reccount)
        {
            string ustr = Encoding.Unicode.GetString(userInfobytes, 4, reccount - 4);

string[] splitStr = null;
            splitStr = ustr.Split(‘|‘);
            string[] IPEPSplit = null;
            OLUserName = new List<string>();
            OLUserEP = new List<IPEndPoint>();
            int i = 0;
            for(int k=0;k<splitStr.Length -2;k = k+2)
            {
                OLUserName.Add(splitStr[k]);
                IPEPSplit = splitStr[k + 1].Split(‘:‘);
                OLUserEP.Add(new IPEndPoint(IPAddress.Parse(IPEPSplit[0]), Convert.ToInt32(IPEPSplit[1])));
                IPEPSplit = null;
                i++;
            }
        }

//用保持在线状态的函数
        private void Holdonline(object state,EventArgs e)
        {
            holdBytes = Encoding.Unicode.GetBytes(HOLDLINE + UserName);
            ClientSocket.SendTo(holdBytes, ServerEP);
        }

//登陆时用来异步的接收服务器发送的消息
        void RecvGetU(ref byte[] inData)
        {
            getUrecCount = ClientSocket.Receive(inData);
            getUDone.Set();
        }

/// <summary>
        /// 发送
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void buttonSend_Click(object sender, EventArgs e)
        {
            if (this.textBox2.Text.Trim() == "")
                return;
            else
            {
                SendChatMsg(this.comboBox1.Text, this.textBox2.Text);
            }
        }

/// <summary>
        /// 发送聊天消息
        /// </summary>
        /// <param name="remoteUser"></param>
        /// <param name="chatMsgStr"></param>
        private void SendChatMsg(string remoteUser, string chatMsgStr)
        {
            if (lastMsg.Trim() == chatMsgStr.Trim())
            {
                MessageBox.Show("看你傻样，还想刷屏!");
                return;
            }
            else
                lastMsg = chatMsgStr;
            IPEndPoint remoteUEP = null;
            if (remoteUser == "所有人")
            {
                for(int i=0;i<OLUserName.Count;i++)
                {
                    if (OLUserName[i].ToUpper().Trim() == this.UserName.ToUpper().Trim())
                        continue;
                    byte[] msgbytes = Encoding.Unicode.GetBytes(CHATMSGALL + UserName + "|" + chatMsgStr);                    
                    string test = OLUserEP[i].Address.ToString();
                    string port = OLUserEP[i].Port.ToString();
                    ClientSocket.SendTo(msgbytes, OLUserEP[i]);                    
                }
                this.textbox.AppendText(this.UserName + " to " + this.comboBox1.Text + ":" + chatMsgStr + "\n");
                this.textbox.Focus();
                Application.DoEvents();
                this.textBox2.Focus();
            }
            else
            {
                for (int i = 0; i < OLUserName.Count; i++)
                {
                    if (remoteUser == OLUserName[i])
                        remoteUEP = OLUserEP[i];
                }
                byte[] msgbytes = Encoding.Unicode.GetBytes(CHATMSG + userName + "|" + chatMsgStr);
                byte[] holdbytes = Encoding.Unicode.GetBytes(P2PCONN + userName + "|" + remoteUser);
                chatDone = new ManualResetEvent(false);
                string test = remoteUEP.Address.ToString();
                string port = remoteUEP.Port.ToString();
                ClientSocket.SendTo(msgbytes, remoteUEP);
                chatDone.WaitOne(1000, true);
                this.textbox.AppendText(this.UserName + " to " + this.comboBox1.Text + ":" + chatMsgStr + "\n");
                //this.textbox.Focus();
                Application.DoEvents();
                //this.textBox2.Focus();

if (testChat)
                {
                    testChat = false;
                    return;
                }
                testHold = false;
                while (testHold == false)
                {
                    //开始打洞
                    holdDone = new ManualResetEvent(false);
                    ClientSocket.SendTo(holdbytes, remoteUEP);
                    ClientSocket.SendTo(holdbytes, ServerEP);
                    holdDone.WaitOne(1000, true);
                    if (testHold == false)
                    {
                        //打洞超时
                        testHold = true;
                    }
                    else
                    {
                        //打洞成功                    
                    }
                }
                while (testChat == false)
                {
                    //打洞成功准备发送
                    chatDone = new ManualResetEvent(false);

ClientSocket.SendTo(msgbytes, remoteUEP);
                    chatDone.WaitOne(1000, true);
                    if (testChat == false)
                    {
                        //发送超时
                        testChat = true;
                    }
                    else
                    {
                        //发送成功
                        testChat = true;
                    }
                }
            }
            this.textBox2.Text = "";
            testHold = false;
            testChat = false;
        }

/// <summary>
        /// 客户程序监听的函数
        /// </summary>
        private void Listen()
        {
            while (true)
            {
                try
                {
                    int recv = 0;//收到的字节数
                    byte[] data = new byte[1024];//缓冲区大小
                    IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0);
                    EndPoint tempRemoteEP = (EndPoint)sender;
                    
                    recv = ClientSocket.ReceiveFrom(data, ref tempRemoteEP);
                    //获得消息头的内容
                    string msgHead = Encoding.Unicode.GetString(data, 0, 4);
                    switch (msgHead)
                    {                           
                        case MSGEND:
                            msgSendEnd = true;
                            sendDone.Set();
                            break;
                        case LOGININ:
                            AddOnLine(data, recv);
                            break;
                        case LOGINOUT:
                            RemoveOnLine(data, recv);
                            break;
                        case MAKHOLD:
                            MakeHold(data, recv);
                            break;
                        case CHATMSG:
                            ShowChatMsg(data, recv);
                            break;
                        case CHATMSGALL:
                            ShowChatMsgAll(data, recv);
                            break;
                        case HOLDOK:
                            testHold = true;
                            holdDone.Set();
                            break;
                        case CHTMSGEND:
                            testChat = true;
                            chatDone.Set();
                            break;
                        case LOGINADD:
                            this.GetU();
                            break;
                        case LOGINREMOVE:
                            this.GetU();
                            break;
                    }
                }
                catch
                { }
            }
        }

/// <summary>
        /// 处理聊天消息
        /// </summary>
        /// <param name="data"></param>
        /// <param name="recv"></param>
        private void ShowChatMsgAll(byte[] data, int recv)
        {
            string msgStr = Encoding.Unicode.GetString(data, 4, recv - 4);
            string[] splitStr = msgStr.Split(‘|‘);
            string fromUname = splitStr[0];
            string msg = splitStr[1];
            this.textbox.Invoke(new TextChangedMelegate(SetTextBox), fromUname + " to 所有人：" + msg);            
        }

/// <summary>
        /// 处理聊天消息
        /// </summary>
        /// <param name="data"></param>
        /// <param name="recv"></param>
        private void ShowChatMsg(byte[] data, int recv)
        {
            string msgStr = Encoding.Unicode.GetString(data, 4, recv-4);
            string[] splitStr = msgStr.Split(‘|‘);
            string fromUname = splitStr[0];
            string msg = splitStr[1];
            this.textbox.Invoke(new TextChangedMelegate(SetTextBox), fromUname + " to " + userName + ":" + msg);
            //this.textBox1.Text += fromUname + " to " + userName + ":" + msg + "\n";
            byte[] tempbytes = Encoding.Unicode.GetBytes(CHTMSGEND);
            for (int i = 0; i < OLUserName.Count; i++)
            {
                if (OLUserName[i].ToUpper() == fromUname.ToUpper())
                {
                    ClientSocket.SendTo(tempbytes, OLUserEP[i]);
                }
            }
        }

private void SetTextBox(string text)
        {
            this.textbox.SelectionColor = Color.Blue;
            this.textbox.AppendText(text + "\n");
            //this.textbox.Focus();
            Application.DoEvents();
            //this.textBox2.Focus();
        }

/// <summary>
        /// 处理打洞函数
        /// </summary>
        /// <param name="data"></param>
        /// <param name="recv"></param>
        private void MakeHold(byte[] indata, int recvcount)
        {
            string makholdstr = Encoding.Unicode.GetString(indata, 4, recvcount);
            string[] ipepstr = makholdstr.Split(‘:‘);
            IPEndPoint holdEP = new IPEndPoint(IPAddress.Parse(ipepstr[0]), Convert.ToInt32(ipepstr[1]));
            byte[] holdbytes = Encoding.Unicode.GetBytes(HOLDOK + UserName);            
            //回送打洞消息
            ClientSocket.SendTo(holdbytes, holdEP);
        }

/// <summary>
        /// 处理用户上线的函数
        /// </summary>
        private void AddOnLine(byte[] inData, int recvCount)
        {
            string inStr = Encoding.Unicode.GetString(inData, 4, recvCount - 4);
            string[] userinfo = inStr.Split(‘|‘);
            string[] strUserEP = userinfo[1].Split(‘:‘);
            int count = OLUserName.Count - 1;
            //for (int i = 0; i < count; i++)
            //{
            //    if (OLUserName[i] == "")
            //    {
            OLUserName.Add(userinfo[0]);
            IPEndPoint ip = new IPEndPoint(IPAddress.Parse(strUserEP[0]), Convert.ToInt32(strUserEP[1]));
            OLUserEP.Add(ip);
            lock (dt)
            {
                DataRow dr = this.dt.NewRow();
                dr["Name"] = userinfo[0];
                dr["IP"] = ip;
                dt.Rows.Add(dr);
            }
            this.textbox.Invoke(new TextChangedMelegate(SetTextBox), userinfo[0] + "上线了!");
            
            //this.textBox1.Text += userinfo[0] + "上线了!\n";
            //break;
            //    }
            //}
        }

/// <summary>
        /// 处理用户下线的函数
        /// </summary>
        private void RemoveOnLine(byte[] inData,int recvCount)
        {
            string offUname = Encoding.Unicode.GetString(inData,4,recvCount-4);
            for(int i = 0; i< OLUserName.Count-1;i++)
            {
                if(OLUserName[i] == offUname)
                {
                    OLUserName.Remove(offUname);
                    OLUserEP.RemoveAt(i);
                    lock (dt)
                    {
                        foreach (DataRow dr in dt.Rows)
                        {
                            if (dr["name"].ToString().Trim() == offUname.Trim())
                            {
                                dt.Rows.Remove(dr);
                                break;
                            }
                        }
                    }
                    this.textbox.Invoke(new TextChangedMelegate(SetTextBox), offUname + "下线了!");
                    //this.textBox1.Text += offUname + "下线了！\n";
                    break;
                }
            }
        }

private void textBox2_KeyPress(object sender, KeyPressEventArgs e)
        {
            if (e.KeyChar == ‘\r‘)
                this.buttonSend_Click(null, null);
        }

private void textbox_TextChanged(object sender, EventArgs e)
        {
            ////让文本框获取焦点   
            //this.textbox.Focus();
            ////设置光标的位置到文本尾   
            //this.textbox.Select(this.richTextBoxInfo.TextLength, 0);
            ////滚动到控件光标处   
            //this.textbox.ScrollToCaret();
        }

private void Chat_FormClosed(object sender, FormClosedEventArgs e)
        {
            this.thListen.Abort();
            string loginOutStr = LOGINOUT + UserName;
            byte[] sendBytes = Encoding.Unicode.GetBytes(loginOutStr);
            ClientSocket.SendTo(sendBytes,ServerEP);
        }
    }
}

namespace TestClient
{
    partial class Chat
    {
        /// <summary>
        /// 必需的设计器变量。
        /// </summary>
        private System.ComponentModel.IContainer components = null;

/// <summary>
        /// 清理所有正在使用的资源。
        /// </summary>
        /// <param name="disposing">如果应释放托管资源，为 true；否则为 false。</param>
        protected override void Dispose(bool disposing)
        {
            if (disposing && (components != null))
            {
                components.Dispose();
            }
            base.Dispose(disposing);
        }

#region Windows 窗体设计器生成的代码

/// <summary>
        /// 设计器支持所需的方法 - 不要
        /// 使用代码编辑器修改此方法的内容。
        /// </summary>
        private void InitializeComponent()
        {
            this.panel1 = new System.Windows.Forms.Panel();
            this.buttonSend = new System.Windows.Forms.Button();
            this.textBox2 = new System.Windows.Forms.TextBox();
            this.label1 = new System.Windows.Forms.Label();
            this.comboBox1 = new System.Windows.Forms.ComboBox();
            this.textbox = new System.Windows.Forms.RichTextBox();
            this.panel1.SuspendLayout();
            this.SuspendLayout();
            // 
            // panel1
            // 
            this.panel1.Controls.Add(this.buttonSend);
            this.panel1.Controls.Add(this.textBox2);
            this.panel1.Controls.Add(this.label1);
            this.panel1.Controls.Add(this.comboBox1);
            this.panel1.Dock = System.Windows.Forms.DockStyle.Bottom;
            this.panel1.Location = new System.Drawing.Point(0, 382);
            this.panel1.Name = "panel1";
            this.panel1.Size = new System.Drawing.Size(557, 59);
            this.panel1.TabIndex = 0;
            // 
            // buttonSend
            // 
            this.buttonSend.Location = new System.Drawing.Point(470, 29);
            this.buttonSend.Name = "buttonSend";
            this.buttonSend.Size = new System.Drawing.Size(75, 23);
            this.buttonSend.TabIndex = 1;
            this.buttonSend.Text = "发送";
            this.buttonSend.UseVisualStyleBackColor = true;
            this.buttonSend.Click += new System.EventHandler(this.buttonSend_Click);
            // 
            // textBox2
            // 
            this.textBox2.Location = new System.Drawing.Point(3, 29);
            this.textBox2.Name = "textBox2";
            this.textBox2.Size = new System.Drawing.Size(443, 21);
            this.textBox2.TabIndex = 0;
            this.textBox2.KeyPress += new System.Windows.Forms.KeyPressEventHandler(this.textBox2_KeyPress);
            // 
            // label1
            // 
            this.label1.AutoSize = true;
            this.label1.Location = new System.Drawing.Point(3, 6);
            this.label1.Name = "label1";
            this.label1.Size = new System.Drawing.Size(53, 12);
            this.label1.TabIndex = 2;
            this.label1.Text = "发送给：";
            // 
            // comboBox1
            // 
            this.comboBox1.FormattingEnabled = true;
            this.comboBox1.Location = new System.Drawing.Point(62, 3);
            this.comboBox1.Name = "comboBox1";
            this.comboBox1.Size = new System.Drawing.Size(121, 20);
            this.comboBox1.TabIndex = 3;
            // 
            // textbox
            // 
            this.textbox.BackColor = System.Drawing.SystemColors.ActiveCaptionText;
            this.textbox.Dock = System.Windows.Forms.DockStyle.Fill;
            this.textbox.Location = new System.Drawing.Point(0, 0);
            this.textbox.Name = "textbox";
            this.textbox.ReadOnly = true;
            this.textbox.Size = new System.Drawing.Size(557, 382);
            this.textbox.TabIndex = 1;
            this.textbox.Text = "";
            this.textbox.TextChanged += new System.EventHandler(this.textbox_TextChanged);
            // 
            // Chat
            // 
            this.AutoScaleDimensions = new System.Drawing.SizeF(6F, 12F);
            this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font;
            this.ClientSize = new System.Drawing.Size(557, 441);
            this.Controls.Add(this.textbox);
            this.Controls.Add(this.panel1);
            this.Name = "Chat";
            this.Text = "Chat";
            this.FormClosed += new System.Windows.Forms.FormClosedEventHandler(this.Chat_FormClosed);
            this.Load += new System.EventHandler(this.Chat_Load);
            this.panel1.ResumeLayout(false);
            this.panel1.PerformLayout();
            this.ResumeLayout(false);

}

#endregion

private System.Windows.Forms.Panel panel1;
        private System.Windows.Forms.TextBox textBox2;
        private System.Windows.Forms.Label label1;
        private System.Windows.Forms.ComboBox comboBox1;
        private System.Windows.Forms.Button buttonSend;
        private System.Windows.Forms.RichTextBox textbox;
    }
}

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace TestClient
{
    public partial class Login : Form
    {
        //以下是客户端到服务器端的消息开头
        const string LOGININ = "10";//请求登陆的消息|||消息形式:10+自己的用户名
        const string LOGINOK = "23";//登陆成功
        //以下是服务器到客户端的消息开头
        const string HVUSER  = "20";//用户名已存在

Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);  //客户端套节字的定义
        IPEndPoint serverEP;//服务器的IPEP

delegate void myMethodDelegate(ref byte[] myInData);//登陆时用的事件

private ManualResetEvent receiveDone;//在登陆时用来阻塞线程,等待收到数据

bool inPutOk = false;
        public Login()
        {
            InitializeComponent();
        }

private void button1_Click(object sender, EventArgs e)
        {
            try
            {
                serverEP = new IPEndPoint(IPAddress.Parse(this.textBoxServerIP.Text), 11000);
                inPutOk = true;
            }
            catch
            {
                MessageBox.Show("你输入的服务器IP不正确,请重新输入.");
                inPutOk = false;
            }

//判断用户是否登陆成功
            bool ok = false;
            while (ok == false)
            {
                bool loginOk = LogOn(this.textBoxUserName.Text);
                if (loginOk)
                    ok = true;
                else
                {
                    DialogResult res = MessageBox.Show("是否重试?", "是否重试", MessageBoxButtons.YesNo);
                    if (res == DialogResult.No)
                        ok = true;
                    else
                        ok = false;
                }
            }
            Chat c = (Chat)this.Tag;
            c.UserName = this.textBoxUserName.Text;
            c.ServerEP = serverEP;
            c.ClientSocket = clientSocket;
            c.LoadInit();
            this.Close();          
        }

//登陆函数
        private bool LogOn(string username)
        {
            receiveDone = new ManualResetEvent(false);
            byte[] userBytes = null;
            bool userOk = false;
            //判断用户名是否符合格式
            while(userOk != true)
            {
            username = username.ToUpper();
            userBytes = Encoding.Unicode.GetBytes(LOGININ + username);

if(userBytes.Length > 24 || userBytes.Length < 10)
            {
                MessageBox.Show("用户名不得小于6个字节,且不得大于20个字节.");
                return false;
            }
            else
                userOk = true;
            }

//向服务器发送客户消息
            clientSocket.SendTo(userBytes, serverEP);
            byte[] data = new Byte[1024];
            string comStr = Encoding.Unicode.GetString(data,0,4);

//异面的接收服务器回送的消息
            myMethodDelegate DGrecv = new myMethodDelegate(RecvLogin);
            DGrecv.BeginInvoke(ref data, null, null);

//等待服务器回送消息的时长为10秒,否则为服务器超时
            receiveDone.WaitOne(30000, true);

string recvStr = Encoding.Unicode.GetString(data,0,4);
            if(recvStr == comStr)
            {
                MessageBox.Show("服务器超时.登陆失败!!");
                return false;
            }
            else
            {
                if(Encoding.Unicode.GetString(data,0,4) == LOGINOK)
                {
                    MessageBox.Show("登陆成功!!");
                }
                else
                {
                    if (Encoding.Unicode.GetString(data, 0, 4) == HVUSER)
                    {
                        MessageBox.Show("用户名重复.登陆失败!!");
                        return false;
                    }
                    else
                    {
                        if (Encoding.Unicode.GetString(data, 0, 4) == LOGINOK)
                        {
                            MessageBox.Show("服务器未知错误,登陆失败!!!!");
                            return false;
                        }                       
                    }
                }
            }
            return true;
        }

//登陆时用来异步的接收服务器发送的消息
        void RecvLogin(ref byte[] inData)
        {
            clientSocket.Receive(inData);
            receiveDone.Set();
        }
    }
}

namespace TestClient
{
    partial class Login
    {
        /// <summary>
        /// 必需的设计器变量。
        /// </summary>
        private System.ComponentModel.IContainer components = null;

/// <summary>
        /// 清理所有正在使用的资源。
        /// </summary>
        /// <param name="disposing">如果应释放托管资源，为 true；否则为 false。</param>
        protected override void Dispose(bool disposing)
        {
            if (disposing && (components != null))
            {
                components.Dispose();
            }
            base.Dispose(disposing);
        }

#region Windows 窗体设计器生成的代码

/// <summary>
        /// 设计器支持所需的方法 - 不要
        /// 使用代码编辑器修改此方法的内容。
        /// </summary>
        private void InitializeComponent()
        {
            this.label2 = new System.Windows.Forms.Label();
            this.textBoxServerIP = new System.Windows.Forms.TextBox();
            this.label1 = new System.Windows.Forms.Label();
            this.textBoxUserName = new System.Windows.Forms.TextBox();
            this.button1 = new System.Windows.Forms.Button();
            this.SuspendLayout();
            // 
            // label2
            // 
            this.label2.AutoSize = true;
            this.label2.Location = new System.Drawing.Point(56, 27);
            this.label2.Name = "label2";
            this.label2.Size = new System.Drawing.Size(77, 12);
            this.label2.TabIndex = 7;
            this.label2.Text = "服务器ＩＰ：";
            // 
            // textBoxServerIP
            // 
            this.textBoxServerIP.Location = new System.Drawing.Point(139, 24);
            this.textBoxServerIP.Name = "textBoxServerIP";
            this.textBoxServerIP.Size = new System.Drawing.Size(100, 21);
            this.textBoxServerIP.TabIndex = 6;
            this.textBoxServerIP.Text = "10.24.11.231";
            // 
            // label1
            // 
            this.label1.AutoSize = true;
            this.label1.Location = new System.Drawing.Point(56, 68);
            this.label1.Name = "label1";
            this.label1.Size = new System.Drawing.Size(53, 12);
            this.label1.TabIndex = 9;
            this.label1.Text = "用户名：";
            // 
            // textBoxUserName
            // 
            this.textBoxUserName.Location = new System.Drawing.Point(139, 65);
            this.textBoxUserName.Name = "textBoxUserName";
            this.textBoxUserName.Size = new System.Drawing.Size(100, 21);
            this.textBoxUserName.TabIndex = 8;
            // 
            // button1
            // 
            this.button1.Location = new System.Drawing.Point(100, 106);
            this.button1.Name = "button1";
            this.button1.Size = new System.Drawing.Size(75, 23);
            this.button1.TabIndex = 10;
            this.button1.Text = "登　陆";
            this.button1.UseVisualStyleBackColor = true;
            this.button1.Click += new System.EventHandler(this.button1_Click);
            // 
            // Login
            // 
            this.AutoScaleDimensions = new System.Drawing.SizeF(6F, 12F);
            this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font;
            this.ClientSize = new System.Drawing.Size(292, 144);
            this.Controls.Add(this.button1);
            this.Controls.Add(this.label1);
            this.Controls.Add(this.textBoxUserName);
            this.Controls.Add(this.label2);
            this.Controls.Add(this.textBoxServerIP);
            this.Name = "Login";
            this.Text = "Login";
            this.ResumeLayout(false);
            this.PerformLayout();

}

#endregion

private System.Windows.Forms.Label label2;
        private System.Windows.Forms.TextBox textBoxServerIP;
        private System.Windows.Forms.Label label1;
        private System.Windows.Forms.TextBox textBoxUserName;
        private System.Windows.Forms.Button button1;
    }
}

Server：
using System;
using System.Drawing;
using System.Collections;
using System.Collections.Generic;
using System.ComponentModel;
using System.Windows.Forms;
using System.Data;
using System.Net.Sockets;
using System.Threading;
using System.Net;
using System.Text;

namespace ChatServer
{
 /// <summary>
 /// Form1 的摘要说明。
 /// </summary>
 public partial class Form1 : System.Windows.Forms.Form
 {
  /// <summary>
  /// 必需的设计器变量。
  /// </summary>
  private System.ComponentModel.Container components = null;
  //全局变量
  Socket ServerSocket = null;
  IPEndPoint ipep = null;
  Hashtable htUserList = null;
  string[] userName = new string[1000];
  IPEndPoint[] userIPEP = new IPEndPoint[1000];
  int[] userTime = new int[1000];
  TimerCallback timerDelegate = null;
  WriteLog writeLog = null;
  Thread listenTH = null;
  bool flag = true;

//常量
  //以下是客户端到服务器端的消息开头
  const string LOGININ = "10"; //请求登陆的消息|||消息形式:10+自己的用户名
  const string LOGINOUT = "11"; //请求登出的消息|||消息形式:11+自己的用户名
  const string GETULIST = "12"; //请求获得在线用户列表|||消息形式:12
  const string P2PCONN = "13"; //请求P2P连接的消息|||消息形式:13+自己的用户名+|+对方的用户名
  const string HOLDLINE = "14"; //保持连接.|||消息开式:14+自己的用户名
        const string LOGINADD = "15";//新用户登录
        const string LOGINREMOVE = "16";//用户登出

//以下是服务器到客户端的消息开头
  const string HVUSER = "20"; //用户名已存在
  const string GETUSER = "21"; //在线用户列表|||消息格式:21+用户名+EP
  const string MAKHOLD = "22"; //打洞命令|||消息格式:22+IP
  const string LOGINOK = "23"; //登陆成功
  const string SERVCLS = "24"; //服务器关闭
  const string MSGEND = "25"; //消息结束

//以下是服务器端的命名
  const string EXITPRO = "EXIT"; //退出命令
  const string SHOWULIST = "SHOWUSER";
  private System.Windows.Forms.StatusBar statusBar1;
  private System.Windows.Forms.StatusBarPanel statusBarPanel1;
  private System.Windows.Forms.TextBox textBox1; //显示在线用户
  const string HELP = "HELP"; //显示帮助
        private List<IPEndPoint> onlineIPList;

public Form1()
  {
   //
   // Windows 窗体设计器支持所必需的
   //
   InitializeComponent();

//初始化变量
   ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); 
   ipep = new IPEndPoint(IPAddress.Any, 11000);
   htUserList = new Hashtable();
   writeLog = new WriteLog();
   timerDelegate = new TimerCallback(OnLineTimeOut);
  }

/// <summary>
  /// 清理所有正在使用的资源。
  /// </summary>
  protected override void Dispose( bool disposing )
  {
   if( disposing )
   {
    if (components != null) 
    {
     components.Dispose();
    }
   }
   base.Dispose( disposing );
  }

#region Windows 窗体设计器生成的代码
  /// <summary>
  /// 设计器支持所需的方法 - 不要使用代码编辑器修改
  /// 此方法的内容。
  /// </summary>
  private void InitializeComponent()
  {
   this.statusBar1 = new System.Windows.Forms.StatusBar();
   this.statusBarPanel1 = new System.Windows.Forms.StatusBarPanel();
   this.textBox1 = new System.Windows.Forms.TextBox();
   ((System.ComponentModel.ISupportInitialize)(this.statusBarPanel1)).BeginInit();
   this.SuspendLayout();
   // 
   // statusBar1
   // 
   this.statusBar1.Location = new System.Drawing.Point(0, 319);
   this.statusBar1.Name = "statusBar1";
   this.statusBar1.Panels.AddRange(new System.Windows.Forms.StatusBarPanel[] {
                        this.statusBarPanel1});
   this.statusBar1.ShowPanels = true;
   this.statusBar1.Size = new System.Drawing.Size(466, 22);
   this.statusBar1.TabIndex = 0;
   // 
   // statusBarPanel1
   // 
   this.statusBarPanel1.AutoSize = System.Windows.Forms.StatusBarPanelAutoSize.Spring;
   this.statusBarPanel1.Text = "statusBarPanel1";
   this.statusBarPanel1.Width = 450;
   // 
   // textBox1
   // 
   this.textBox1.Dock = System.Windows.Forms.DockStyle.Left;
   this.textBox1.Location = new System.Drawing.Point(0, 0);
   this.textBox1.Multiline = true;
   this.textBox1.Name = "textBox1";
   this.textBox1.ScrollBars = System.Windows.Forms.ScrollBars.Vertical;
   this.textBox1.Size = new System.Drawing.Size(286, 319);
   this.textBox1.TabIndex = 1;
   this.textBox1.Text = "";
   // 
   // Form1
   // 
   this.AutoScaleBaseSize = new System.Drawing.Size(6, 14);
   this.ClientSize = new System.Drawing.Size(466, 341);
   this.Controls.Add(this.textBox1);
   this.Controls.Add(this.statusBar1);
   this.FormBorderStyle = System.Windows.Forms.FormBorderStyle.FixedDialog;
   this.MaximizeBox = false;
   this.Name = "Form1";
   this.StartPosition = System.Windows.Forms.FormStartPosition.CenterScreen;
   this.Text = "服务程序";
   this.Load += new System.EventHandler(this.Form1_Load);
   this.Closed += new System.EventHandler(this.Form1_Closed);
   ((System.ComponentModel.ISupportInitialize)(this.statusBarPanel1)).EndInit();
   this.ResumeLayout(false);

}
  #endregion

/// <summary>
  /// 启动服务器
  /// </summary>
  /// <param name="sender"></param>
  /// <param name="e"></param>
  private void Form1_Load(object sender, System.EventArgs e)
  {
   IPAddress[] addressList = Dns.GetHostByName(Dns.GetHostName()).AddressList;
   IPAddress ServerIP = addressList[0];
   ServerSocket.Bind(ipep);
   SetStatusText("服务器正在启动......");
   SetStatusText("服务器IP:" + ServerIP.ToString() + "  正在监听" + ipep.Port.ToString() + "端口");
   listenTH = new Thread(new ThreadStart(Listen)); //监听线程
   listenTH.Start(); //启动
   SetStatusText("服务器启动成功.....");
   System.Windows.Forms.Timer timer = new System.Windows.Forms.Timer();
   timer.Tick += new EventHandler(timer_Tick);
   timer.Interval = 5000;
   timer.Start();
  }

/// <summary>
  /// 服务器监听函数
  /// </summary>
  private void Listen()
  {
   try
   {
    while (flag)
    {
     int recv = 0;
     byte[] data = new byte[1024];
     IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0);
     EndPoint tempRemoteEP = sender as EndPoint;
     recv = ServerSocket.ReceiveFrom(data, ref tempRemoteEP);
     string msgHead = Encoding.Unicode.GetString(data, 0, 4);
     switch (msgHead)
     {
      case LOGININ: //用户登录
       string LoginThing = UserLogin(data, (IPEndPoint)tempRemoteEP, recv);
       if (LoginThing == HVUSER) //用户存在
       {
        SendMsg(HVUSER, (IPEndPoint)tempRemoteEP);
       }
       else
       {
           SendMsg(LOGINOK, (IPEndPoint)tempRemoteEP);
                                if (onlineIPList == null)
                                {
                                    onlineIPList = new List<IPEndPoint>();
                                }
                                onlineIPList.Add((IPEndPoint)tempRemoteEP);
                                foreach (IPEndPoint ip in onlineIPList)
                                {
                                    SendMsg(LOGINADD, ip);
                                }
       }
       break;
      case LOGINOUT: //用户退出
       Userloginout(data, recv);
                            onlineIPList.Remove((IPEndPoint)tempRemoteEP);
                            foreach (IPEndPoint ip in onlineIPList)
                            {
                                SendMsg(LOGINREMOVE, ip);
                            }
       break;
      case GETULIST: // 获取用户列表
       string userInfor = GetUserList();
       SendMsg(GETUSER + userInfor, (IPEndPoint)tempRemoteEP);
       break;
      case P2PCONN: //打洞
       QuestP2PConn(data, recv);
       break;
      case HOLDLINE:
       HoldOnLine(data, recv);
       break;
     }
    }
   }
   catch (System.Exception errr)
   {
    writeLog.AppendErrorLog(errr.ToString());
   }
  }

/// <summary>
  /// 保持用户在线
  /// </summary>
  /// <param name="data"></param>
  /// <param name="recvCount"></param>
  private void HoldOnLine(byte[] data, int recvCount)
  {
   string Uname = Encoding.Unicode.GetString(data, 4, recvCount - 4);
   int i = 0;
   for (i=0;i<userName.Length;i++)
   {
    if (Uname == userName[i])
    {
     userTime[i] = 60;
     break;
    }
   }
  }

/// <summary>
  /// 用户超时退出
  /// </summary>
  private void OnLineTimeOut(object state)
  {
   int i = 0, j= 0;
   for (i=0;i<userName.Length;i++)
   {
    if (userTime[i] > 0)
    {
     userTime[i] -= 5;
     if (userTime[i] < 0)
     {
      string loginoutmsg = LOGINOUT + userName[i];
      userName[i] = "";
      userIPEP[i] = null;
      
      byte[] ULoginOutbytes = Encoding.Unicode.GetBytes(loginoutmsg);
      for (i=1;j<userName.Length;j++)
      {
       if (userName[j] != "")
       {
        if (userIPEP[j] != null)
        {
         ServerSocket.SendTo(ULoginOutbytes, userIPEP[j]);
        }
       }
      }
     }
    }
   }
  }

/// <summary>
  /// 转发P2P连接请求
  /// </summary>
  private void QuestP2PConn(byte[] data, int recv)
  {
   string recvStr = Encoding.Unicode.GetString(data, 4, recv - 4);
   string[] split = recvStr.Split(new char[]{‘|‘});
   IPEndPoint fromEP = null, toEP = null;
   int i;
   for (i=0;i<userName.Length;i++)
   {
    if (userName[i] == split[0])
    {
     fromEP = userIPEP[i];
    }
    if (userName[i] == split[1])
    {
     toEP = userIPEP[i];
    }
   }
   byte[] holdbyte = Encoding.Unicode.GetBytes(MAKHOLD + fromEP.ToString());
   ServerSocket.SendTo(holdbyte, toEP);
  }

/// <summary>
  /// 用户登录，直接返回登陆是否成功的值
  /// </summary>
  /// <param name="data"></param>
  /// <param name="userEP"></param>
  /// <param name="recvCount"></param>
  /// <returns></returns>
  private string UserLogin(byte[] data, IPEndPoint userEP, int recvCount)
  {
   string Uname = Encoding.Unicode.GetString(data, 4, recvCount - 4);
   byte[] Uinfobytes = null;
   int i, j;
   for (i=0;i<userName.Length;i++)
   {
    if (userName[i] != "" && userName[i] != null)
    {
     if (userName[i].Equals(Uname))
      return HVUSER;
    }
   }
   for (i=0;i<userName.Length;i++)
   {
    if (userName[i] == "" || userName[i] == null)
    {
     userName[i] = Uname;
     userIPEP[i] = userEP;
     userTime[i] = 60;
     Uinfobytes = Encoding.Unicode.GetBytes(LOGININ + userName[i] + "|" + userIPEP[i].ToString());
     for (j=1;j<userName.Length;j++)
     {
      if (userName[j] != "" && userName[j] != Uname && userName[j] != null && userIPEP[j] != null)
      {
       ServerSocket.SendTo(Uinfobytes, userIPEP[j]);
      }
     }
     break;
    }
   }
   return LOGINOK;
  }

/// <summary>
  /// 用户退出
  /// </summary>
  /// <param name="data"></param>
  /// <param name="recvCount"></param>
  private void Userloginout(byte[] data, int recvCount)
  {
   int i = 0, j = 0;
   string Uname = Encoding.Unicode.GetString(data, 4, recvCount - 4);
   for (i=0;i<userName.Length;i++)
   {
    if (Uname.ToUpper() == userName[i].ToUpper())
    {
     string loginOutMsg = LOGINOUT + Uname;
     userName[i] = "";
     userIPEP[i] = null;
     userTime[i] = 0;
     for (j=1;j<userName.Length;j++)
     {
      if (userName[j]!= null && userName[j] != "")
      {
       SendMsg(loginOutMsg, userIPEP[j]);
      }
     }
     break;
    }
   }
  }

/// <summary>
  /// 获取用户列表
  /// </summary>
  /// <returns></returns>
  private string GetUserList()
  {
   string userInfor = "";
   int i = 0;
   for (i=0;i<userName.Length;i++)
   {
    if (userName[i] != "" && userName[i] != null && userIPEP[i] != null)
    {
     userInfor += userName[i] + "|" + userIPEP[i].ToString() + "|";
    }
   }
   return userInfor;
  }

/// <summary>
  /// 发送消息
  /// </summary>
  /// <param name="msg"></param>
  /// <param name="remoteEP"></param>
  private void SendMsg(string msg, IPEndPoint remoteEP)
  {
   byte[] sendBytes = Encoding.Unicode.GetBytes(msg);
   try
   {
    ServerSocket.SendTo(sendBytes, remoteEP);
   }
   catch (System.Exception errr) {
    writeLog.AppendErrorLog(errr.ToString());
   }
  }

/// <summary>
  /// 提示信息
  /// </summary>
  /// <param name="text"></param>
  /// <returns></returns>
  private void SetStatusText(string text)
  {
   this.statusBarPanel1.Text = text;
  }

/// <summary>
  /// 显示在线用户 
  /// </summary>
  private StringBuilder ShowUser()
  {
   StringBuilder strB = new StringBuilder();
   if (userName != null && userName.Length > 0)
   {
    int i;
    for (i=0;i<userName.Length;i++)
    {
     if (userName[i] != "" && userIPEP[i] != null)
     {
      strB.Append(Environment.NewLine + "用户名:" + userName[i] + "  地址:" + userIPEP[i].ToString());
     }
    }
   }
   return strB;
  }

/// <summary>
  /// 退出
  /// </summary>
  /// <param name="sender"></param>
  /// <param name="e"></param>
  private void Form1_Closed(object sender, System.EventArgs e)
  {
   flag = false;
   if (listenTH != null)
   {
    if (listenTH.ThreadState == ThreadState.Running)
    {
     listenTH.Abort();
    }
    listenTH = null;
   }
   timerDelegate = null;
   ServerSocket.Close();
  }

private void timer_Tick(object sender, EventArgs e)
  {
   OnLineTimeOut(null);
   StringBuilder strB = ShowUser();
   this.textBox1.Text = strB.ToString();
  }

}
}

using System;
using System.Text;
using System.IO;
using System.Windows.Forms;

namespace ChatServer
{
 /// <summary>
 /// WriteLog 的摘要说明。
 /// </summary>
 public class WriteLog
 {
  public WriteLog()
  {
   //
   // TODO: 在此处添加构造函数逻辑
   //
  }
  /// <summary>
  /// 追加日志文件
  /// </summary>
  /// <param name="errorMsg"></param>
  public void AppendErrorLog(string errorMsg)
  {
   try
   {
    StringBuilder strB = new StringBuilder();
    strB.Append(DateTime.Now.ToString());
    strB.Append("   ");
    strB.Append(Environment.MachineName.ToString());
    strB.Append("   ");
    strB.Append(Environment.UserDomainName.ToString() + "\\" + Environment.UserName);
    strB.Append("   ");
    strB.Append(Environment.OSVersion.Platform.ToString() + "\\" + Environment.OSVersion.Version.ToString());
    strB.Append(Environment.NewLine + Environment.NewLine);
    strB.Append(errorMsg);
    strB.Append(Environment.NewLine + Environment.NewLine);
    AppendErrorLog(strB);
   }
   catch{}
  }

/// <summary>
  /// 追加日志文件
  /// </summary>
  /// <param name="strB"></param>
  public void AppendErrorLog(StringBuilder strB)
  {
   try
   {
    string filePath = "";
    filePath = CreateErrorLogFile();
    FileStream fileStream = File.Open(filePath, FileMode.Append, FileAccess.Write);
    StreamWriter streamWriter = new StreamWriter(fileStream);
    
    streamWriter.Write(strB.ToString());
    streamWriter.Flush();
    streamWriter.Close();
    fileStream.Close();
    fileStream = null;
   }
   catch{}
  }

/// <summary>
  /// 创建日志文件
  /// </summary>
  private string CreateErrorLogFile()
  {
   string directoryPath = Application.StartupPath + "\\ErrorLog";
   string filePath = string.Empty;
   //判断日志文件夹是否存在
   if (!Directory.Exists(directoryPath))
   {
    Directory.CreateDirectory(directoryPath);
   }
   //根据日期创建日志文件
   filePath = directoryPath + "\\Error" + string.Format("{0:D2}", DateTime.Today.Year) + string.Format("{0:D2}", DateTime.Today.Month) + string.Format("{0:D2}", DateTime.Today.Day) + ".log";
   if (!File.Exists(filePath))
   {
    FileStream fileStream = File.Create(filePath);
    fileStream.Close();
   }
   return filePath;
  }

}
}

地址：http://www.cnblogs.com/gjahead/archive/2007/04/04/699842.html

时间： 2024-10-07 17:35:03

Socket 打洞的相关文章

内网ip打洞-----p2p实现原理

网上找了很多,代码大堆,原理讲清楚透彻的不多. 本人找几篇讲得好的来整理一下. 一片技术文章,最主要的讲清楚原理,如果再有完整的能运行的源代码也可,关键是要把核心部分代码分析清楚. (1)问题的由来: 大部分的电脑上网都是用动态ip地址.内网的ip是由net(路由.网关)分配的,net发出去的时候,映射到一个公网地址,这是一个动态计算的过程(特别是端口号),因此称为动态ip地址.外部网是无法直接访问内网计算机的,但在大部分情况下,借助一台有公网ip地址电脑(这里叫服务器),通过某种方式,可以实现

QQ视频与webrtc打洞对比分析

工作后的第一篇博客,mark一下. 一.NAT 1. 含义 NAT技术(Network Address Translation,网络地址转换)是一种把内部网络(简称为内网)私有IP地址转换为外部网络(简称为外网)公共IP地址的技术,它使得一定范围内的多台主机只利用一个公共IP地址连接到外网,可以在很大程度上缓解了公网IP地址紧缺的问题. 2. 实现方式 静态转换.动态转换.端口多路复用. 静态转换:是指将内部网络的私有IP地址转换为公有IP地址,IP地址对是一对一的,是一成不变的.通过静态配置,

UDP打洞、P2P组网方式研究

catalogue 1. NAT概念 2. P2P概念 3. UDP打洞 4. P2P DEMO 5. ZeroNet P2P 1. NAT概念 在STUN协议中,根据内部终端的地址(LocalIP:LocalPort)到NAT出口的公网地址(PublicIP:PublicPort)的影射方式,把NAT分为四种类型(rfc3489: http://www.ietf.org/rfc/rfc3489.txt) 1. Full Cone: 这种NAT内部的机器A连接过外网机器C后,NAT会打开一个端口

NAT穿透（UDP打洞）

1.NAT(Network Address Translator)介绍 NAT有两大类,基本NAT和NAPT. 1.1.基本NAT 静态NAT:一个公网IP对应一个内部IP,一对一转换 动态NAT:N个公网IP对应M个内部IP,不固定的一对一转换关系  1.2.NAPT(Network Address/Port Translator) 现在基本使用这种,又分为对称和锥型NAT. 锥型NAT,有完全锥型.受限制锥型.端口受限制锥型三种: a)Full Cone NAT(完全圆锥型):从同一私网地址

P2P UPD打洞原理

转自:http://blog.pfan.cn/fengfei/18828.html 首先先介绍一些基本概念:            NAT(Network Address             Translators),网络地址转换:网络地址转换是在IP地址日益缺乏的情况下产生的,它的主要目的就是为了能够地址重用.NAT分为两大类,基本的NAT和NAPT(Network             Address/Port Translator).            最开始NAT是运行在路由器

TCP打洞与UDP打洞的差别

为什么网上讲到的P2P打洞基本上都是基于UDP协议的打洞?难道TCP不可能打洞?还是TCP打洞难于实现? 如果如今有内网clientA和内网clientB.有公网服务端S. 如果A和B想要进行UDP通信,则必须穿透两方的NAT路由.如果为NAT-A和NAT-B. A发送数据包到公网S,B发送数据包到公网S,则S分别得到了A和B的公网IP, S也和A B 分别建立了会话.由S发到NAT-A的数据包会被NAT-A直接转发给A, 由S发到NAT-B的数据包会被NAT-B直接转发给B,除了S发出的数据包

Udp打洞原理和源代码。

所谓udp打洞就是指客户端A通过udp协议向服务器发送数据包,服务器收到后,获取数据包,并且 可获取客户端A地址和端口号.同样在客户端B发送给服务器udp数据包后,服务器同样在收到B发送过来 的数据包后获取B的地址和端口号,将A和B的地址与端口号分别发送给对方,这样双方可以继续用UDP协议 通信.这么做有什么用呢?因为对于一些应用或者需求,需要两个客户端临时做一些通信,而这种通信 不需要建立tcp就可以完成,所以才去udp打洞. 下面附上测试代码: 头文件 // udphole.cpp : 定义

TCP、UDP及Socket(Port)的关系，深入浅出！

转自http://www.cnblogs.com/wish123/archive/2013/04/12/3017031.html 提醒:貌似这里说的socket是指port,而非socket api技术!仅供参考!貌似标题命名不准确的说<更安全的Linux网络>第1章防火墙的基本概念,在本书的开始将详尽讲解与防火墙相关的TCP/IP技术.此外,对于防火墙的原理.种类.架构及其优.缺点,在本章中也都有详尽的介绍.本节为大家介绍TCP.UDP及Socket的关系.1.4 TCP.UDP及Socke

NAT打洞

NAT(Network Address Translation)是一种广域网的接入技术,将私有地址转换为合法的公共IP地址,可以完美的解决IP地址不足问题,而且还能有效避免来自外部网络的攻击,隐藏并保护网络内部的计算机. NAT的功能通常被集成到路由器.防火墙.ISDN路由器或者单独的NAT设备中. 一.NAT有三种实现方式: 1. 静态转换:即1对1.好处是外部可以访问内部网络: 2. 动态转换:多内部IP对几个外部IP,动态适配.无法实现对网络内部主机的访问: 3. 端口多路复用:即PAT,