socket异步处理问题

你的名字 2022-09-20 08:37 142阅读 0赞

由于一个项目要和第三方软件做接口，第三方软件是Unix的操作系统，所以用了Socket来传输数据。  
具体结构是这样的：本项目作为服务器端，第三方软件是客户端，并且有多个客户端。  
  
通常情况下，要开多个线程来处理多个客户端，并且一个客户端要占用一个端口，每个客户端在访问服务端时，服务器端要找到当前空闲的端口返回给客户端进行调用。  
msdn上提供了这种的解决方案：  
[http://www.microsoft.com/china/msdn/archives/library/dncscol/html/csharp09182003.asp][http_www.microsoft.com_china_msdn_archives_library_dncscol_html_csharp09182003.asp]  
  
但是，经过我今天的摸索，发现用socket异步处理也能解决这个问题，只要一个端口就可以给n个客户端访问了。  
并且客户不需要做异步处理，只是服务端做异步处理就可以了。这样的话，第三方软件改动量就很小，主要控制权在我这里。  
**客户端**做法的代码片断：  
创建连接：

![None.gif][] mobj\_stSend  =   new  Socket ( AddressFamily.InterNetwork ,   
![None.gif][]                    SocketType.Stream , ProtocolType.Tcp ) ;  // 初始化一个Socket实例    
![None.gif][]                   
![None.gif][]                IPEndPoint tempRemoteIP  =   new  IPEndPoint   
![None.gif][]                    ( IPAddress.Parse ( textBox1.Text ) , mi\_port ) ;  // 根据IP地址和端口号创建远程终结点    
![None.gif][]                   
![None.gif][]                EndPoint epTemp  =  ( EndPoint ) tempRemoteIP ;   
![None.gif][]                mobj\_stSend.Connect ( epTemp ) ;  // 连接远程主机的8000端口号

发送数据：

![None.gif][]   int  iLength  =  textBox2.Text.Length ;  // 获取要发送的数据的长度    
![None.gif][]               
![None.gif][]                Byte \[ \] bySend  =   new   byte  \[ iLength \] ;  // 根据获取的长度定义一个Byte类型数组    
![None.gif][]               
![None.gif][]                bySend  =  System.Text.Encoding.Default.GetBytes   
![None.gif][]                    ( textBox2.Text ) ;  // 按照指定编码类型把字符串指定到指定的Byte数组    
![None.gif][]               
![None.gif][]                 int  i  =  mobj\_stSend.Send ( bySend ) ;  // 发送数据

**服务器**端做了一个Socket数组来存放所有客户端的连接：

![None.gif][] private  Socket ListenSoc ;   
![None.gif][]         public   static  ManualResetEvent allDone  =   new  ManualResetEvent( false );  
![None.gif][]         private  Socket \[\] SocClient;  
![None.gif][]         private   const   int  MAX\_SOCKET =   100 ;  
![None.gif][]        Thread mobj\_thTreadRead;

启动监听线程：

![None.gif][] mobj\_thTreadRead  =   new  Thread (  new  ThreadStart ( Listen ) ) ; // 以Listen过程来初始化Thread实例               
![None.gif][]             mobj\_thTreadRead.Start() ; // 启动线程               
![None.gif][]             button1.Enabled  =   false   ;

在Listen方法中使用异步访问：

![None.gif][] void  Listen()  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][]         ![dot.gif][] \{  
![InBlock.gif][]            int nPort = 8000;              
![InBlock.gif][]            IPEndPoint ipLocalEndPoint;  
![InBlock.gif][]            try  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ![dot.gif][]\{  
![InBlock.gif][]//                IPAddress ipAddress = Dns.Resolve("localhost").AddressList\[0\];  
![InBlock.gif][]                ipLocalEndPoint = new IPEndPoint(GetServerIP(), nPort);   
![ExpandedSubBlockEnd.gif][]            \}  
![InBlock.gif][]            catch(SocketException socErr )  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ![dot.gif][]\{  
![InBlock.gif][]                MessageBox.Show(socErr.Message);  
![InBlock.gif][]                return;  
![ExpandedSubBlockEnd.gif][]            \}  
![InBlock.gif][]             
![InBlock.gif][]            try  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ![dot.gif][]\{                  
![InBlock.gif][]                ListenSoc = new Socket(AddressFamily.InterNetwork, SocketType.Stream,ProtocolType.Tcp );  
![InBlock.gif][]                ListenSoc.Bind(ipLocalEndPoint);  
![InBlock.gif][]                ListenSoc.Listen(100);  
![InBlock.gif][]                while (true)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                ![dot.gif][]\{  
![InBlock.gif][]                    allDone.Reset();  
![InBlock.gif][]                    ListenSoc.Soc.BeginAccept(new AsyncCallback(AcceptCallback),ListenSoc); //异步访问，并定义回调方法  
![InBlock.gif][]                    allDone.WaitOne();  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][]                \}  
![ExpandedSubBlockEnd.gif][]            \}  
![InBlock.gif][]            catch(Exception err)   
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ![dot.gif][]\{  
![InBlock.gif][]                MessageBox.Show(err.Message);  
![ExpandedSubBlockEnd.gif][]            \}  
![ExpandedBlockEnd.gif][]        \}

实现回调方法：

![None.gif][] public   void  AcceptCallback(IAsyncResult ar)   
![ExpandedBlockStart.gif][]![ContractedBlock.gif][]         ![dot.gif][] \{  
![InBlock.gif][]            try  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ![dot.gif][]\{  
![InBlock.gif][]                allDone.Set();  
![InBlock.gif][]                WSocket listener = (WSocket) ar.AsyncState;  
![InBlock.gif][]                int nSoc = GetAvailbleSocket(); //获取有效的Socket，即一个新的Socket实例  
![InBlock.gif][]SocClient\[nSoc\] = (Socket)ListenSoc.EndAccept(ar);  
![InBlock.gif][]//在这里处理接收过来得数据  
![ExpandedSubBlockEnd.gif][]\}  
![ExpandedBlockEnd.gif][]\}

![None.gif][] private   int  GetAvailbleSocket()  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][]         ![dot.gif][] \{  
![InBlock.gif][]            int i=-1;  
![InBlock.gif][]            for( i=0;i<MAX\_SOCKET;i\++)  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]            ![dot.gif][]\{  
![InBlock.gif][]                try  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                ![dot.gif][]\{  
![InBlock.gif][]                    if (SocClient\[i\]==null)  
![InBlock.gif][]                        break;  
![InBlock.gif][]                    else  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                    ![dot.gif][]\{  
![InBlock.gif][]                        if (!SocClient\[i\].Soc.Connected)  
![InBlock.gif][]                            break;  
![ExpandedSubBlockEnd.gif][]                    \}  
![ExpandedSubBlockEnd.gif][]                \}  
![InBlock.gif][]                catch (Exception err)   
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]                ![dot.gif][]\{  
![InBlock.gif][]                    MessageBox.Show("GetSock :"\+err.Message);  
![ExpandedSubBlockEnd.gif][]                \}  
![InBlock.gif][]  
![ExpandedSubBlockEnd.gif][]            \}  
![InBlock.gif][]  
![InBlock.gif][]            if ((i>-1)&& (i <MAX\_SOCKET))    
![InBlock.gif][]                InitSocket(ref SocClient\[i\],i);  
![InBlock.gif][]            return i;  
![ExpandedBlockEnd.gif][]        \}

[http_www.microsoft.com_china_msdn_archives_library_dncscol_html_csharp09182003.asp]: http://www.microsoft.com/china/msdn/archives/library/dncscol/html/csharp09182003.asp
[None.gif]: /images/20220828/80ab3c5653a546079ea011b08b79354b.png
[ExpandedBlockStart.gif]: http://cnblogs.com/Images/OutliningIndicators/ExpandedBlockStart.gif
[ContractedBlock.gif]: http://cnblogs.com/Images/OutliningIndicators/ContractedBlock.gif
[dot.gif]: /images/20220828/8c7784b4ed8f4180af002bc9b1722095.png
[InBlock.gif]: /images/20220828/a99f2464a30846eb99eb85ca8c3f17b8.png
[ExpandedSubBlockStart.gif]: http://cnblogs.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif
[ContractedSubBlock.gif]: http://cnblogs.com/Images/OutliningIndicators/ContractedSubBlock.gif
[ExpandedSubBlockEnd.gif]: /images/20220828/ce7ffe8548624859958ea1af8400b7f2.png
[ExpandedBlockEnd.gif]: /images/20220828/0ec2ab4865354fb09ef09eeb71c48740.png