多进程socket编程

socket

import socket,os,time
from multiprocessing import Process,Pool
def new_socket(port):
    print(port)
    if not isinstance(port,int):
        exit("not int!")
        pass

    server = socket.socket()
    server.bind(('localhost',port))
    server.listen()
    while True:
        conn, addr = server.accept()
        print("new conn:",addr)
        while True:
            print("等待新指令")
            data = conn.recv(1024)
            if not data:
                print("客户端已断开")
                break
    server.close()
if __name__ == "__main__":
    list = [7050,7051]
    p = Pool(len(list))
    for i in list:
        p.apply_async(new_socket,args=(i,))
    p.close()
    p.join()

可以一次性传入多个port进行监听

谷文杰博客
请先登录后发表评论
  • 最新评论
  • 总共0条评论
  • 本站使用Laravel5.4框架程序搭建 © 2016-2017 guwenjie.freephp.top 版权所有 ICP证:京ICP备17038807号
  • 联系邮箱:guguguwenjie@163.com