linux网络编程学习笔记之三 -----多进程并发服务端

首先是fork()函数，移步APUE 8.3.  比较清晰的解释可以参考http://blog.csdn.net/lingdxuyan/article/details/4993883和http://www.oschina.net/question/195301_62902

补充一点是：fork返回后，原进程中的每个文件或套接口描述符的引用计数加1（相当于被多打开了一次），每调用一次close，引用计数减1，只有当引用计数减到0时才会真正关闭该套接字。

可执行文件被linux执行的唯一方式就是调用exec，把当前进程映像替换成新的程序文件，从该程序的main开始执行。

linux典型做法是，fork之后开始exec，通常用COW技术。

关于僵尸进程

进程在exit()结束后，进程表中任然会保留如进程号、退出状态、运行时间等信息。虽然它已经放弃了内存空间，不能被调度。由于linux对进程数量有限制，过多的僵尸进程将会占用可用进程号，导致新的进程无法生成，所以必须及时地清除。当时我就纳闷了。。。那僵尸进程存在的意义何在？答：保留子进程退出的状态，等待父进程收尸时确定死因。（在父进程中调用各种宏：WEXITSTATUS(status)等）

处理方式：

1、父进程调用wait()或waitpid()来等待子进程结束，当然这会导致父进程挂起

2、如果父进程并不关心子进程何时结束，可以调用signal(SIGCHLD,SIG_IGN)来通知内核，内核会在子进程结束后自动回收。注意：此方法不是可移植的，Stevent在UNP5.9中提到，这个处理并不是POSIX标准，只是在某些系统上可用

3、同样使用异步处理的方式，信号处理函数signal，安装handler来处理SIGCHLD信号。这样，父进程可以在handler中调用wait()进行回收。但是由于相同的信号不排队的原因，要注意处理同时提交的信号，即对同时终止的子进程做处理。UNP5.10详细地讨论了该问题，并给出了安全的方法。

4、通过给信号处理函数设置SA_NOCLDWAIT标志。使调用进程的子进程终止时不创建僵尸进程（APUE10.14）

signala.sa_handler = SIG_IGN;
signala.sa_flags = SA_NOCLDWAIT;
sigemptyset(&signala.sa_mask);
sigaction(SIGCHLD, &signala, NULL);

信号处理：

在此小结下，每个内核的信号，操作系统都有默认的处理方式，比如前面的SIGCHLD，默认是忽略，因此不处理会留下僵尸。我们可以自己定义函数来处理信号，注意SIGKILL和SIGSTOP是不能被捕获和忽略的。

信号处理函数是进程相关的，为全进程所有线程公用。

信号处理函数中，尽量不要使用printf这样的不可重入函数（UNP11.18）

一个信号被信号处理函数响应，在处理过程中，该信号被屏蔽。标准的信号实现没有排队的功能，所以信号可能会被丢失，多个连续的信号来不及处理。如果通过sa_mask设置了信号集，集合中的信号也会被阻塞。

建立信号处理函数的POSIX方法是调用sigaction()，简单些直接调用signal()，虽然它不是POSIX函数，但多数平台用signal()来实现sigaction()，以实现向后兼容。

下面是一个简单的多进程服务端程序：

#include"simon_socket.h"

#define SERV_PORT 12345

extern pid_t waitpid(pid_t, int *, int);

void handler(int signo)
{
	pid_t pid;
	int status;
	while ((pid = waitpid(-1, &status, WNOHANG)) > 0)
	{
		printf("Child process %d terminated\nThe WEXITSTATUS return code is %d \nThe WIFEXITED return code is %d\n", pid, WEXITSTATUS(status), WIFEXITED(status));
	}
}

int main()
{
	int sockfd, acfd;
	struct sockaddr_in client_addr;

	size_t sin_len = sizeof(client_addr);

	sockfd = init_tcp_psock(SERV_PORT);

	signal(SIGCHLD, handler);

/*   another method :
 *
	struct sigaction signala;
	signala.sa_handler = SIG_IGN;
	signala.sa_flags = SA_NOCLDWAIT;
	sigemptyset(&signala.sa_mask);
	sigaction(SIGCHLD, &signala, NULL);
*/	
	while (1)
	{
		if ((acfd = accept(sockfd, (struct sockaddr *)&client_addr, &sin_len)) == -1)
		{
			perror("Accept request failed: ");
			return 1;
		}
		else
			printf("Get a connection from %s:%d !\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));

		pid_t pid;
		if ((pid = fork()) > 0)
		{
			close(acfd);
			continue;
		}
		else if(pid == 0)
		{
			close(sockfd);
			process_client(acfd, &client_addr);
			close(acfd);
			exit(0); 
		}
		else
		{
			perror("Fork error");
			exit(0);
		}
	}
	close(sockfd);
	return 0;
}

代码中一些调用函数的实现，移步我的github：https://github.com/simon-xia/lnp

linux网络编程学习笔记之三 -----多进程并发服务端,古老的榕树,5-wow.com