多个客户端连接 为什么只有最后一个连接的才可以与服务器通信 求助在线等谢谢

bsknight

多个客户端连接 只有最后一个连接的才可以与服务器通信

服务器代码：

1. 
   
2. 
   
3. 服务器类成员变量：CArray<CRRUItem, CRRUItem> m_RRUArray;   用于存储各个RRU连接
   
4. // RRU元素
   
5. class CRRUItem {
   
6. public:
   
7.         unsigned char m_Id[11];                                                //        RRU标识
   
8.         SOCKET m_socket;
   
9.         CWinThread *pWinThread;                                       
   
10.         //HANDLE hThread;
    
11.         CBBUDlg *m_pDlgBBU;// 指向BBU窗口的指针
    
12.        
    
13.         CRRUItem()
    
14.         {
    
15.                 memset(m_Id, 0, sizeof(m_Id));
    
16.                 m_pDlgBBU = NULL;
    
17.                 m_socket = INVALID_SOCKET;
    
18.                 pWinThread = NULL;
    
19.         }
    
20. };
    
21. int CBBUDlg::InitServer( LPVOID lpParam, unsigned short wPort, int nClientNum )
    
22. {
    
23.     CBBUDlg *BBUDlg = (CBBUDlg *)lpParam;
    
24.     ASSERT(BBUDlg != NULL);
    
25. 
    
26.     BBUDlg->m_socket=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
    
27.     if(NULL == BBUDlg->m_socket)
    
28.     {
    
29.         BBUDlg->PrintToEdit("socket初始化失败.\r\n", BBUDlg, IDC_EDIT_CONTENT);
    
30.         return 0;
    
31.     }
    
32.     SOCKADDR_IN addrSrv;
    
33.     addrSrv.sin_addr.S_un.S_addr=htonl(INADDR_ANY);
    
34.     addrSrv.sin_family=AF_INET;
    
35.     addrSrv.sin_port=htons(wPort);
    
36. 
    
37.     if(bind(BBUDlg->m_socket,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR)) == SOCKET_ERROR )
    
38.     {
    
39.         BBUDlg->PrintToEdit("绑定端口失败.\r\n", BBUDlg, IDC_EDIT_CONTENT);
    
40.         return 0;
    
41.     }
    
42. 
    
43.     if(listen(BBUDlg->m_socket,nClientNum) == SOCKET_ERROR )
    
44.     {
    
45.         BBUDlg->PrintToEdit("监听失败.\r\n", BBUDlg, IDC_EDIT_CONTENT);
    
46.         return 0;
    
47.     }
    
48. 
    
49.     int len=sizeof(SOCKADDR);
    
50.     while(1)
    
51.     {
    
52.         if ( Select(READ, nTimeOut, BBUDlg->m_socket) )
    
53.         {
    
54.             sockaddr_in clientAddr;
    
55.             int iLen = sizeof(sockaddr_in);
    
56.             SOCKET accSock = accept(BBUDlg->m_socket, (struct sockaddr *)&clientAddr , &iLen);
    
57.             if (accSock == INVALID_SOCKET)
    
58.             {
    
59.                 continue;
    
60.             }
    
61.             // 将每个RRU的信息以CRRUItem的形式保存至m_RRUArray
    
62.             //    为每个连接的RRU开设一个线程
    
63.             CRRUItem tItem;
    
64.             tItem.m_socket = accSock;
    
65.             tItem.m_pDlgBBU = BBUDlg;
    
66. 
    
67.             INT_PTR idx = BBUDlg->m_RRUArray.Add(tItem);
    
68. 
    
69. 
    
70.             tItem.pWinThread = AfxBeginThread(BBUDlg->RRUThreadProc, &tItem );
    
71.             
    
72.             BBUDlg->m_RRUArray.GetAt(idx).pWinThread = tItem.pWinThread;
    
73. 
    
74.             ResumeThread(tItem.pWinThread);
    
75. 
    
76.             char cBuff[] = "BBU:Hello!\r\n";
    
77.             Send(cBuff, sizeof(cBuff), accSock);
    
78. 
    
79.             Sleep(100);
    
80.         }
    
81.     }
    
82.     closesocket(BBUDlg->m_socket);
    
83.     return 1;
    
84. }
    
85. UINT CBBUDlg::RRUThreadProc( LPVOID pParam )
    
86. {
    
87.     CRRUItem *RRU = (CRRUItem *)pParam;
    
88.     BR_PACKAGE pkg;
    
89.     ASSERT(RRU != NULL);
    
90. 
    
91.     CRRUItem tItem;
    
92.     for(int index = 0; index<RRU->m_pDlgBBU->m_RRUArray.GetSize(); index++)
    
93.     {
    
94.         tItem = RRU->m_pDlgBBU->m_RRUArray.GetAt(index);
    
95.     }
    
96.     while (1)
    
97.     {
    
98.         ASSERT(RRU->m_socket != INVALID_SOCKET);
    
99. 
    
100.         if(Select(READ, nTimeOut, RRU->m_socket))
     
101.         {
     
102.             //    先接收头部
     
103.             if(0 == Recv((char *)&pkg.head, sizeof(pkg.head), RRU->m_socket) )
     
104.             {
     
105.                 EnterCriticalSection(&RRU->m_pDlgBBU->m_csec_editContent);
     
106.                 RRU->m_pDlgBBU->PrintToEdit("接收数据失败！\r\n", RRU->m_pDlgBBU, IDC_EDIT_CONTENT);
     
107.                 LeaveCriticalSection(&RRU->m_pDlgBBU->m_csec_editContent);
     
108.             }
     
109.             //    再根据头部接收数据部
     
110.             switch(ntohl(pkg.head.Command_Id))
     
111.             {
     
112.             case nBR_BROADCAST:
     
113.                 {
     
114.                     EnterCriticalSection(&RRU->m_pDlgBBU->m_csec_editContent);
     
115.                     RRU->m_pDlgBBU->PrintHEAD(_T("RRU->BBU"), _T("BR_BROADCAST"), RRU->m_pDlgBBU, pkg);
     
116.                     LeaveCriticalSection(&RRU->m_pDlgBBU->m_csec_editContent);
     
117. 
     
118.                     memcpy(RRU->m_Id, (char *)pkg.head.Id, sizeof(RRU->m_Id));
     
119.                     RRU->m_Id[10] = '\0';
     
120. 
     
121.                     //    再接收数据部分
     
122.                     BR_BROADCAST *broadCast = (BR_BROADCAST *)pkg.data;
     
123.                     if( false == Recv( (char *)broadCast, sizeof(BR_BROADCAST),  RRU->m_socket) )
     
124.                         return 0;   
     
125. 
     
126.                     EnterCriticalSection(&RRU->m_pDlgBBU->m_csec_editContent);
     
127.                     RRU->m_pDlgBBU->PrintBR_BROADCAST(RRU->m_pDlgBBU, (BR_BROADCAST *)pkg.data);
     
128.                     LeaveCriticalSection(&RRU->m_pDlgBBU->m_csec_editContent);
     
129. 
     
130.                 }
     
131.                 break;
     
132.             }
     
133.             EnterCriticalSection(&RRU->m_pDlgBBU->m_csec_editContent);
     
134.             RRU->m_pDlgBBU->KeepScrollDown(RRU->m_pDlgBBU, IDC_EDIT_CONTENT);
     
135.             LeaveCriticalSection(&RRU->m_pDlgBBU->m_csec_editContent);
     
136.         }
     
137.     }
     
138.     return 0;
     
139. }
     

复制代码