您的位置:首页 > 理论基础 > 计算机网络

实现高并发服务器三种简化模型 线程 进程 IO复用

2016-05-24 18:30 537 查看
知识点:UNIX网络编程第四章, 第五章,第六章

多进程模型:

#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<arpa/inet.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<errno.h>
#include<netinet/in.h>
#define SERV_PORT 3000
#define MAXLINE 1024
void str_echo(int sockfd)
{
ssize_t n;
char buf[MAXLINE];
again:
while( (n= read(sockfd, buf ,MAXLINE)) > 0)
write(sockfd, buf, n);
if(n<0 && errno == EINTR)
goto again;
else if(n<0)
printf("stro_echo:read error\n");
}

void main(void)
{
int lfd, cfd;
struct sockaddr_in serv_addr, clin_addr;
socklen_t clin_len;
char buf[MAXLINE];
pid_t childpid;
lfd = socket(AF_INET, SOCK_STREAM, 0);
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
serv_addr.sin_port = htons(SERV_PORT);
bind(lfd, (struct sockaddr*)&serv_addr, sizeof(serv_addr));
listen(lfd, 128);
for(;;){
clin_len = sizeof(clin_addr);
cfd = accept(lfd,(struct sockaddr*) &clin_addr, &clin_len);
if( (childpid = fork()) == 0){
close(lfd);
str_echo(cfd);
exit(0);
}
close(cfd);
}
}


多线程模型:编译时记得加上 -lpthread

#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<arpa/inet.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<errno.h>
#include<netinet/in.h>
#include<pthread.h>
#define SERV_PORT 3000
#define MAXLINE 1024
static void *str_echo(void *sockfd)
{
ssize_t n;
char buf[MAXLINE];
again:
while( (n= read((int)(sockfd), buf ,MAXLINE)) > 0)
write((int)(sockfd), buf, n);
if(n<0 && errno == EINTR)
goto again;
else if(n<0)
printf("stro_echo:read error\n");
close((int)sockfd);
}

void main(void)
{
int lfd, cfd;
struct sockaddr_in serv_addr, clin_addr;
socklen_t clin_len;
char buf[MAXLINE];
pid_t childpid;
lfd = socket(AF_INET, SOCK_STREAM, 0);
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
serv_addr.sin_port = htons(SERV_PORT);
bind(lfd, (struct sockaddr*)&serv_addr, sizeof(serv_addr));
listen(lfd, 128);
for(;;){
clin_len = sizeof(clin_addr);
cfd = accept(lfd,(struct sockaddr*) &clin_addr, &clin_len);
pthread_t tid;
pthread_create(&tid, NULL, &str_echo,(void *) cfd);
}
close(lfd);
}


IO复用:

因为select和poll都存在很多缺陷,这里选用新的epoll函数来实现。

#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<arpa/inet.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<sys/epoll.h>
#include<errno.h>
#include<netinet/in.h>
#define SERV_PORT 3000
#define MAXLINE 1024
void str_echo(int sockfd)
{
ssize_t n;
char buf[MAXLINE];
again:
while( (n= read(sockfd, buf ,MAXLINE)) > 0)
write(sockfd, buf, n);
if(n<0 && errno == EINTR)
goto again;
else if(n<0)
printf("stro_echo:read error\n");
}
void main(void)
{
int lfd, cfd, efd;
struct sockaddr_in serv_addr, clin_addr;
socklen_t clin_len;
char buf[MAXLINE];
int len, n;
struct epoll_event tep, ep[1024];
lfd = socket(AF_INET, SOCK_STREAM, 0);
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
serv_addr.sin_port = htons(SERV_PORT);
bind(lfd, (struct sockaddr*)&serv_addr, sizeof(serv_addr));
listen(lfd, 128);
efd = epoll_create(1024);
tep.events = EPOLLIN;
tep.data.fd = lfd;
epoll_ctl(efd, EPOLL_CTL_ADD, lfd, &tep);
for(;;){
n = epoll_wait(efd, ep, 1024, -1);
int  i = 0;
for( i =0;i<n;i++){

clin_len = sizeof(clin_addr);
cfd = accept(lfd,(struct sockaddr*) &clin_addr, &clin_len);
str_echo(cfd);
close(cfd);
}
}
close(lfd);
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息