用C语言写一个多路复用开关程序

你好，以下是回答：

可以使用 select 函数实现多路复用开关程序。select 函数可以同时监视多个文件描述符，当其中任意一个文件描述符发生可读、可写或异常事件时，select 函数就会返回，然后可以通过判断哪些文件描述符发生了事件来进行相应的操作。

具体实现可以参考以下代码：

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/select.h>

#define MAX_CLIENTS 10

int main(int argc, char *argv[]) {
int server_fd, client_fds[MAX_CLIENTS], max_fd, i, ret;
struct sockaddr_in server_addr, client_addr;
socklen_t client_len;
fd_set read_fds;

// 创建服务器套接字
server_fd = socket(AF_INET, SOCK_STREAM, );
if (server_fd < ) {
perror("socket");
exit(EXIT_FAILURE);
}

// 绑定服务器地址
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = INADDR_ANY;
server_addr.sin_port = htons(8888);
if (bind(server_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) < ) {
perror("bind");
exit(EXIT_FAILURE);
}

// 监听客户端连接
if (listen(server_fd, MAX_CLIENTS) < ) {
perror("listen");
exit(EXIT_FAILURE);
}

// 初始化客户端套接字数组
for (i = ; i < MAX_CLIENTS; i++) {
client_fds[i] = -1;
}

// 设置最大文件描述符
max_fd = server_fd;

while (1) {
// 清空文件描述符集合
FD_ZERO(&read_fds);

// 将服务器套接字加入文件描述符集合
FD_SET(server_fd, &read_fds);

// 将客户端套接字加入文件描述符集合
for (i = ; i < MAX_CLIENTS; i++) {
if (client_fds[i] != -1) {
FD_SET(client_fds[i], &read_fds);
if (client_fds[i] > max_fd) {
max_fd = client_fds[i];
}
}
}

// 监视文件描述符集合
ret = select(max_fd + 1, &read_fds, NULL, NULL, NULL);
if (ret < ) {
perror("select");
exit(EXIT_FAILURE);
}

// 处理服务器套接字事件
if (FD_ISSET(server_fd, &read_fds)) {
// 接受客户端连接
client_len = sizeof(client_addr);
int client_fd = accept(server_fd, (struct sockaddr *)&client_addr, &client_len);
if (client_fd < ) {
perror("accept");
exit(EXIT_FAILURE);
}

// 将客户端套接字加入客户端套接字数组
for (i = ; i < MAX_CLIENTS; i++) {
if (client_fds[i] == -1) {
client_fds[i] = client_fd;
break;
}
}

// 如果客户端套接字数组已满，则关闭新连接
if (i == MAX_CLIENTS) {
close(client_fd);
}

// 更新最大文件描述符
if (client_fd > max_fd) {
max_fd = client_fd;
}

printf("New client connected: %s:%d\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
}

// 处理客户端套接字事件
for (i = ; i < MAX_CLIENTS; i++) {
if (client_fds[i] != -1 && FD_ISSET(client_fds[i], &read_fds)) {
char buf[1024];
int n = read(client_fds[i], buf, sizeof(buf));
if (n < ) {
perror("read");
exit(EXIT_FAILURE);
} else if (n == ) {
// 客户端关闭连接
close(client_fds[i]);
client_fds[i] = -1;
printf("Client disconnected\n");
} else {
// 处理客户端数据
buf[n] = '\';
printf("Received from client: %s", buf);
}
}
}
}

return ;
}