linux 多进程 缺点

 

fork有一些副作用，其中最明显的就是重复的文件描述符。比如,socket, 磁盘上的文件，终端（标准输入、输出，错误）或某些其他文件类对象。

 

因为一个进程的fork是一个准确的拷贝，它继承了父进程的所有文件描述符和socket,所以就可能遇到这样一个情况，那就是父进程和子进程对于一个单一的远程主机，都有一个开放的连接.

 

这并不好，有几个原因，如果两个进程都视图通过socket通信，结果就可能混淆。另外一点是，两个进程都要调用 close() ,连接才能真正被关闭。因此，一些协议中，使用关闭socket作为某些操作结束信号的情况会出现问题。除非父进程和子进程都关闭了。

 

这个问题的解决办法是在fork之后，只要进程不用 socket的时候就马上关闭它。

 

 

 

 

#!/usr/bin/env python

#!coding=utf-8

 

"""

forking 服务器

 

多进程服务器

"""

 

import socket ,traceback, os,sys

import time

 

def reap():

    print "in reap"

    """

    处理子进程

    """

    while 1:

        try:

            print "in reap ,pid=%s"%(getpid())

            result = os.waitpid(-1 , os.WNOHANG)  # -1 表示等待所有的子进程结束，作用相当于调用wait ,WNOHANG表示不使父进程挂起，而立即返回

            print "000000000000000"

 

            if not result[0]:

                break

        except:

            break

 

        print "reaped child process %d" % result[0]

 

 

 

def getpid():

    return os.getpid()

 

host=''

port=9002

 

s =socket.socket(socket.AF_INET, socket.SOCK_STREAM)

 

s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

 

s.bind((host, port))

 

s.listen(1)

 

 

print "parent at %d listening for connection" % getpid()

 

if __name__ == "__main__":

    while 1:

        try:

            print "accept , pid= %s"%(getpid())

            clientsock , clientaddr = s.accept()

            print "start accpet"

        except KeyboardInterrupt:

            raise

        except:

            traceback.print_exc()

            continue

 

        #reap()

 

        pid = os.fork()

        print "*****************"

 

        if pid:

            #子父进程中

            #this is the parent process .close the child's socket

            print "in parent socket"+str(clientsock)

            print "in parent port=%s"%str(port)

            print "in parent s=%s"%str(s)

 

            """

            这里为什么要关闭clientsock呢，这里解释（this is the parent process .close the child's socket）

            关闭的是子线程的socket，我觉得是写错了，

            应该关闭的是父进程的client的socket连接，因为这里是在父进程里面，这里为什么要关闭呢，

            因为多进程是， 子进程会复制父进程的数据，那么这样clientsocket,就会存在2次饮用（父进程一个，

            子进程一个) ，如果每创建一次子进程都增加一次引用的话，这样就会消耗系统的资源，所以这里应该关闭

            """

            clientsock.close()

            #s.close()

            print "in parent socket"+str(clientsock)

            continue

        else:

            #在子进程中

            #from here on . this is child

            #clientsock.close()

            print "in child socket"+str(clientsock)

            print "in child port=%s"%str(port)

            print "in child s=%s"%str(s)

 

            """

            子进程里面也有s， 父进程也有s，如果这时候，客户端有连接的话，就有可能出现混乱的情况，所以这里选择关闭

            子进程的s

            """

            s.close()

 

 

 

        #process the connection

        try:

            print "child from %s being handled bu pid %d"%\

            (clientsock.getpeername(), os.getpid())

 

        #不停的循环接收数据

            while 1:

                data = clientsock.recv(4096)

                print str(data) + " , pid = %s"%(getpid())

                if not len(data):

                    break

                clientsock.sendall(data)

        except(KeyboardInterrupt, SystemExit):

            raise

        except:

            traceback.print_exc()

 

 

    #close the connection

        try:

            print "断开连接 ,pid=%s"%(getpid())

            clientsock.close()

        except KeyboardInterrupt:

            raise

        except:

            traceback.print_exc()

 

        print "进程结束,pid=%s"%(getpid())

        sys.exit(0)