# 1，尝试不使用进程池，可否循环创建多个进程并调用
# from multiprocessing import Process
# def func():
#     print("123")
# if __name__ == "__main__":
#     for i in range(10):
#         a1 = Process(target=func)
#         a1.start()
#         a1.join()
# 2，使用UDP协议编写一个局域网聊天程序
# 服务端
# import threading
# from socket import *
# s = socket(AF_INET,SOCK_DGRAM)
# s.bind(("",8888))
# def func():
#     data=("192.168.0.104",8080)
#     while True:
#         data1 = input("请输入\n")
#         s.sendto(data1.encode(),data)
#         if data1 == "886":
#             break
# def func2():
#     while True:
#         global num
#         data2 = s.recvfrom(1024)
#         print(f"消息:{data2[0].decode()}")
#         if data2[0].decode() == "886":
#             break
# a= threading.Thread(target=func)
# a2 = threading.Thread(target=func2)
# a.start()
# a2.start()
# # 客户端
# import threading
# from socket import *
# s = socket(AF_INET,SOCK_DGRAM)
# s.bind(("",8080))
# def func():
#     data=("192.168.0.104",8888)
#     while True:
#         data1 = input("请输入\n")
#         s.sendto(data1.encode(),data)
#         if data1 == "886":
#             break
# def func2():
#     while True:
#         global num
#         data2 = s.recvfrom(1024)
#         print(f"消息:{data2[0].decode()}")
#         if data2[0].decode() == "886":
#             break
# a= threading.Thread(target=func)
# a2 = threading.Thread(target=func2)
# a.start()
# a2.start()

# 3，使用TCP协议编写一个能同时支持多个客户端访问的服务器
# 服务器端
# import socketserver
# class MyServer(socketserver.BaseRequestHandler):
#     def handle(self):
#         while True:
#             data = self.request.recv(1024)
#             print(data)
#             self.request.send(data.upper())
# socketserver.TCPServer.allow_reuse_address=True
# server = socketserver.ThreadingTCPServer(("192.0.0.1",8080),MyServer)
# server.serve_forever()

# 客户端

# from socket import *
# s = socket(AF_INET,SOCK_STREAM)
# s.connect(("192.0.0.1",8080))
# while True:
#     s.send(b"123")
#     data = s.recv(1024)
#     print(data)