ASP.NET学习网|ASP.NET教程|ASP.NET MVC|ASP.NET 源码|VS2010教程|ASP.NET视频教程

  hander data#region hander data
 2                    try
 3                    {
 4                        Logger.Log("DataReceive", data);//test, catch the data transaction
 5
 6                        string[] allData = data.Split(';');
 7                        string requestTo = allData[0]; // this is the basic format: to_IP;from_IP;MSG
 8
 9                        //find stored socket connection here
10                        ClientConnection requectToCC = null;
11                        foreach (DictionaryEntry de in SocketListener.ClientConnections)
12                        {
13                            ClientConnection cc = de.Key as ClientConnection;
14                            // request form will be like this "xx.xx.xxx.xxx:xxxxxx",the last number is running number
15                            // so if 2 client both in the same network, this will be confued to dispatch the socket
16                            //here just find the last one that in the same network
17                            if (cc.RequestFrom.IndexOf(requestTo) > -1)
18                            {
19                                requectToCC = cc;
20                            }
21
22                        }
23                        if (requectToCC != null && requectToCC.ConSocket.Connected)
24                        {
25                            //can get the connection here, then transfer this request to it
26                            try
27                            {
28                                ReplayMsg(requectToCC.ConSocket, data);
29                            }
30                            catch (Exception ce)
31                            {
32                                ReplayMsg(this.ConSocket, "process error: " + ce.Message);
33                                Logger.Log("SendMsgError", ce.Message);
34                            }
35                        }
36                        else
37                        {
38                            //if can not find, means the reqeust to is not login/register there
39                            ReplayMsg(this.ConSocket, "the client you request to is disconnected");
40                            Logger.Log("SendMsgError", "the client you request to is disconnected");
41                        }
42                        //
43                    }
44                    catch (Exception ex)
45                    {
46                        Logger.Log("DataError " + _requestFrom, ex.Message);
47                    }
48                    #endregion
 

3：）客户端的简单实现:

1 namespace P2PClient
 2 {
 3     public class ConnectionManager
 4     {
 5         private Socket _socket;
 6         private IPEndPoint _hostEP;
 7         private string _localIP;
 8
 9         public delegate void MessageReceiveEvent(string fromIP,string msg);
10
11         public event MessageReceiveEvent OnMsgReceived;
12
13         public ConnectionManager(string ip, int port)
14         {
15             IPAddress address = IPAddress.Parse(ip);
16             _hostEP = new IPEndPoint(address, port);
17         }
18
19         public bool Connect2Server()
20         {
21             try
22             {
23                 _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
24                 _socket.Connect(_hostEP);
25
26                 IPHostEntry oIPHost = Dns.Resolve(Environment.MachineName);
27                 _localIP = oIPHost.AddressList[0].ToString();
28
29                 //there use the same socket, to wait for reply msg
30                 Thread thread = new Thread(new ThreadStart(WaitForReceiveData));
31                 thread.Name = "connection_";
32                 thread.Start();
33
34                 return true;
35             }
36             catch (Exception ex)
37             {
38                 return false;
39             }
40         }
41         public void Close()
42         {
43             _socket.Shutdown(SocketShutdown.Both);
44             _socket.Close();
45         }
46         public void SendMessage(string clientIP, string msg)
47         {
48             string sendStr = clientIP + ";"+_localIP+";" + msg;//simple format; to_IP;from_IP;MSG
49
50             byte[] bytesSendStr = new byte[1024];
51             bytesSendStr = Encoding.ASCII.GetBytes(sendStr);
52             _socket.Send(bytesSendStr, bytesSendStr.Length, 0);
53         }
54
55         public void WaitForReceiveData()
56         {
57             byte[] bytes = new Byte[1024];
58
59             while (true)
60             {
61                 bytes = new byte[1024];
62                 string data = "";
63
64                 //the system while be wait here until there is msg received here
65                 int bytesRec = this._socket.Receive(bytes);
66
67                 data += Encoding.ASCII.GetString(bytes, 0, bytesRec);
68                 #region hander data
69                 Logger.Log("DataReceive", data);
70
71                 string[] allData = data.Split(';');
72                 string requestFrom = allData[1]; // this is the basic format; to_IP;from_IP;MSG
73                 string msg=allData[2];
74
75                 if (OnMsgReceived != null)
76                 {
77                     OnMsgReceived(requestFrom, msg);
78                 }
79                 #endregion
80             }
81         }
82   }
4：）UI等其他处理 （略）