c - 如何使用 C 套接字在不同线程中接收和发送

Question

我正在尝试在不同的线程中发送和接收。当我使用下面的代码时，我收到错误地址错误，我猜是因为我的服务器地址无法正确传递给线程函数。

代码:

#include "client.h"

struct global_table{
  struct sockaddr_in *serveraddr;
  int sockID;
};

void *recvFromServer(struct global_table *rec){
  char recBuf[RECVBUFSIZE];
  int serverSize = sizeof(rec->serveraddr);

  while(1)
  {
    int n = recvfrom(rec->sockID, recBuf, RECVBUFSIZE, 0, &rec->serveraddr, &serverSize);
    if (n < 0)
      perror("ERROR in recvfrom");
    decryptData(recBuf);
    printf("Recieved: %s\n", recBuf);
    pthread_exit(NULL);
  }
}

void pingServer(char *hostname, int portno)
{
  int sockfd, n, serverlen;
  struct sockaddr_in serveraddr;
  struct sockaddr_in client_addr; 
  struct hostent *server;
  char *buf;

  sockfd = socket(AF_INET, SOCK_DGRAM, 0);
  if (sockfd < 0) 
    perror("ERROR opening socket");

  server = gethostbyname(hostname);
  if (server == NULL) 
    perror("ERROR, no host found");

  bzero((char *) &serveraddr, sizeof(serveraddr));
  serveraddr.sin_family = AF_INET;
  bcopy((char *)server->h_addr, (char *)&serveraddr.sin_addr.s_addr, server->h_length);
  serveraddr.sin_port = htons(portno);

  client_addr.sin_family = AF_INET;
  client_addr.sin_addr.s_addr = htonl(INADDR_ANY);
  client_addr.sin_port = htons(5500);

  if (bind(sockfd,(struct sockaddr *)&client_addr, sizeof(struct sockaddr)) == -1)
    perror("Socket could not be binded");

  if(setsockopt(sockfd,IPPROTO_IP,IP_TOS,&tos,sizeof(tos)))
    perror("Could not set socket option");

  pthread_t threads[2];
  serverlen = sizeof(serveraddr);
  struct global_table server_info;

  server_info.sockID = sockfd;
  server_info.serveraddr = &serveraddr;

  pthread_create(&threads[0],NULL,recvFromServer, &server_info); // Trying to recv on a different thread
  pthread_join(threads[0],NULL);

}

int main(int argc, char **argv) {
  char *hostname;
  int portno;
  if (argc != 3)
    perror("usage: <hostname> <port>\n");

  hostname = argv[1];
  portno = atoi(argv[2]);
  pingServer(hostname, portno);
  return 0;
}

如何解决这个问题？

Answer 1

除了评论中指出的问题(到现在为止，评论中也指出了这个问题...)，这一行

struct global_table server_info;

在 pingServer() 函数中创建一个局部变量。

这一行

pthread_create(&threads[0],NULL,recvFromServer, &server_info); // Trying to recv on a different thread

of code 将该变量的地址传递给 recvFromServer() 函数，该函数将在不同的线程中运行。但随后 pingServer() 立即返回，并且本地 server_info 变量不再存在。

一个解决方法是将 server_info 和 serveraddr 变量定义为 static:

static struct global_table server_info;
static struct sockaddr_in serveraddr;

这将创建 server_info 变量的一个副本，该变量将由 pingServer() 的每次调用共享，但是该副本将在程序的整个生命周期中都存在。