访问套接字的文件描述符

Question

这是 .c 文件的一部分，包含在 tcp 服务器-客户端消息服务中，每个线程有一个客户端；我想在服务器线程中使用 select 来处理新的传入连接或写入缓冲区的数据，但我遇到的问题是我需要套接字文件描述符来执行客户端和服务器的操作。

在这部分代码中，服务器的套接字描述符位于 s->sd 内，但我似乎可以在此函数之外访问它，因为它返回（套接字）。

我能做什么？ （为了便于阅读，省略了大部分代码）

#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>

typedef struct {
  int sd; //id of the socket??
  char *ip_addr;
  int port;   
  } MySocket;   

Socket tcp_passive_open(int port) 
{                                                                                      
  MySocket *s = (MySocket *)malloc( sizeof(MySocket) );
  struct sockaddr_in addr;
  s->sd = socket(PROTOCOLFAMILY, TYPE, PROTOCOL);

  memset(&addr, 0, sizeof(struct sockaddr_in));
  addr.sin_family = PROTOCOLFAMILY;
  addr.sin_addr.s_addr = htonl(INADDR_ANY);
  addr.sin_port = htons(port);

  if ( bind(s->sd, (struct sockaddr *)&addr, sizeof(addr)) != 0 ) {
    die("tcp_open_server failed(): bind() failed"); 
  }

  s->port = port;
  s->ip_addr = NULL;  //INADDR_ANY ...  
  return (Socket)s;  
}

主要：

Socket server = tcp_passive_open( PORT );
FD_SET(SOCKETDESCRIPTOR_SERVER??,&master_socketDescriptors);

Answer 1

MySocket::sd 是您需要与select() 一起使用的描述符。 socket() 和accept() 都返回可与select() 一起使用的套接字描述符。更改tcp_passive_open() 以返回MySocket* 而不是Socket，然后您的主服务器线程将有权访问服务器的套接字描述符以传递给select() 以检测传入连接，例如：

#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>

typedef struct {
    int sd;
    char *ip_addr;
    int port;
} MySocket;

MySocket* tcp_passive_open(int port) {
    MySocket *s = (MySocket *)malloc( sizeof(MySocket) );
    if ( s == NULL ) {
        die("tcp_open_server failed(): malloc() failed");
    }

    s->sd = socket(PROTOCOLFAMILY, TYPE, PROTOCOL);
    if ( s->sd == -1 ) {
        die("tcp_open_server failed(): socket() failed");
    }

    struct sockaddr_in addr;
    memset(&addr, 0, sizeof(struct sockaddr_in));
    addr.sin_family = PROTOCOLFAMILY;
    addr.sin_addr.s_addr = htonl(INADDR_ANY);
    addr.sin_port = htons(port);

    if ( bind(s->sd, (struct sockaddr *)&addr, sizeof(addr)) != 0 ) {
        die("tcp_open_server failed(): bind() failed");
    }

    s->port = port;
    s->ip_addr = NULL;  //INADDR_ANY ...
    return s;
}

.

MySocket* server = tcp_passive_open( PORT );
FD_SET(server->sd, &master_socketDescriptors); 

之后，当select()在服务器socket上报告一个挂起的入站连接连接时，调用accept()接受连接并获取它的socket描述符，然后你可以为它分配一个单独的MySocket：

int sd = accept(server->sd, ...);
if ( sd != -1 ) {
    MySocket *client = (MySocket*) malloc(sizeof(MySocket));
    client->sd = sd;
    ...
}

然后您可以为该MySocket 创建一个新线程，该线程可以根据需要调用select() 来检测该连接上的入站数据。