在C語言中,使用socket處理并發(fā)連接通常涉及以下幾個(gè)步驟:
#include <sys/socket.h>
int sockfd = socket(AF_INET, SOCK_STREAM, 0);
struct sockaddr_in server_addr;
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = INADDR_ANY;
server_addr.sin_port = htons(port);
bind(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr));
listen()
函數(shù)來實(shí)現(xiàn)。listen(sockfd, 10);
accept()
函數(shù)來實(shí)現(xiàn)。accept()
函數(shù)會(huì)返回一個(gè)新的socket描述符,用于與客戶端進(jìn)行通信。struct sockaddr_in client_addr;
socklen_t client_addr_len = sizeof(client_addr);
int client_sockfd = accept(sockfd, (struct sockaddr *)&client_addr, &client_addr_len);
send(client_sockfd, "Hello, client!", strlen("Hello, client!"), 0);
char buffer[1024];
recv(client_sockfd, buffer, sizeof(buffer) - 1, 0);
例如,使用多線程處理并發(fā)連接:
#include <pthread.h>
void *handle_client(void *arg) {
int client_sockfd = *(int *)arg;
// 與客戶端通信
}
int main() {
// ... 創(chuàng)建socket、綁定地址和端口、監(jiān)聽連接 ...
while (1) {
int client_sockfd = accept(sockfd, (struct sockaddr *)&client_addr, &client_addr_len);
pthread_t thread;
pthread_create(&thread, NULL, handle_client, &client_sockfd);
pthread_detach(thread);
}
return 0;
}
請注意,這只是一個(gè)簡單的示例,實(shí)際應(yīng)用中可能需要考慮更多因素,例如錯(cuò)誤處理、資源管理和性能優(yōu)化。