一个EOFError

oneMelon

python写了一个简易聊天室，server端运行的时候出现了一个EOFError好像不能接受input输入的信息？请问要怎么解决

1. from socket import *
   
2. import multiprocessing as mp
   
3. import os,sys
   
4. 
   
5. # 登录判断
   
6. def do_login(s,user,name,addr):
   
7.     if (name in user)  or  name == '管理员':
   
8.         s.sendto("该用户已存在".encode(),addr)
   
9.         return
   
10.     s.sendto(b'OK',addr)
    
11. 
    
12.     # 通知其他人
    
13.     msg = "\n欢迎 %s 进入聊天室"%name
    
14.     for i in user:
    
15.         s.sendto(msg.encode(),user[i])
    
16.     # 插入用户
    
17.     user[name] = addr
    
18. 
    
19. # 转发聊天消息
    
20. def do_chat(s,user,name,text,banned):
    
21.     if name not in banned:
    
22.         msg = "\n%s 说:%s"%(name,text)
    
23.         for i in user:
    
24.             if i != name:
    
25.                 s.sendto(msg.encode(),user[i])
    
26. 
    
27. # 退出聊天室
    
28. def do_quit(s,user,name):
    
29.     msg = '\n' + name + "退出了聊天室"
    
30.     for i in user:
    
31.         if i == name:
    
32.             s.sendto(b'EXIT',user[i])
    
33.         else:
    
34.             s.sendto(msg.encode(),user[i])
    
35.     # 从字典删除用户
    
36.     del user[name]
    
37. 
    
38. # 禁言功能
    
39. def ban(s,user,name,banned):
    
40.     banned.append(name)
    
41.     for i in name:
    
42.         if i==name:
    
43.             msg = '您已被禁言'
    
44.             s.sendto(msg.encode(),user[i])
    
45. 
    
46. #解除禁言功能
    
47. def release(s,user,name,banned):
    
48.     banned.remove(name)
    
49.     for i in name:
    
50.         if i==name:
    
51.             msg = '您已被解除禁言'
    
52.             s.sendto(msg.encode(),user[i])
    
53. 
    
54. 
    
55. # 接收客户端请求
    
56. def do_parent(s):
    
57.     while True:
    
58.         msg,addr = s.recvfrom(1024)
    
59.         msgList = msg.decode().split(' ')
    
60.         
    
61.         # 区分请求类型
    
62.         if msgList[0] == 'L':
    
63.             do_login(s,user,msgList[1],addr)
    
64.         elif msgList[0] == 'C':
    
65.             do_chat(s,user,msgList[1],\
    
66.                 ' '.join(msgList[2:]),banned)
    
67.         elif msgList[0] == 'Q':
    
68.             do_quit(s,user,msgList[1])
    
69. 
    
70. # 管理员功能
    
71. def do_child(s,addr):
    
72.     while True:
    
73.         msg = input("管理员消息:")
    
74.         if msg[0]=='@':
    
75.             name = msg[1:]
    
76.             ban(s,user,name,banned)
    
77.         elif msg[0]=='#':
    
78.             release(s,user,name,banned)
    
79.         else:
    
80.             msg = 'C 管理员 ' + msg
    
81.             s.sendto(msg.encode(),addr)
    
82. 
    
83. # 创建网络,创建进程,调用功能函数
    
84. def main():
    
85.     # server address
    
86.     ADDR = ('0.0.0.0',8888)
    
87. 
    
88.     # 创建套接字
    
89.     s = socket(AF_INET,SOCK_DGRAM)
    
90.     s.setsockopt(SOL_SOCKET,SO_REUSEADDR,1)
    
91.     s.bind(ADDR)
    
92. 
    
93.     # 创建一个用户字典和一个禁言列表
    
94.     user = mp.Manager().dict()
    
95.     banned = mp.Array('u',[])
    
96.    
    
97.     # 创建一个单独的进程处理管理员喊话功能
    
98.     p1 = mp.Process(target=do_parent,args=(s,))
    
99.     p2 = mp.Process(target=do_child,args=(s,ADDR))
    
100. 
     
101.     p1.start()
     
102.     p2.start()
     
103.     p1.join()
     
104.     p2.join()
     
105. 
     
106. if __name__ == "__main__":
     
107.     main()

复制代码

hrp

子进程输入报错，只能在主进程input

oneMelon

hrp 发表于 2020-1-3 19:21
子进程输入报错，只能在父进程input

手滑点到反对了还取消不了…………你知道怎么修改不

hrp

oneMelon 发表于 2020-1-3 19:25
手滑点到反对了还取消不了…………你知道怎么修改不

不会多进程，坐等大佬