请教如何实现 TCP服务器的多连接

glj77

比方说建立了一个 TCP服务器，端口为 5000，现在只能是一个客户端可以成功连接，第2个就连不上。假如我需要多个客户端可以同时连接 5000这个端口，应该怎么做啊？

eric2013

简单点，创建多个tcp服务器，监听同一个端口即可，因为TCP通信是一对一，一个服务器对应一个客户端。

或者使用BSD Socket，可以设置监听多个连接，会自动创建TCP服务器处理客户端来的连接。

xujun

eric2013:
简单点，创建多个tcp服务器，监听同一个端口即可，因为TCP通信是一对一，一个服务器对应一个客户端。

或者使用BSD Socket，可以设置监听多个连接，会自动创建TCP服务器处理客户端来的连接。

BSD有没有

select()这个函数，lwip里用bsd的时候有这个，看您的教程里直接是监听，等待连接，接收数据，没有判断是哪个的数据啊？还是内部已经处理过了？

eric2013

xujun:BSD有没有

select()这个函数，lwip里用bsd的时候有这个，看您的教程里直接是监听，等待连接，接收数据，没有判断是哪个的数据啊？还是内部已经处理过了？

....... (2017-09-29 09:02) 

无此函数，可以accept的时候获取是来自哪个IP。

glj77

多谢版主，去试一下

albert.hu

同样碰到这个问题，在官方找到了另外一个方法，放过来供大家参考
https://www.keil.com/support/man ... _tn_tcp_mulconn.htm

The framework of the user application shall contain the following basic functions:

The user_init() function to initialize all user application sessions at startup.
void user_init () {
  USER_INFO *user_s;
  int i;

  for (i = 0; i < user_num_sess; i++) {
    user_s = &user_session;
    user_s->Count = 0;
    user_s->Flags = 0;
    user_s->BCnt  = 0;
    user_s->Tout  = 0;
    user_s->File  = NULL;
    user_s->Script= NULL;
    /* Allocate a TCP socket for the session. */
    user_s->Socket = tcp_get_socket (TCP_TYPE_SERVER, TCP_TOS_NORMAL,
                     120, user_listener);
    user_s->State = USER_STATE_ERROR;
    if (user_s->Socket != 0) {
      if (tcp_listen (user_s->Socket, USER_SERVER_PORT) == __TRUE) {
        user_s->State = USER_STATE_IDLE;
      }
    }
  }
}
All user sessions are now initialized and each session has allocated it's own TCP socket. A socket is listening on selected USER_SERVER_PORT port.
The user_listener() callback function for TCP socket. This callback function is common for all TCP sockets allocated in this user application.
static U16 user_listener (U8 socket, U8 event, U8 *ptr, U16 par) {
  USER_INFO *user_s;
  U8 session;
  int i;

  session = user_map_session (socket);
  if (session == 0)) {
    return (__FALSE);
  }
  user_s = &user_session[session-1];
  switch (event) {
    case TCP_EVT_CONREQ:
      if (user_s->State == USER_STATE_IDLE) {
        user_s->State = USER_STATE_RESERVED;
      }
      return (__TRUE);

    case TCP_EVT_ABORT:
      user_kill_session (user_s);
      return (__TRUE);

    case TCP_EVT_CONNECT:
      user_s->State = USER_STATE_ACTIVE;
      return (__TRUE);

    case TCP_EVT_CLOSE:
      user_kill_session (user_s);
      return (__TRUE);

    case TCP_EVT_ACK:
      user_s->Count += user_s->BCnt;
      user_s->BCnt = 0;
      return (__TRUE);

    case TCP_EVT_DATA:
       ..
      return (__TRUE);
  }
  return (__FALSE);
}
The user_map_session() function to map the socket, which has generated a callback event, to it's owner session.
static U8 user_map_session (U8 socket) {
  int i;

  for (i = 1; i <= user_num_sess; i++) {
    if (user_session[i-1].Socket == socket) {
      return (i);
    }
  }
  return (0);
}
The user_kill_session() function to initialize the session to a default state, close any eventually opened files and release any eventually allocated buffers.
static void user_kill_session (USER_INFO *user_s) {

  user_s->State =  USER_STATE_IDLE;
  if (user_s->Flags & USER_FLAG_FOPENED) {
    user_fclose (user_s->File);
    user_s->File = NULL;
  }
  if (user_s->Script != NULL) {
    free_mem (user_s->Script);
    user_s->Script = NULL;
  }
  user_s->Flags = 0;
  user_s->Count = 0;
  user_s->BCnt  = 0;
  user_s->Tout  = 0;
}
The user_run_server() function to maintain the application jobs, timeouts, etc. This function shall be frequently called from the main loop.
void user_run_server () {
  USER_INFO *user_s;
  int i;

  for (i = 0; i < user_num_sess; i++) {
    user_s = &user_session;

    switch (user_s->State) {
      case USER_STATE_IDLE:
      case USER_STATE_RESERVED:
        /* Keep TCP sockets listening. */
        if (tcp_get_state (user_s->Socket) < TCP_STATE_LISTEN) {
          tcp_listen (user_s->Socket, USER_SERVER_PORT);
        }
        break;
      case USER_STATE_WAITING:
        if (sec_tick == __TRUE) {
          if (--user_s->Tout == 0) {
            /* A timeout expired. */
            user_kill_session (user_s);
          }
        }
        break;
      case USER_STATE_ACTIVE:
         ..
        break;
    }
  }
}