順著教程1往下走，這個章節(jié)我們需要開發(fā)支持并發(fā)的web服務器，并加入容錯處理
首先加入容錯處理，建議將socket函數(shù)封裝在新的wrap_socket.c文件中结执，并創(chuàng)建他的.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 <stdio.h>
#include <stdlib.h>
#include <string.h>
//read方法需要的頭文件
#include <unistd.h>
//socket方法需要的頭文件
#include <sys/socket.h>
#include <sys/types.h>
//htonl 方法需要的頭文件
#include <netinet/in.h>
//inet_ntop方法需要的頭文件
#include <arpa/inet.h>
#include <unistd.h>
#include <sys/stat.h>
#include <sys/mman.h>
#include <fcntl.h>
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參數(shù)
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交互的時候恃泪，<b>再開啟另一個Client連接Server</b>，看能不能順利運行犀斋，為什么贝乎？
這時候程序要能夠支持并發(fā)的能力，就需要fork()這個方式叽粹，找個簡單的例子說明下fork是這樣的運行方式的
#include <unistd.h>
#include <stdio.h>
int main ()
{
pid_t fpid; //fpid表示fork函數(shù)返回的值
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("統(tǒng)計結果是: %d/n",count);
return 0;
}
當然我們這個程序也是要加上這個fork進行并發(fā)處理的，話不多說虫几，獻上代碼
//死循環(huán)中進行accept()
while (1) {
cliaddr_len = sizeof(cliaddr);
//accept()函數(shù)返回一個connfd描述符
connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &cliaddr_len);
//fork()方法 創(chuàng)建一個跟父進程一摸一樣的進程 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辆脸，并多運行幾次但校，就呃可以看到進程數(shù)在增加
second_start_server.png
好了，這個章節(jié)關于錯誤處理以及fork的內容到這了啡氢，第3章就開始真正進行web服務器的開發(fā)了原文章鏈接
