1 使用程序池實現socket 通訊

ftp服務端

#!/usr/bin/python
# -*- coding utf8 -*- 

from multiprocessing import Process,Pool
from socket import *
import os

server=socket(AF_INET,SOCK_STREAM)
server.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
server.bind(('127.0.0.1',8080))
server.listen(5)
def talk(conn,addr):
    print(os.getpid())
    while True:#通訊迴圈
        try:
            msg=conn.recv(1024)
            if not msg:break
            conn.send(msg.upper())
        except Exception:
            break

if __name__ == '__main__':
    pool=Pool()
    res_l=[]
    while True:#連結迴圈

        conn,addr=server.accept()
        print(addr)
        #pool.apply(talk,args=((conn,addr)))    #同步
        res=pool.apply_async(talk, args=((conn, addr)))
        res_l.append(res)

        # p=Process(target=talk,args=((conn,addr)))
        #p.start()
 

#!/usr/bin/python
# -*- coding utf8 -*- 

from multiprocessing import Process
from socket import *
client=socket(AF_INET,SOCK_STREAM)
client.connect(('127.0.0.1',8080))
while True:
    msg=input('msg: ').strip()
    if not msg:continue
    client.send(msg.encode('utf-8'))
    msg2=client.recv(1024)
    print(msg2.decode('utf-8'))
 

可以多開幾個客戶端 然後執行

此示例的cpu_count()為4

啟動了5個客戶端

執行之後呢  第五個客戶端掛起 這時候呢 關閉任意一個客戶端 掛起的客戶端會執行 

在

服務端看到他的pid是關掉的那個 等同於複用了pid

這樣就避免了程序過多