C 中发送同时接收

Question

我在我的服务器上编写了一段代码作为多线程。

问题是，当我在另一个套接字上接收数据时，它不会发送数据。

所以如果我从客户端1向客户端2发送一些东西，客户端2只有在他自己发送一些东西时才会收到（跳出recv函数）..我该如何解决这个问题？

 /* Thread*/
while (! stop_received) {
        nr_bytes_recv = recv(s, buffer, BUFFSIZE, 0);

        if(strncmp(buffer, "SEND", 4) == 0) {
            char *message = "Text asads \n";
            rv = send(users[0].s, message, strlen(message), 0);
            rv = send(users[1].s, message, strlen(message), 0);
            if (rv < 0) {
                perror("Error sending");
                exit(EXIT_FAILURE);
            }           
        }else{
            char *message = "Unknown command \n";
            rv = send(s, message, strlen(message), 0);
            if (rv < 0) {
                perror("Error sending");
                exit(EXIT_FAILURE);
            }
        }
}

Answer 1

更具体地说，I/O 有几种类型。您当前正在做的事情称为阻塞 I/O。一般来说，这意味着当您调用 send 或 recv 时，操作将“阻塞”直到完成。

与此相反的是所谓的非阻塞 I/O。在此 I/O 模型中，如果操作无法完成，它将立即返回。通常 select 函数与此 i/o 模型一起使用。

您可以在 Select 教程 中查看示例程序。完整的源代码位于页面底部。

正如其他人所指出的，您的另一个选择是使用线程。

Answer 2

您的代码将在 recv() 调用上阻塞。编写一个多线程应用程序，或者研究 select() 函数的使用。

Answer 3

将发送和接收放在单独的线程中。

Answer 4

我注意到您正在使用 perror() （POSIX 错误函数），这让我相信您正在使用 POSIX 操作系统，这让我怀疑它是 GNU/Linux。

select() 是可移植的，poll() 以 POSIX 为中心，epoll() 以 Linux 为中心。如果使用 GNU/Linux，我强烈建议避免使用 select() 并使用：

• poll()（如果您只轮询几十个文件描述符）
• epoll()< /code> 如果您需要扩展到数千个连接，它是可用的。

如果您的应用程序不需要可移植，并且没有要求禁止使用扩展，请使用 poll() 或 epoll()。一旦您了解了 select() 的工作原理，您就会很高兴摆脱它，特别是对于必须扩展以服务许多客户的东西。

如果需要可移植性，请查看构建配置期间是否存在 poll() 或 epoll() 并使用其中之一来支持 select()。

注意，epoll() 直到 Linux 2.5(something) 才出现，所以最好习惯使用两者。

Answer 5

您应该将代码分成两个线程，一个发送器和一个接收器。

是这样的：

 /* 1st Thread*/
while (! stop_received) {
        nr_bytes_recv = recv(s, buffer, BUFFSIZE, 0);
}


 /* 2nd Thread*/
while (! stop_received) {
        if(strncmp(buffer, "SEND", 4) == 0) {
            char *message = "Text asads \n";
            rv = send(users[0].s, message, strlen(message), 0);
            rv = send(users[1].s, message, strlen(message), 0);
            if (rv < 0) {
                perror("Error sending");
                exit(EXIT_FAILURE);
            }           
        }else{
            char *message = "Unknown command \n";
            rv = send(s, message, strlen(message), 0);
            if (rv < 0) {
                perror("Error sending");
                exit(EXIT_FAILURE);
            }
        }
}

并发会带来一些问题，比如访问buffer变量。

Answer 6

有两种方法可以实现您想要的目标：

1.) 在不同的线程中实现发送和接收代码。但会有一些问题，比如增加客户端数量可能会让你在处理代码时遇到麻烦。还会存在一些并发问题（如 pcent 所提到的）。
你可以选择无阻塞套接字，但我建议不要这样做，因为我希望你不想要CPU占用。

2.) 另一种方法是使用 select() 函数，它可以让您同时监视多个不同类型的套接字。有关“select()”的更多描述，您可以谷歌搜索。 :)