TCP-sever

发布于 2016-05-25 14:41:22 浏览：1754 订阅该版

```void tcpserv(void *parameter)
{
   int maxfd, tmp, nbyte, res;
   rt_uint32_t sin_size;
   char buf[BUF_SIZE];
   int listenfd, connfd; /* ?¨???à??socket?è??·???????????socket?è??·? */
   struct sockaddr_in server_addr, client_addr; /* ±??úIP????????????  */
   fd_set global_rdfs, current_rdfs;
   int opt;
   CLIENT client[BACKLOG];

/* ????socket???????°???è???¤?????¨?????????¨SOCK_STREAM??TCP??socket */
   if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)
   {
      /* ???¨?§°????í?ó???í */
      rt_kprintf("TcpServ:Socket error!
");
      return;
   }

opt = 1;
   setsockopt(listenfd, IPPROTO_TCP, TCP_NODELAY, &opt, sizeof(opt)); //×?????±¨???????????±
   setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)); //???í???·????
   setsockopt(listenfd, SOL_SOCKET, SO_REUSEPORT, &opt, sizeof(opt)); //???í????????

/* ??????·????????· */
   server_addr.sin_family = AF_INET;        /* Ipv4?ò?????ò */
   server_addr.sin_port = htons(SERV_PORT); /* ·??????¤×÷?????? ????????????×????ò×???*/
   server_addr.sin_addr.s_addr = INADDR_ANY; /* ±??úIP???· */
   rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero)); /* ??0 */

/* °ó?¨socket??·????????· */
   if (bind(listenfd, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1)
   {
      /* °ó?¨?§°? */
      rt_kprintf("TcpServ:Unable to bind!
");
      return;
   }

/* ??sockfd???????à?? */
   if (listen(listenfd, BACKLOG) == -1)
   {
      rt_kprintf("TcpServ:Listen error!
");
      return;
   }

rt_sprintf(buf, "%4d", SERV_PORT);
   rt_kprintf("
TcpServ:TCPServer Waiting for client on port %s...
", buf);

FD_ZERO(&global_rdfs); //?????à???è??·???
   FD_SET(listenfd, &global_rdfs); //??listenfd?????à???è??·???
   maxfd = listenfd;
   while (1)
   {
      current_rdfs = global_rdfs;

//?ì?????è??·???????????????
      res = select(maxfd + 1, ¤t_rdfs, NULL, NULL, NULL);
      if (res < 0)
      {
         rt_kprintf("TcpServ:fail to select!");
         break;
      }
      else if (res == 0)
      {
         continue;
      }
      else
      {   //???è??·????????é?è?????í??
         for (tmp = 0; tmp <= maxfd; tmp++)
         {   //???????×???????è??·????????é·??ú
            if (FD_ISSET(tmp, ¤t_rdfs))
            {
               if (tmp == listenfd)
               {   //???à???è??·? ?ò???????§????????
                  rt_kprintf("TcpServ:New connection Detected->");
                  sin_size = sizeof(struct sockaddr_in);
                  if ((connfd = accept(tmp, (struct sockaddr *)&client_addr, &sin_size)) < 0)
                  {
                     rt_kprintf("TcpServ:!Fail to accept!
");
                     break;
                  }
                  /* ?ò?????§????IP???????? */
                  rt_kprintf("TcpServ:Connection from (IP: %s ,PORT: %d) is Done
",
                             inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));

FD_SET(connfd, &global_rdfs); //??????connfd?????à???è??·???
                  maxfd = maxfd > connfd ? maxfd : connfd; //?????è??·???×??ó??
                  if (connfd >= 0)
                  {
                     client[connfd].connectfd = connfd; /* save descriptor */
                     client[connfd].addr = client_addr;
                  }
               }
               else
               {   //?????§???????é·??ú??
                  if ((nbyte = recv(tmp, buf, BUF_SIZE, 0)) <= 0)
                  {   //???§????????????
		     rt_kprintf("TcpServ: Connection from (IP: %s ,PORT: %d) is Removed
",
                             inet_ntoa(client[tmp].addr.sin_addr), ntohs(client[tmp].addr.sin_port));

closesocket(client[tmp].connectfd);
                     //???????ì???è??·?????????
                     FD_CLR(tmp, &global_rdfs);
                     client[tmp].connectfd = -1;
                  }
                  else
                  {
                     buf[nbyte] = 0;
                     //rt_kprintf("TcpServ: RECIEVED DATA = %s from IP:%s ,PORT: %d)
", buf,
                     //           inet_ntoa(client[tmp].addr.sin_addr), ntohs(client[tmp].addr.sin_port));
                     //??????????????·????????§??
                     //send(tmp, buf, nbyte, 0);
		     //MdTcp ???í?ó????
		     TcpTimeOut=60;
		     nbyte = ReMapTcpRsp(buf,nbyte);
                     send(tmp, buf, nbyte, 0);

}
               }
            }
         }
      }
   }

/* ??±?socket ????·??? */
   closesocket(listenfd);
   return;
}```
大家看看这个程序哪有问题，我建立了四个连接同时通信，正常运行一段时间后程序就死在idle了，该线程无法被唤醒（除了TCPIP和shell线程，就这一个）