Unix网络编程——常见服务器模型

常见服务器模型：

UDP循环服务器模型

// UDP循环服务器模型
struct sockaddr_in local_addr,accept_addr;
// 填充local_addr，略
// 使用SOCK_DGRAM调用socket创建UDP套接字
int sockfd = socket(AF_INET,SOCK_DGRAM,0);
bind(sockfd,(struct sockaddr *)&local_addr,sizeof(local_addr));
while(1){
recvfrom(sockfd,buf,sizeof(buf),0,(struct sockaddr*)&accept_addr,&len);
time_t now = time(NULL);
sprintf(buf,"%24s\n",ctime(&now));
sendto(sockfd,buf,strlen(buf),0,(struct sockaddr*)&accept_addr,len);
}

TCP循环服务器模型

// TCP循环服务器模型
int sockfd = socket(AF_INET,SOCK_STREAM,0);
struct sockaddr_in serv_addr,client_addr;
// 填充serv_addr
bind();
listen();
while(1){
int client_fd = accept(sockfd,(struct sockaddr*)&client_addr,&len);
// dosomething
close(client_fd);
}
close(sockfd);

简单的TCP并发服务器模型

// 简单的TCP并发服务器模型
int sockfd = socket(AF_INET,SOCK_STREAM,0);
struct sockaddr_in serv_addr,client_addr;
// 填充serv_addr
bind();
listen();
while(1){
int client_fd = accept(sockfd,(struct sockaddr*)&client_addr,&len);
if(fork() == 0){
// dosomething for request
}
close(client_fd);
}
close(sockfd);

带线程池的TCP并发服务器模型

#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>

pthread_mutex_t alock = PTHREAD_MUTEX_INITITIALIZER;

static void *handle_request(void *argv){
int sockfd = *((int*)argv);
while(1){
pthread_mutex_lock(alock);
client_sock = accept();
pthread_mutex_unlock(alock);
// do something
}
}

static void handle_connect(int sockfd){
pthread_t thread_id[MAX_THREAD_NO];
int i;
for(i = 0;i < MAX_THREAD_NO;++i){
pthread_create(&thread_id[i],NULL,handle_request,(void *)&sockfd);
}
// 等待线程结束
for(i = 0;i < MAX_THREAD_NO;++i)
pthread_join(thread_id[i],NULL);
}

// 简单的TCP并发服务器模型
int main(){
int sockfd = socket(AF_INET,SOCK_STREAM,0);
struct sockaddr_in serv_addr,client_addr;
// 填充serv_addr
bind();
listen();
handle_connect(sockfd);
close(sockfd);
return 0;
}

I/O复用循环式TCP服务器模型