\u5b9e\u73b02\u4e2a\u5ba2\u6237\u7aef\u4e4b\u95f4\u4e92\u76f8\u804a\u5929
\n\u8981\u6c42：
\n1\u3001\u670d\u52a1\u5668\u4f7f\u7528 select \u6a21\u578b\u5b9e\u73b0\u63a5\u53d7\u591a\u4e2a\u5ba2\u6237\u7aef\u8fde\u63a5，\u4ee5\u53ca\u8f6c\u53d1\u6d88\u606f
\n2\u3001\u5ba2\u6237\u7aef\u8981\u6c42：\u4f7f\u7528 poll \u6a21\u578b\u89e3\u51b3 \u6280\u80fd\u591f read \u8bfb\u53d6\u670d\u52a1\u5668\u53d1\u6765\u7684\u6d88\u606f，\u53c8\u80fd\u591fscanf\u8bfb\u53d6\u952e\u76d8\u8f93\u5165\u7684\u4fe1\u606f
\n3\u3001\u5ba2\u6237\u7aef\u670d\u52a1\u5668\u4e0d\u5141\u8bb8\u5f00\u542f\u989d\u5916\u7ebf\u7a0b\u548c\u8fdb\u7a0b<\/p>\n<\/p>\n
#include <stdio.h>
\n#include <stdlib.h>
\n#include <string.h>
\n#include <unistd.h>
\n#include <sys\/socket.h>
\n#include <netinet\/in.h>
\n#include <sys\/select.h><\/p>\n
#define MAX_CLIENTS 10
\n#define BUFFER_SIZE 1024<\/p>\n
int main(int argc, char *argv[]) {
\n if (argc != 2) {
\n printf("Usage: %s <port>\\\\n", argv[0]);
\n return 1;
\n }<\/p>\n
int server_fd, new_socket, client_sockets[MAX_CLIENTS];
\n struct sockaddr_in address;
\n int opt = 1;
\n int addrlen = sizeof(address);
\n char buffer[BUFFER_SIZE] = {0};<\/p>\n
\/\/ \u521d\u59cb\u5316\u5ba2\u6237\u7aefsocket\u6570\u7ec4
\n for (int i = 0; i < MAX_CLIENTS; i++) {
\n client_sockets[i] = 0;
\n }<\/p>\n
\/\/ \u521b\u5efasocket
\n if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
\n perror("socket failed");
\n exit(EXIT_FAILURE);
\n }<\/p>\n
\/\/ \u8bbe\u7f6esocket\u9009\u9879
\n if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt))) {
\n perror("setsockopt");
\n exit(EXIT_FAILURE);
\n }<\/p>\n
address.sin_family = AF_INET;
\n address.sin_addr.s_addr = INADDR_ANY;
\n address.sin_port = htons(atoi(argv[1]));<\/p>\n
\/\/ \u7ed1\u5b9asocket
\n if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {
\n perror("bind failed");
\n exit(EXIT_FAILURE);
\n }<\/p>\n
\/\/ \u76d1\u542c
\n if (listen(server_fd, 3) < 0) {
\n perror("listen");
\n exit(EXIT_FAILURE);
\n }<\/p>\n
printf("Server started on port %d\\\\n", atoi(argv[1]));<\/p>\n
fd_set readfds;
\n int max_sd, activity;<\/p>\n
while (1) {
\n FD_ZERO(&readfds);
\n FD_SET(server_fd, &readfds);
\n max_sd = server_fd;<\/p>\n
\/\/ \u6dfb\u52a0\u5ba2\u6237\u7aefsocket\u5230\u96c6\u5408
\n for (int i = 0; i < MAX_CLIENTS; i++) {
\n if (client_sockets[i] > 0) {
\n FD_SET(client_sockets[i], &readfds);
\n }
\n if (client_sockets[i] > max_sd) {
\n max_sd = client_sockets[i];
\n }
\n }<\/p>\n
\/\/ \u4f7f\u7528select\u7b49\u5f85\u6d3b\u52a8
\n activity = select(max_sd + 1, &readfds, NULL, NULL, NULL);
\n if ((activity < 0) && (errno != EINTR)) {
\n perror("select error");
\n }<\/p>\n
\/\/ \u68c0\u67e5\u65b0\u8fde\u63a5
\n if (FD_ISSET(server_fd, &readfds)) {
\n if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen)) < 0) {
\n perror("accept");
\n exit(EXIT_FAILURE);
\n }<\/p>\n
printf("New connection, socket fd: %d, ip: %s, port: %d\\\\n",
\n new_socket, inet_ntoa(address.sin_addr), ntohs(address.sin_port));<\/p>\n
\/\/ \u6dfb\u52a0\u65b0socket\u5230\u6570\u7ec4
\n for (int i = 0; i < MAX_CLIENTS; i++) {
\n if (client_sockets[i] == 0) {
\n client_sockets[i] = new_socket;
\n printf("Adding to list of sockets as %d\\\\n", i);
\n break;
\n }
\n }
\n }<\/p>\n
\/\/ \u68c0\u67e5\u5ba2\u6237\u7aef\u6570\u636e
\n for (int i = 0; i < MAX_CLIENTS; i++) {
\n int sd = client_sockets[i];
\n if (FD_ISSET(sd, &readfds)) {
\n int valread = read(sd, buffer, BUFFER_SIZE);
\n if (valread == 0) {
\n \/\/ \u5ba2\u6237\u7aef\u65ad\u5f00\u8fde\u63a5
\n getpeername(sd, (struct sockaddr*)&address, (socklen_t*)&addrlen);
\n printf("Host disconnected, ip: %s, port: %d\\\\n",
\n inet_ntoa(address.sin_addr), ntohs(address.sin_port));
\n close(sd);
\n client_sockets[i] = 0;
\n } else {
\n \/\/ \u8f6c\u53d1\u6d88\u606f\u7ed9\u6240\u6709\u5ba2\u6237\u7aef
\n buffer[valread] = '\\\\0';
\n printf("Forwarding message: %s\\\\n", buffer);
\n for (int j = 0; j < MAX_CLIENTS; j++) {
\n if (client_sockets[j] > 0 && client_sockets[j] != sd) {
\n send(client_sockets[j], buffer, strlen(buffer), 0);
\n }
\n }
\n }
\n }
\n }
\n }<\/p>\n
return 0;
\n}<\/p>\n
#include <stdio.h>
\n#include <stdlib.h>
\n#include <string.h>
\n#include <unistd.h>
\n#include <sys\/socket.h>
\n#include <netinet\/in.h>
\n#include <arpa\/inet.h>
\n#include <poll.h><\/p>\n
#define BUFFER_SIZE 1024<\/p>\n
int main(int argc, char *argv[]) {
\n if (argc != 3) {
\n printf("Usage: %s <ip> <port>\\\\n", argv[0]);
\n return 1;
\n }<\/p>\n
int sock = 0;
\n struct sockaddr_in serv_addr;
\n char buffer[BUFFER_SIZE] = {0};
\n struct pollfd fds[2];<\/p>\n
\/\/ \u521b\u5efasocket
\n if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
\n perror("socket creation failed");
\n return -1;
\n }<\/p>\n
serv_addr.sin_family = AF_INET;
\n serv_addr.sin_port = htons(atoi(argv[2]));<\/p>\n
\/\/ \u8f6c\u6362IP\u5730\u5740
\n if (inet_pton(AF_INET, argv[1], &serv_addr.sin_addr) <= 0) {
\n perror("invalid address");
\n return -1;
\n }<\/p>\n
\/\/ \u8fde\u63a5\u670d\u52a1\u5668
\n if (connect(sock, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) {
\n perror("connection failed");
\n return -1;
\n }<\/p>\n
printf("Connected to server\\\\n");<\/p>\n
\/\/ \u8bbe\u7f6epoll\u7ed3\u6784
\n fds[0].fd = STDIN_FILENO; \/\/ \u6807\u51c6\u8f93\u5165
\n fds[0].events = POLLIN;
\n fds[1].fd = sock; \/\/ socket
\n fds[1].events = POLLIN;<\/p>\n
while (1) {
\n int ret = poll(fds, 2, -1); \/\/ \u65e0\u9650\u7b49\u5f85<\/p>\n
if (ret == -1) {
\n perror("poll error");
\n break;
\n }<\/p>\n
\/\/ \u68c0\u67e5\u952e\u76d8\u8f93\u5165
\n if (fds[0].revents & POLLIN) {
\n memset(buffer, 0, BUFFER_SIZE);
\n if (fgets(buffer, BUFFER_SIZE, stdin) == NULL) {
\n break;
\n }
\n \/\/ \u53d1\u9001\u6d88\u606f\u5230\u670d\u52a1\u5668
\n send(sock, buffer, strlen(buffer), 0);
\n }<\/p>\n
\/\/ \u68c0\u67e5\u670d\u52a1\u5668\u6d88\u606f
\n if (fds[1].revents & POLLIN) {
\n memset(buffer, 0, BUFFER_SIZE);
\n int len = recv(sock, buffer, BUFFER_SIZE, 0);
\n if (len <= 0) {
\n printf("Server disconnected\\\\n");
\n break;
\n }
\n printf("Received: %s", buffer);
\n }
\n }<\/p>\n
close(sock);
\n return 0;
\n}<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb808\u6b21\u3002\u5b9e\u73b02\u4e2a\u5ba2\u6237\u7aef\u4e4b\u95f4\u4e92\u76f8\u804a\u5929\u8981\u6c42\uff1a1\u3001\u670d\u52a1\u5668\u4f7f\u7528 select \u6a21\u578b\u5b9e\u73b0\u63a5\u53d7\u591a\u4e2a\u5ba2\u6237\u7aef\u8fde\u63a5\uff0c\u4ee5\u53ca\u8f6c\u53d1\u6d88\u606f2\u3001\u5ba2\u6237\u7aef\u8981\u6c42\uff1a\u4f7f\u7528 poll \u6a21\u578b\u89e3\u51b3 \u6280\u80fd\u591f read \u8bfb\u53d6\u670d\u52a1\u5668\u53d1\u6765\u7684\u6d88\u606f\uff0c\u53c8\u80fd\u591fscanf\u8bfb\u53d6\u952e\u76d8\u8f93\u5165\u7684\u4fe1\u606f3\u3001\u5ba2\u6237\u7aef\u670d\u52a1\u5668\u4e0d\u5141\u8bb8\u5f00\u542f\u989d\u5916\u7ebf\u7a0b\u548c\u8fdb\u7a0b\u3002<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[174,190],"topic":[],"class_list":["post-48534","post","type-post","status-publish","format-standard","hentry","category-server","tag-c","tag-190"],"yoast_head":"\n