一个udp服务程序占用cpu过高的问题

qingfengjianke

#include   <unistd.h>    &nbsp;&nbsp;#include   <arpa/inet.h>    &nbsp;&nbsp;#include   <stdio.h>    &nbsp;&nbsp;#include   <stdlib.h>    &nbsp;&nbsp;#include   <string.h>    &nbsp;&nbsp;#include   <sys/types.h>    &nbsp;&nbsp;#include   <sys/socket.h> #include <sys/wait.h>    &nbsp;&nbsp;#include   <netinet/in.h>    &nbsp;&nbsp;#include   <mysql/mysql.h>    &nbsp;&nbsp;#include   <signal.h>    &nbsp;&nbsp;#include   <errno.h>    &nbsp;&nbsp;#include   <syslog.h> &nbsp;&nbsp;#include   <time.h> &nbsp;&nbsp; #define MAX 0 int main() { &nbsp;&nbsp;&nbsp;&nbsp;int opt =1; &nbsp;&nbsp;&nbsp;&nbsp; int sockSrv = socket(AF_INET,SOCK_DGRAM,0); &nbsp;&nbsp;&nbsp;&nbsp; //setsockopt(sockSrv, SOL_SOCKET, SO_REUSEADDR, (const void*)&opt, sizeof(opt)); &nbsp;&nbsp;&nbsp;&nbsp; sockaddr_in addrSrv; &nbsp;&nbsp;&nbsp;&nbsp;addrSrv.sin_addr.s_addr=htonl(INADDR_ANY);//本地地址转换成网络长字节 &nbsp;&nbsp;&nbsp;&nbsp;addrSrv.sin_family=AF_INET; &nbsp;&nbsp;&nbsp;&nbsp;addrSrv.sin_port=htons(8888);//本地字节转换成网络字节 &nbsp;&nbsp;&nbsp;&nbsp;bind(sockSrv,(sockaddr*)&addrSrv,sizeof(sockaddr)); &nbsp;&nbsp;&nbsp;&nbsp;char recvBuf[100]; &nbsp;&nbsp;&nbsp;&nbsp;char sendBuf[100]; &nbsp;&nbsp;&nbsp;&nbsp;char tempBuf[100]; &nbsp;&nbsp;&nbsp;&nbsp; sockaddr_in addrClient; &nbsp;&nbsp;&nbsp;&nbsp; int len = sizeof(sockaddr); &nbsp;&nbsp;&nbsp;&nbsp;printf("聊天程序服务器!!!\n"); &nbsp;&nbsp;&nbsp;&nbsp;struct timeval tv; &nbsp;&nbsp;&nbsp;&nbsp;tv.tv_sec=1; &nbsp;&nbsp;&nbsp;&nbsp;tv.tv_usec=0; &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;while(1) &nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;fd_set fdsocket; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;FD_ZERO(&fdsocket); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;FD_SET(sockSrv,&fdsocket); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if(select(MAX+1,&fdsocket,NULL,NULL,&tv)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if(FD_ISSET(sockSrv,&fdsocket)) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;recvfrom(sockSrv,recvBuf,100,0,(sockaddr*)&addrClient,(socklen_t *)&len); //等待接受数据 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;&nbsp;&nbsp;&nbsp;if('q' == recvBuf[0]) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;sendto(sockSrv,"q",strlen("q")+1,0,(sockaddr*)&addrClient,len); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("Chat end!\n"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;break; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;sprintf(tempBuf,"%s 说 : %s",inet_ntoa(addrClient.sin_addr),recvBuf); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("%s\n",tempBuf); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;printf("请回复:"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;gets(sendBuf); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;sendto(sockSrv,sendBuf,strlen(sendBuf)+1,0,(sockaddr*)&addrClient,len);*/ &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;} &nbsp;&nbsp;&nbsp;&nbsp;close(sockSrv); &nbsp;&nbsp;&nbsp;&nbsp;return 0; }

qingfengjianke

在Windows下,,,,我测试过,,如果程序不初始化 套接字库,,,也会占用很高的cpu,

Linux 的套接字不是不用加载吗???

为啥 cpu 会这么高呢,

咋解决呢?     

cookis

都怪你没判断错误码..

select 第一个参数不对..

selfrun

if(select(MAX+1,&fdsocket,NULL,NULL,&tv))
        {
              ...
        }
        else usleep(1000);

醉卧水云间

夸张, 一个socket还用select?

while(recvfrom(...))
{
  do ...
}

qingfengjianke

回 3楼仁兄:

再多说点嘛......


回 4楼 仁兄:

这个方法.......感觉............


回5楼 仁兄:

  这不是遇到一个问题了么,,
  ,一样的代码在 Windows下,如果不是初始化
套接字库,cpu也占用 很高???

cookis

select(sockSvr+1,

qingfengjianke

我改了,,,cpu 还是高...........

醉卧水云间

windows程序+

    WSADATA wsadata;
    WSAStartup( MAKEWORD( 2, 0 ), &wsadata );

cookis

struct timeval tv;
    tv.tv_sec=1;
    tv.tv_usec=0;
放到循环里边

select 的所有参数每次调用时都需要重设