基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 1 元　

支付宝支付

微信支付

   源码介绍

---

初步实现UDPServer通信，同时采用Log4cpp日志记录，简单的SQLite操作，是服务器编程入门资料。

Log4CPP_Init();

//初始化socket库
WORD wVersionRequested;
WSADATA wsaData;
int err;
wVersionRequested = MAKEWORD( 1, 1 );
err = WSAStartup( wVersionRequested, &wsaData );
if ( err != 0 ) 
{
return -1;
}
if ( LOBYTE( wsaData.wVersion ) != 1 ||
HIBYTE( wsaData.wVersion ) != 1 ) 
{
  WSACleanup( );
  return -1; 
}
 
SOCKET sockSrv = socket( AF_INET , SOCK_DGRAM , 0 ) ;
 
SOCKADDR_IN addrSrv ;
addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY) ;
addrSrv.sin_family = AF_INET ;
addrSrv.sin_port = htons(MYPORT) ;


///bind，成功返回0，出错返回-1
if( bind( sockSrv , (SOCKADDR*)&addrSrv , sizeof(SOCKADDR) ) ==-1){

   perror("bind");
exit(1);
} ;
 
SOCKADDR_IN addrClient ;
int len = sizeof(SOCKADDR) ;


//创建线程
int ret;
ret= pthread_create(&pthid1,NULL,pthread_ProcessDataFromOEM, NULL);
    if(ret)       // 非0则创建失败
    {
        perror("createthread 1 failed.\n");
        return 1;
    }
 
while (1)
{
  recvfrom(sockSrv,recvBuf,350,0,(SOCKADDR*)&addrClient,&len) ;
  if ( 'q' == recvBuf[0] )
  {
sendto(sockSrv,"q",strlen("q") 1,0,(SOCKADDR*)&addrClient,len) ;
printf("chat end!\n") ;
break ;
  }

  //！！需要将地址及端口号也写入内存中。
  PreProcessDataFromOEM();

//日志记录
  MyLogTest.Alert("The data packet has been receieved and parsed.");

  sprintf(tempBuf,"%s say : %s\n",inet_ntoa(addrClient.sin_addr),recvBuf) ;
  sendto(sockSrv,(char*)&SendCommand,10 1,0,(SOCKADDR*)&addrClient,len) ;

}
 
closesocket( sockSrv );
WSACleanup() ;

return 0;