音视频聊天开发: 4 udp封装后的调用-凯发app官方网站

      上文提到的udpsocket,只是一个简单的socket封装，被动地调用。本文仿照mfc的casyncsocket方式做一个包装调用，不过事件响应采用select，不用mfc的窗口消息。
      简单接口如下：

typedef void (*udp_data_cb)(int sockid, char *data, int len, int ip, int port, int timestamp, void* param);

class cudpsession  
{
cudpsession();
virtual ~cudpsession();
int open(uint16_t uslocalport, udp_data_cb cb, void* param);
int close();
int send(char* pbuff,uint32_t nlen,uint32_t ip,uint16_t port);

private:

udp_data_cb m_pcb;
void* m_pparam;

private:
static void*  eventloop(void* lpparameter );
void processevent();

void ontimer();
int  onrecv(char* pbuff,uint32_t nlen, uint32_t ip,uint16_t port);
bool         m_beventloopstarted;
cudpsock     m_udpio;
pthread_t    m_tid;

};

出于通用和简便上考虑，线程采用了pthread形式。在windwos下，可以参考：。
这个项目把windows的线程使用重新封装了一下，话说windows原生的线程函数实在是.....。 

class实现只展示几个重点函数，其他在源码里。


int cudpsession::open(uint16_t uslocalport, udp_data_cb cb, void* param)
{
m_pcb = cb;
m_pparam = param;


if (m_beventloopstarted)
        return 0;


int iresult = m_udpio.open(uslocalport);
if (iresult > 0)
{
 pthread_create (&m_tid, null, eventloop, this);
}
return iresult;
}
int cudpsession::close()
{
if (m_beventloopstarted)
{
m_beventloopstarted = false;
pthread_join(tid, null);
m_udpio.close();
}
return 0;
}


void* cudpsession::eventloop(void* lpparameter )
{
cudpsession* pthis = (cudpsession*)lpparameter;
pthis->processevent();
return 0;
}

void cudpsession::processevent()
{
timeval timeout;
timeout.tv_sec = 0;
timeout.tv_usec = 50000; //50ms


fd_set fsread;


char szbuffer[1500];
int ireceived = 0;
int ierrorcode = 0;




m_beventloopstarted = true;
bool blastsend = false;
while (m_beventloopstarted)
{
fd_zero( &fsread );
fd_set(m_udpio.m_handle, &fsread);


int ret = select (1024, &fsread, null, null, &timeout);
if (ret < 0)
{
//err
}
else if (ret == 0)
{
ontimer();
}
else 
{
if(fd_isset( m_udpio.m_handle, &fsread))
{
uint32_t ip;
uint16_t port;
ireceived = m_udpio.receive(szbuffer, 1500, ip, port);
if (ireceived > 0)
{
onrecv(szbuffer, ireceived, ip, port);
}
else
{
//error
}
}
}
timeout.tv_sec = 0;
timeout.tv_usec = 50000;
}
}


void cudpsession::ontimer()
{
struct timeval cur;
 gettimeofday(&cur, null);

int timestamp = (cur.tv_sec-start_time.tv_sec)*1000 (cur.tv_usec - start_time.tv_usec)/1000;
//start_time是一个时间标志，在合适的位置初始化一下，gettimeofday(&start_time, null);定时时间到就重置。
}