多线程使用不同原始socket发送ICMP的问题

多线程使用不同原始 socket发送ICMP的问题ICMP报文没有端口，在进程中或者多线程中同时新建多个原始套接字，然后发送ICMP包，然后等待返回结果，此时这些原始socket并不能分清哪个ICMP响应包是属于自己的（因为没有端口，到达的socket的目的IP都是一样的）。解决方法可以从ICMP里面的sequencenumber下手，~一个ping和一个pingreply的seqno是一样的，而且唯一下面发出自己的程序，麻烦高手看看，问题如何解决？自己写的CIcmpsocket类简介：1）通过构造函数得到目的 IP，和接收icmp的超时时间，和持续发送的时长；2）通过调用成员函数 start来开始发包 icmp探测的线程，也就是说一个类有自己的一个线程；3）创建3个CIcmpsocket类的对象，赋予不同的目的 IP，然后调用它们的 start函数，使其开始进行各自的 icmp探测；结果出现3个线程互相收到不是自己的 icmp回复报文。麻烦高手解答 ULONGWINAPIIcmpSocketThreadProc(LPVOIDlpParameter){CIcmpSocket*pThread;pThread=(CIcmpSocket*)lpParameter;pThread->Execute();ExitThread(0);return1;}CIcmpSocket::CIcmpSocket(DWORDulDstIP,DWORDulDataSize,DWORDulRcvTimeO,DWORDulTestTime){m_Socket=INVALID_SOCKET;intiTimeout=2000;/*2S 超时*/DWORDulLoop=0;structsockaddrstAddr={0};m_ThreadHandle=NULL;m_tTestTime=ulTestTime;m_ulTimeOut=ulRcvTimeO;m_ulThreadId=0;InitializeCriticalSection(&m_Section);memset(&m_IPHdr,0,sizeof(IpHeader));memset(&m_IcmpHeader,0,sizeof(IcmpHeader));memset(&m_Dest,0,sizeof(m_Dest));if(INADDR_NONE==ulDstIP){assert(0);}m_Dest.sin_family=AF_INET;m_ulDatasize=ulDataSize;m_ulDatasize+=sizeof(IcmpHeader);m_pSndData=(char*)malloc(m_ulDatasize);if(NULL==m_pSndData){assert(0);}m_pRcvData=(char*)malloc(MAX_DATASIZE);if(NULL==m_pRcvData){assert(0);}//fill_icmp_data(m_pSndData,m_ulDatasize);m_bTerminate=false;}CIcmpSocket::~CIcmpSocket(){if(m_Socket!=INVALID_SOCKET){closesocket(m_Socket);m_Socket=INVALID_SOCKET;}Lock();DWORDulDelayCnt=m_DelayMsArray.GetSize();DelayMsInfo*pstDelay=NULL;for(DWORDulLoop=0;ulLoop<ulDelayCnt;ulLoop++){pstDelay=(DelayMsInfo*)m_DelayMsArray[ulLoop];if(NULL!=pstDelay){free((void*)pstDelay);}}m_DelayMsArray.RemoveAll();UnLock(); if(m_pSndData){free(m_pSndData);}if(m_pRcvData){free(m_pRcvData);}}voidCIcmpSocket::Execute(){intiTimeout=0; m_ulThreadId=GetCurrentThreadId();if(WSAStartup(MAKEWORD(2,2),&m_wsaData)!=0){assert(0);}m_Socket=WSASocket(AF_INET,SOCK_RAW,IPPROTO_ICMP,NULL,0,WSA_FLAG_OVERLAPPED);if(INVALID_SOCKET==m_Socket){assert(0);}iTimeout=(int)m_ulTimeOut;if(SOCKET_ERROR==setsockopt(m_Socket,SOL_SOCKET,SO_RCVTIMEO,(char*)&iTimeout,sizeof(iTimeout))){assert(0);}iTimeout=1000;if(SOCKET_ERROR==setsockopt(m_Socket,SOL_SOCKET,SO_SNDTIMEO,(char*)&iTimeout,sizeof(iTimeout))){assert(0);}while(!m_bTerminate){Run(); Sleep(10);}ExitThread(0);return;}voidCIcmpSocket::fill_icmp_data(char*icmp_data,intdatasize){IcmpHeader*icmp_hdr=NULL;char*datapart=NULL;icmp_hdr=(IcmpHeader*)icmp_data;icmp_hdr->i_type=ICMP_ECHO;// 类型为ICMP_ECHOicmp_hdr->i_code=0;icmp_hdr->i_id=(USHORT)m_ulThreadId;// 识别号为进程号icmp_hdr->i_cksum=0;// 校验和初始化icmp_hdr->i_seq=0;//序列号初始化datapart=icmp_data+sizeof(IcmpHeader);//数据端的地址为icmp报文地址加上 ICMP的首部长度memset(datapart,'A',datasize-sizeof(IcmpHeader));//这里我填充的数据全部为"A"，你可以填充任何代码和数据，实际上木马和控制端之间就是通过数据段传递数据的。return;}//CheckSum函数是标准的校验和函数USHORTCIcmpSocket::CheckSum(USHORT*buffer,intsize){unsignedlongcksum=0;{

while(size>1)cksum+=*buffer++;size-=sizeof(USHORT);}if(size){cksum+=*(UCHAR*)buffer;}cksum=(cksum>>16)+(cksum&0xffff);cksum+=(cksum>>16);return(USHORT)(~cksum);}voidCIcmpSocket::Lock(void){EnterCriticalSection(&m_Section);return;}voidCIcmpSocket::UnLock(void){LeaveCriticalSection(&m_Section);return;}voidCIcmpSocket::Start(){if(NULL==m_ThreadHandle){m_ThreadHandle=CreateThread(NULL,1000000,IcmpSocketThreadProc,(LPVOID)this,0,NULL);}return;}voidCIcmpSocket::Stop(){m_bTerminate=false;}boolCIcmpSocket::Run(){time_ttStart=time(NULL);time_ttNow=tStart;unsignedshortusSeq=0;DWORDulByteSndCnt=0;DWORDulByteRcvCnt=0;structsockaddrstIPSrc={0};intlSrcLen=sizeof(stIPSrc);DWORDulMsStart =0;DWORDulLastError=0;DWORDulLoop=0; while((tNow-tStart)<=m_tTestTime){IcmpHeader*pstIcmpHdr=(IcmpHeader*)m_pSndData;if((GetTickCount()-ulMsStart)<=2000){Sleep(10);continue;}fill_icmp_data(m_pSndData,m_ulDatasize);pstIcmpHdr->i_cksum=0;pstIcmpHdr->timestamp=GetTickCount();pstIcmpHdr->i_seq=usSeq;pstIcmpHdr->i_cksum=CheckSum((unsignedshort*)m_pSndData,m_ulDatasize);ulMsStart=GetTickCount();ulByteSndCnt=sendto(m_Socket,m_pSndData,m_ulDatasize,0,(structsockaddr*)&m_Dest,sizeof(structsockaddr));if(SOCKET_ERROR==ulByteSndCnt){ulLastError=WSAGetLastError();if(WSAETIMEDOUT==ulLastError){Lock();m_TimeOutArray.Add(tNow);UnLock();continue;}returnfalse;}if(ulByteSndCnt<m_ulDatasize){continue;}memset((void*)m_pRcvData,0,MAX_DATASIZE);ulByteRcvCnt=recvfrom(m_Socket,m_pRcvData,MAX_DATASIZE,0,(structsockaddr*)&stIPSrc,&lSrcLen);if(SOCKET_ERROR==ulByteRcvCnt){ulLastError=WSAGetLastError();if(WSAETIMEDOUT==ulLastError){Lock();m_TimeOutArray.Add(tNow);UnLock();}}else{pstIcmpHdr=(structicmp*)(m_pRcvData+sizeof(IpHeader));if((ICMP_ECHOREPLY==pstIcmpHdr->i_code)&&(pstIcmpHdr->i_id==(USHORT)m_ulThreadId)){DelayMsInfo*pDelay=(DelayMsInfo*)malloc(sizeof(DelayMsInfo));pDelay->tTime=tNow;pDelay->ulDelay=(GetTickCount()-ulMsStart)+1;Lock();m_DelayMsArray.Add(pDelay);UnLock();}else{assert(0);}}usSeq++;tNow=time(NULL);Sleep(10);}returntrue;}boolCIcmpSocket::GetStatistic(CDWordArray&