顺着教程1往下走，这个章节我们需要开发支持并发的web服务器，并加入容错处理

首先加入容错处理，建议将socket函数封装在新的wrap_socket.c文件中，并创建他的.h文件，Server端include该文件，重写Server端的部分代码。

wrap_socket.c文件应该是这样的:

#include "wrap_socket.h"

#define MAXLINE 1000

void p_error(char *str) {

printf("%s\n",str);

}

/*==========================*/

/* 这里是所有socket方法的封装*/

/*==========================*/

int Socket(int family,int type,int protocol) {

int socketfd = socket(family, type, protocol);

if(socketfd < 0) {

p_error("socket connect error\n");

return -1;

}

return socketfd;

}

void Bind(int fd, const struct sockaddr *sa, socklen_t len) {

if(bind(fd, sa, len) < 0 )

p_error("bind connect error\n");

}

void Listen(int fd,int backlog_size) {

if(listen(fd, backlog_size) < 0)

p_error("listen client error\n");

}

int Accept(int fd,const struct sockaddr *sa,socklen_t *len) {

int clientfd = accept(fd, sa, len);

if(clientfd < 0)

p_error("can't accept clientserver\n");

return clientfd;

}

void Connect(int fd,const struct sockaddr *sa,socklen_t len) {

if(connect(fd, sa, len) < 0)

p_error("connect to webserver error\n");

}

long Read(int fd, void *buf, size_t len) {

long n;

if((n = read(fd, buf, len)) == -1)

p_error("read error\n");

return n;

}

void Write(int fd, void *buf, size_t len) {

if(write(fd, buf, len) == -1 )

p_error("write error\n");

}

void Close(int fd) {

if(close(fd) == -1)

p_error("close fd error\n");

}

当然他对应的wrap_socket.h应该是这样的:

#ifndef wrap_socket_h

#define wrap_socket_h

#include

#include

#include

//read方法需要的头文件

#include

//socket方法需要的头文件

#include

#include

//htonl 方法需要的头文件

#include

//inet_ntop方法需要的头文件

#include

#include

#include

#include

#include

int Socket(int family,int type,int protocol);

int num_sum(int a,int b);

void Bind(int fd, const struct sockaddr *sa, socklen_t len);

void Listen(int fd,int backlog_size);

int Accept(int fd,const struct sockaddr *sa,socklen_t *len);

void Connect(int fd,const struct sockaddr *sa,socklen_t len);

long Read(int fd, void *buf, size_t len);

void Write(int fd, void *buf, size_t len);

void Close(int fd);

#endif /* wrap_socket_h */

这个时候 需要重写下webserver.c的部分socket文件了

listenfd = Socket(AF_INET, SOCK_STREAM, 0);

//初始化myaddr参数

bzero(&servaddr, sizeof(servaddr)); //结构体清零

//对servaddr 结构体进行赋值

servaddr.sin_family = AF_INET;

servaddr.sin_addr.s_addr = htonl(INADDR_ANY);

servaddr.sin_port = htons(SERV_PORT);

Bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr));

Listen(listenfd, BACKLOGSIZE);

这个时候，跑下程序吧。调下bug，看看能不能顺利运行

接下来我们可以这样尝试，在开启一个Client 与Server交互的时候，再开启另一个Client连接Server，看能不能顺利运行，为什么？

这时候程序要能够支持并发的能力，就需要fork()这个方式，找个简单的例子说明下fork是这样的运行方式的

#include

#include

int main ()

{

pid_t fpid; //fpid表示fork函数返回的值

int count=0;

fpid=fork();

if (fpid < 0)

printf("error in fork!");

else if (fpid == 0) {

printf("i am the child process, my process id is %d/n",getpid());

printf("我是爹的儿子/n");//对某些人来说中文看着更直白。

count++;

}

else {

printf("i am the parent process, my process id is %d/n",getpid());

printf("我是孩子他爹/n");

count++;

}

printf("统计结果是: %d/n",count);

return 0;

}

当然我们这个程序也是要加上这个fork进行并发处理的，话不多说，献上代码

//死循环中进行accept()

while (1) {

cliaddr_len = sizeof(cliaddr);

//accept()函数返回一个connfd描述符

connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &cliaddr_len);

//fork()方法 创建一个跟父进程一摸一样的进程 pid <0 表示fork失败 pid＝＝0表示为子进程 pid>0 为父进程 其pid=getpid();

pid = fork();

if(pid < 0) {

printf("fork error\n");exit(1);

}else if(pid == 0) {

while (1) {

n = Read(connfd, buf, MAXLINE);

if (n == 0) {

printf("the other side has been closed.\n");

break;

}

printf("received from %s at PORT %d,message is %s\n",

inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)),

ntohs(cliaddr.sin_port),buf);

for (i = 0; i < n; i++)

buf[i] = toupper(buf[i]);

write(connfd, buf, n);

}

Close(connfd);

exit(0);

}else {

Close(connfd);

}

}

到此，大家试一试运行下，再开启新的client看看能不能顺利访问,我们还可以通过linux命令查看进程情况

ps -ef | grep webserver

初次启动是这样的

first_start_server.png

然后运行client，并多运行几次，就呃可以看到进程数在增加

second_start_server.png

好了，这个章节关于错误处理以及fork的内容到这了，第3章就开始真正进行web服务器的开发了原文章链接