udpserver.cpp

在linux下基于UDP通讯的程序,包括客户端与服务端.

#include "UDPServer.h"
#include <string>
#include <iostream>
#include "LibHead.h"
#include "SimpleUDP.h"
#include "LogHelper.h"

using namespace std;
CUDPServer theServer;
CSimpleUDP udpServer;
extern  CLogHelper theLogger;
CUDPServer::CUDPServer()
{
    if(!udpServer.InitRcvSock(9001))
      {
         string str = "创建UDP服务器失败[CUDPServer::CUDPServer()]";
		 theLogger.LogMessage(str, true);
         exit(0);
      }
	m_nCounter = 0;
    CTask::CTask(this);
}

CUDPServer::~CUDPServer()
{

}

bool CUDPServer::MayEnd()
{
	return (m_nCounter >= 15) ? true : false ;
}

int CUDPServer::Execute()
{
     char * szRead = 0;
	 int nLen = 8192;
	 sockaddr_in addr;
	 char szMsg[1024];
	 memset(szMsg, 0, 1024);
	 szRead = udpServer.RcvMsg(nLen, addr, szMsg);
	 if(strlen(szMsg) > 0)
	 {
		 char szRecv[4096];
		 sprintf(szRecv, "收到消息:%s", szRead);
	     string str = string(szRecv) +  "[CUDPServer::CUDPServer()]";
		 theLogger.LogMessage(str, true);
		 m_nCounter++;
	 }
    return 1;
}