基于VC實(shí)現(xiàn)的網(wǎng)絡(luò)監(jiān)聽功能程序?qū)嵗?/h1>

來源：本站原創(chuàng)|時間：2020-01-10|欄目：C語言|點(diǎn)擊： 次

本文所述VC++網(wǎng)絡(luò)監(jiān)聽器代碼，可以實(shí)現(xiàn)監(jiān)聽網(wǎng)絡(luò)連接所使用的協(xié)議、源IP地址、目標(biāo)IP地址等信息的功能，并且能把數(shù)據(jù)內(nèi)容綁定到網(wǎng)格控件中顯示。具體功能代碼部分如下所示：

//線程函數(shù)
UINT ThreadFun( LPVOID pParam )
{
 CSniffAppDlg* pDlg = static_cast<CSniffAppDlg*>(pParam);
 MSG msg;
 char buffer[1000],sourceip[32] ,*tempbuf;
 char *ptemp;
 BYTE* pData = NULL; //實(shí)際數(shù)據(jù)報中的數(shù)據(jù)
 UINT sourceport ;
 CString str;
 HEADIP*  pHeadIP;
 HEADICMP* pHeadICMP;
 HEADUDP*  pHeadUDP;
 HEADTCP*  pHeadTCP;
 in_addr addr;
 int ret;
 while (TRUE)
 {
 pData = NULL;
 if (PeekMessage(&msg,pDlg->m_hWnd,WM_CLOSE,WM_CLOSE,PM_NOREMOVE ))
 {
  closesocket(pDlg->m_Sock);
  break; 
 }
 memset(buffer,0,1000);
 ret = recv(pDlg->m_Sock,buffer,1000,0);
 
 if (ret == SOCKET_ERROR)
 {
  continue;
 }
 else //接收到數(shù)據(jù)
 {
  tempbuf = buffer;
  pHeadIP = (HEADIP*)tempbuf;
  //獲取數(shù)據(jù)報總長度
  WORD len = ntohs(pHeadIP->totallen);
  
  //獲取源IP
  pDlg->m_List.InsertItem(pDlg->m_List.GetItemCount(),"");
  addr.S_un.S_addr = pHeadIP->sourceIP;
  ptemp = inet_ntoa(addr);
  
  pDlg->m_List.SetItemText(pDlg->m_List.GetItemCount()-1,1,ptemp);
 
  //獲取目的IP
  addr.S_un.S_addr = pHeadIP->destIP;
  ptemp = inet_ntoa(addr);
  pDlg->m_List.SetItemText(pDlg->m_List.GetItemCount()-1,2,ptemp);
  
  //獲取協(xié)議名稱
  ptemp = get_protoname(pHeadIP->proto);
  strcpy(sourceip,ptemp);
  pDlg->m_List.SetItemText(pDlg->m_List.GetItemCount()-1,0,sourceip);
  
  //獲取IP數(shù)據(jù)報總長度
  WORD ipSumLen = ntohs(pHeadIP->totallen);
  
  //IP數(shù)據(jù)報頭總長度
  int ipHeadLen = 20;
  //獲得去除IP層數(shù)據(jù)的長度
  WORD netlen = ipSumLen - ipHeadLen;
  
  //根據(jù)不同大協(xié)議獲得不同協(xié)議的數(shù)據(jù)
  switch (pHeadIP->proto)
  {
  case IPPROTO_ICMP:
  {
   pHeadICMP = (HEADICMP*)(tempbuf+20); 
   
   pData = (BYTE*)(pHeadICMP)+4; //ICMP數(shù)據(jù)報頭共4個字節(jié)   
   //獲取數(shù)據(jù)的長度
   netlen -= 4;
   break;
  }
  case IPPROTO_UDP:
  {
   pHeadUDP = (HEADUDP*)(tempbuf+20); 
   pData = (BYTE*)pHeadUDP+8; //UDP數(shù)據(jù)報頭共8個字節(jié)
   sourceport = ntohs(pHeadUDP->SourcePort);
   str.Format("%d",sourceport);
   //設(shè)置源端口
   pDlg->m_List.SetItemText(pDlg->m_List.GetItemCount()-1,3,str); 
   str.Empty();
   netlen -= 8;  
   break;
  }
  case IPPROTO_TCP:
  {
   pHeadTCP = (HEADTCP*)(tempbuf+20);
   sourceport = ntohs(pHeadTCP->SourcePort);   
   pData = (BYTE*)pHeadTCP+20; //TCP數(shù)據(jù)報頭共20個字節(jié)
   str.Format("%d",sourceport);
   //設(shè)置源端口
   pDlg->m_List.SetItemText(pDlg->m_List.GetItemCount()-1,3,str); 
   str.Empty();
   netlen-= 20;  
   break;
  }     
  }
  //設(shè)置數(shù)據(jù)大小
  str.Format("%d",netlen);
  pDlg->m_List.SetItemText(pDlg->m_List.GetItemCount()-1,4,str);
  str.Empty();
  //設(shè)置數(shù)據(jù)
  if (pData != NULL)
  {
  str.Format(" %s",pData);
  pDlg->m_List.SetItemText(pDlg->m_List.GetItemCount()-1,5,str);
  }
  str.Empty();
 }
 }
 return 0;
}
void CSniffAppDlg::OnBeginlisten() 
{
 //創(chuàng)建套接字
 m_Sock = socket(AF_INET,SOCK_RAW, IPPROTO_IP );
 char name[128];
 memset(name,0,128);
 hostent* phostent;
 phostent = gethostbyname(name);
 DWORD ip;
 ip = inet_addr(inet_ntoa(*(in_addr*)phostent->h_addr_list[0]));
 int timeout = 4000; //超時4秒
 //設(shè)置接收數(shù)據(jù)的超時時間
 setsockopt(m_Sock,SOL_SOCKET,SO_RCVTIMEO,(const char*)&timeout,sizeof(timeout));
 sockaddr_in skaddr;
 skaddr.sin_family = AF_INET;
 skaddr.sin_port = htons(700);
 skaddr.sin_addr.S_un.S_addr = ip;
 //綁定地址
 if ( bind(m_Sock,(sockaddr*)&skaddr,sizeof(skaddr))==SOCKET_ERROR)
 {
 MessageBox("地址綁定錯誤");
 return;
 }
 DWORD inBuffer=1;
 DWORD outBuffer[10];
 DWORD reValue = 0;
 if (WSAIoctl(m_Sock,SIO_RCVALL,&inBuffer,sizeof(inBuffer),&outBuffer,sizeof(outBuffer),&reValue,NULL,NULL)==SOCKET_ERROR)
 {
 MessageBox("設(shè)置緩沖區(qū)錯誤.");
 closesocket(m_Sock);
 return;
 }
 else
 m_pThread = AfxBeginThread(ThreadFun,(void*)this);
}
void CSniffAppDlg::OnCancel()
{
 if (m_pThread)
 {
 //m_pThread->ExitInstance();
 delete m_pThread;
 }
 closesocket( m_Sock) ;
 CDialog::OnCancel();
}

該實(shí)例只是功能部分主要代碼，讀者可根據(jù)自身項(xiàng)目需求進(jìn)行測試，加以改進(jìn)與完善之后整合進(jìn)自身項(xiàng)目中去。