这是父进程的代码import socket import multiprocessing print('你好1111') def server(connection): word = { '你好':'你好,很高兴认识你', '你叫什么名字':'我叫机器人', '再见':'很高兴为您服务' } while True: reception = connection.recv(1024) print('接收到的数据为:{}'.format(reception.decode())) response_data = word.get(reception.decode(),'无相关信息') connection.sendall(response_data.encode()) if __name__ == '__main__': host = ('127.0.0.1',500) s = socket.socket(socket.AF_INET,socket.SOCK_STREAM) s.bind(host) s.listen(1) print('正在监听{}端口'.format(host)) while True: connection = None connection,addr = s.accept() if connection != None: print(f'已被{addr}成功连接') t = multiprocessing.Process(target=server,args=(connection,)) t.start(),请写出由该父进程所创建的子进程的代码
时间: 2023-06-14 17:05:02 浏览: 121
Python多进程编程:深入理解multiprocessing模块
以下是由该父进程所创建的子进程的代码:
```python
import socket
import multiprocessing
def server(connection):
word = {
'你好':'你好,很高兴认识你',
'你叫什么名字':'我叫机器人',
'再见':'很高兴为您服务'
}
while True:
reception = connection.recv(1024)
print('接收到的数据为:{}'.format(reception.decode()))
response_data = word.get(reception.decode(),'无相关信息')
connection.sendall(response_data.encode())
if __name__ == '__main__':
host = ('127.0.0.1',500)
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.bind(host)
s.listen(1)
print('正在监听{}端口'.format(host))
while True:
connection = None
connection,addr = s.accept()
if connection != None:
print(f'已被{addr}成功连接')
t = multiprocessing.Process(target=server,args=(connection,))
t.start()
```
该子进程会接收来自客户端的数据,然后根据不同的信息进行回复,同时会将接收到的数据打印出来。该子进程会一直运行下去,直到被手动终止。
阅读全文