1 using System;  2 using System.Collections.Generic;  3 using System.Linq;  4 using System.Text;  5 using System.Net.Sockets;  6 using System.Threading;  7 using System.Net;  8   9 namespace socket 10 { 11     class Server 12     { 13         // 通知一个或多个正在等待的线程已发生事件。 14         ManualResetEvent manager = new ManualResetEvent(false); 15         ManualResetEvent reviceManager = new ManualResetEvent(false); 16  17         // 负责监听的套接字 18         private Socket socketServer; 19  20         /// <summary> 21         /// 启动服务 22         /// </summary> 23         public void CreateSocketService() 24         { 25             try 26             { 27                 // 获取IP 28                 var address =  IPAddress.Parse("127.0.0.1"); 29                 // 创建一个包含ip port 的网络节点对象 30                 Int32 Port = 12306; 31                 var ipPoint = new IPEndPoint(address, Port); 32                 // 创建一个套接字socket,参数(IP4寻址协议,流式连接,使用TCP协议传输数据) 33                 socketServer = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 34                 // 将负责监听的套接字绑定到唯一的IP和端口上 35                 socketServer.Bind(ipPoint); 36                 // 设置监听队列的长度，同时100个队列 37                 socketServer.Listen(100); 38                 // 线程开始监听客户端的请求 39                 Thread threadService = new Thread(StartSocketService); 40                 // 设置线程为后台线程 41                 threadService.IsBackground = true; 42                 // 启动线程 43                 threadService.Start(); 44                 // 显示消息 45                 ShowMsg("服务器监听开启成功!"); 46             } 47             catch (Exception e) 48             { 49                 ShowMsg(e.Message); 50             } 51         } 52  53         /// <summary> 54         /// 启动服务监听 55         /// </summary> 56         //private void StartSocketService() 57         public void StartSocketService() 58         { 59             while (true) 60             { 61                 try 62                 { 63                     // 将事件状态设置为非终止状态，导致线程阻止 64                     manager.Reset(); 65                     // 开始监听客户端的连接请求 66                     var args = new SocketAsyncEventArgs(); 67                     args.Completed += args_Completed; 68                     socketServer.AcceptAsync(args); 69                     // 阻止当前线程，直到当前 WaitHandle 收到信号。 70                     manager.WaitOne(); 71                 } 72                 catch (Exception ex) 73                 { 74                     ShowMsg(ex.Message); 75                     break; 76                 } 77             } 78         } 79  80         public void args_Completed(object sender, SocketAsyncEventArgs e) 81         { 82             // 监听完成客户端的请求,一但监听到返回新的套接字 83             var clientSocket = e.AcceptSocket; 84             // 启动线程获取客户端发来的消息 85             if (clientSocket == null) return; 86             // 这部分为接收消息 87             var t = new Thread(GetClientMsg); 88             // 设置线程为后台线程 89             t.IsBackground = true; 90             // 启动线程 91             t.Start(clientSocket); 92             // 显示信息 93             ShowMsg(clientSocket.RemoteEndPoint + "上线了"); 94             // 将事件状态设置为终止状态，允许一个或多个等待线程继续 95             manager.Set(); 96         }               97  98         void ShowMsg(string message) 99         {100             // 显示消息101              //txtConneMsg.AppendText("\r\n" + DateTime.Now + "\r\n\r\n" + message + "\r\n");102              Console.WriteLine("\r\n" + DateTime.Now + "\r\n\r\n" + message + "\r\n");103         }104 105         private void GetClientMsg(object socket)106         {107             var socketClient = socket as Socket;108             if (socketClient == null) return;109             while (true)110             {111                 try112                 {113                     reviceManager.Reset();114                     var bytes = new byte[1024 * 1024 * 4];115                     var receiveArgs = new SocketAsyncEventArgs();116                     //设置缓冲区117                     receiveArgs.SetBuffer(bytes, 0, bytes.Length);118                     receiveArgs.Completed += receiveArgs_Completed;119                     //开始异步接收120                     socketClient.ReceiveAsync(receiveArgs);121                     reviceManager.WaitOne();122                 }123                 catch (Exception ex)124                 {125                     //显示异常消息126                     ShowMsg(ex.Message);127                 }128             }129         }130 131         void receiveArgs_Completed(object sender, SocketAsyncEventArgs e)132         {133             var socketClient = sender as Socket;134             var bytes = e.Buffer;135             ShowMsg(socketClient.RemoteEndPoint + "说:" + System.Text.Encoding.UTF8.GetString(bytes));136             reviceManager.Set();137         }138 139     }140 }

 1 using System; 2 using System.Collections.Generic; 3 using System.Linq; 4 using System.Text; 5 using System.Net.Sockets; 6 using System.Threading; 7 using System.Net; 8  9 namespace socket10 {11     class Client12     {13         private Socket socketClient;  // 客户端套接字14         private Thread threadClient;  // 客户端线程15 16         /// <summary>17         /// 创建套接字连接到服务端18         /// </summary>19         //private void CreateSocketConnection()20         public void CreateSocketConnection()21         {22             try23             {24                 // 创建一个客户端的套接字 参数(IP4寻址协议,流连接方式,TCP数据传输协议)25                 socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);26                 // 获取IP27                 IPAddress address = IPAddress.Parse("127.0.0.1");28                 //创建一个包含IP和端口号的网络节点对象29                 Int32 Port = 12306;30                 IPEndPoint ipPoint = new IPEndPoint(address, Port);31                 // 连接服务端32                 socketClient.Connect(ipPoint);33                 // 创建一个线程,接受服务端发来的数据34                 threadClient = new Thread(ReceiveService);35                 // 设置线程为后台线程36                 threadClient.IsBackground = true;37                 // 启动线程连接服务端38                 threadClient.Start();39                 // 显示消息40                 ShowMsg("与服务器" + address.ToString() + ":" + Port.ToString() + "成功建立连接！");41 42             }43             catch (Exception)44             {45                 ShowMsg( "服务器未启动！");46             }47         }48 49         //private void ReceiveService()50         public void ReceiveService()51         {52             while (true)53             {54                 try55                 {56                     var b = new byte[1024 * 1024 * 4];57                     int length = socketClient.Receive(b);58                     var msg = System.Text.Encoding.UTF8.GetString(b, 0, length);59                     ShowMsg(socketClient.RemoteEndPoint.ToString() + "对您: " + msg);60                 }61                 catch (Exception ex)62                 {63                     ShowMsg(ex.Message);64                     break;65                 }66             }67         }68 69         public void ShowMsg(string msg)70         {71             //txtConneMsg.AppendText("\r\n" + DateTime.Now + "\r\n\r\n" + msg + "\r\n");72             Console.WriteLine("\r\n" + DateTime.Now + "\r\n\r\n" + msg + "\r\n");73         }74 75         /// <summary>76         /// 发送数据到服务端77         /// </summary>78         public void Send()79         {80             if (socketClient == null)81             {82 83                 ShowMsg("服务器未启动！");84                 return;85             }86             //byte[] b = System.Text.Encoding.UTF8.GetBytes(txtSend.Text.Trim());87             string txtSend = "Hello";88             byte[] b = System.Text.Encoding.UTF8.GetBytes(txtSend);89             // 客户端向服务器发送消息90             socketClient.Send(b);91             //清空文本92             ShowMsg("您对" + socketClient.RemoteEndPoint.ToString() + "说：" + txtSend);93             txtSend = "";94         }95         96     }97 }