1

这是 .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);
4

1 回答 1

2

MySocket::sd是您需要与 . 一起使用的描述符select()。socket()和返回accept()可以与 . 一起使用的套接字描述符select()。更改tcp_passive_open()为返回 aMySocket*而不是 a 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()在服务器套接字上报告一个未决的入站连接连接时，调用accept()接受连接并获取其套接字描述符，然后您可以为其分配一个单独MySocket的：

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

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

于 2012-05-28T21:40:54.510 回答