您当前位置：首页 > php开源 > 综合技术 > 1高并发服务器：多进程服务器

1高并发服务器：多进程服务器

来源：程序员人生发布时间：2014-10-10 08:00:00 阅读次数：2387次

1多进程并发服务器

使用多进程并发服务器时要考虑以下几点：

A.父最大文件描述个数（父进程中需要close关闭accept返回的新文件描述符）

B.系统内创建进程个数（和内存大小相关）

C.进程创建过多是否降低整体服务性能（进程调度）

2.案例说明

server.c,代码如下：

#include <stdio.h>

#include <string.h>

#include <netinet/in.h>

#include <arpa/inet.h>

#include <signal.h>

#include <sys/wait.h>

#include <sys/types.h>

#include <arpa/inet.h>

#include <ctype.h>

#include <unistd.h>

#include "wrap.h"

#define MAXLINE 80

#define SERV_PORT 8000

void do_sigchild(int num) {

waitpid(0,NULL,WNOHANG);

}

int main(void) {

struct sockaddr_in servaddr,cliaddr;

socklen_t cliaddr_len;

int listenfd,connfd;

char buf[MAXLINE];

//INET_ADDRSTRLEN是ip地址的最大长度，是系统定义的一个宏

char str[INET_ADDRSTRLEN];

int i,n;

pid_t pid;

struct sigaction newact;

newact.sa_handler = do_sigchild;

sigemptyset(&newact.sa_mask);

newact.sa_flags = 0;

//发信号

sigaction(SIGCHLD,&newact,NULL);

//1.这里建立一个TCP的连接，因为是SOCK_STREAM的，表示的是TCP的

listenfd = Socket(AF_INET,SOCK_STREAM,0);

//将seraddr内容清零

bzero(&servaddr,sizeof(servaddr));

servaddr.sin_family = AF_INET;

servaddr.sin_addr.s_addr = htonl(INADDR_ANY);

servaddr.sin_port = htons(SERV_PORT);

//2.绑定ip地址和端口号

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

//监听，最多的可以是20个

Listen(listenfd,20);

printf("Accepting connections... ");

while(1) {

cliaddr_len = sizeof(cliaddr_len);

//connfd:这里才是后续进程需要用的文件描述符

//listenfd:已经不用里，可以被销毁,这个程序是在子进程里面销毁

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

pid = fork();

if(pid ==0) {

if(pid == 0) {

Close(listenfd);

while(1) {

n = Read(connfd,buf,MAXLINE);

if(n == 0) {

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

break;

}

printf("received from %s at PORT %d ",

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

ntohs(cliaddr.sin_port));

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

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

}

Write(connfd,buf,n);

}

Close(connfd);

return 0;

} else if(pid > 0) {

Close(connfd);

} else {

perr_exit("fork");

}

client.c

#include <stdio.h>

#include <string.h>

#include <unistd.h>

#include <netinet/in.h>

#include <arpa/inet.h>

#include "wrap.h"

#define MAXLINE 80

#define SERV_PORT 8000

int main(int argc,char *argv[]) {

struct sockaddr_in servaddr;

char buf[MAXLINE];

int sockfd,n;

sockfd = Socket(AF_INET,SOCK_STREAM,0);

bzero(&servaddr,sizeof(servaddr));

servaddr.sin_family = AF_INET;

inet_pton(AF_INET,"127.0.0.1",&servaddr.sin_addr.s_addr);

servaddr.sin_port = htons(SERV_PORT);

Connect(sockfd,(struct sockaddr *)&servaddr,sizeof(servaddr));

while(fgets(buf,MAXLINE,stdin) != NULL) {

Write(sockfd,buf,strlen(buf));

n = Read(sockfd,buf,MAXLINE);

if(n == 0) {

生活不易，码农辛苦
如果您觉得本网站对您的学习有所帮助,可以手机扫描二维码进行捐赠
程序员人生

------分隔线----------------------------

上一篇 高效代码管理--本地svn环境搭建

下一篇 Linux特殊权限分析(第二版)

分享到:

------分隔线----------------------------

为码而活

积分：4237

15粉丝

7关注

栏目热点