客户端与服务端交互的基本流程
- 服务端server
#!/usr/bin/env python# -*- coding;utf-8 -*-import socketsk = socket.socket()sk.bind(("127.0.0.1", 9999))sk.listen(5)while True: conn, address = sk.accept() conn.sendall(bytes("欢迎访问老男孩！",encoding="utf-8")) while True: ret_bytes = conn.recv(1024) ret_str = str(ret_bytes, encoding="utf-8") print(ret_str) if ret_str == "q": break conn.sendall(bytes("答：" + "好！", encoding="utf-8")) - 客户端client
#!/usr/bin/env python# -*- coding;utf-8 -*-import socketobj = socket.socket()obj.connect(("127.0.0.1", 9999))ret_bytes = obj.recv(1024)ret_str = str(ret_bytes, encoding="utf-8")print(ret_str)while True: inp = input("请输入内容：\n 问：") obj.sendall(bytes(inp, encoding="utf-8")) if inp == 'q': break else: ret = str(obj.recv(1024), encoding="utf-8") print(ret)obj.close()
粘包问题解决方案：一个类型文件发送完毕之后进行一次确认信息交互。
- server(粘包)
#!/usr/bin/env python# -*- coding;utf-8 -*-import socketsk = socket.socket()sk.bind(("192.168.1.107", 9999,)) # 传入元组sk.listen(5) # 监听客户端请求，最多有五个客户端请求等待)# 连接，客户端的地址信息（IP,port)while True: conn, address = sk.accept() # accept表示阻塞，等待连接请求 conn.sendall(bytes("欢迎访问老男孩！", encoding="utf-8")) file_size = str(conn.recv(1024), encoding="utf-8") print(file_size) conn.sendall(bytes("开始吧！", encoding="utf-8")) total_size = int(file_size) has_recv = 0 with open("c11.py", "wb") as f: i = 0 while True: if total_size == has_recv: print("接收完毕！") break data = conn.recv(1024) f.write(data) has_recv += len(data)obj.close() - client（粘包）
#!/usr/bin/env python# -*- coding;utf-8 -*-import socketimport osobj = socket.socket()obj.connect(("192.168.1.107", 9999))result_bytes = obj.recv(1024) # 等待发送消息result_str = str(result_bytes, encoding="utf-8")print(result_str)# 发送当前文件大小file_size = os.stat("client(粘包).py").st_sizeprint("文件大小：" + str(file_size))obj.sendall(bytes(str(file_size), encoding="utf-8"))obj.recv(1024)with open("client(粘包).py", "rb") as f: seed_size = 0 for i, line in enumerate(f, 1): obj.sendall(line) seed_size += len(line) if seed_size == file_size: print("发送完毕！")obj.close()
IO多路复用在socket中的运用：针对老用户和新用户，服务器做出不同的响应
- server服务端
#!/usr/bin/env python# -*- coding;utf-8 -*-"""IO多路复用socket实例代码"""import socketimport selectsk1 = socket.socket()sk1.bind(("127.0.0.1", 8001))sk1.listen(5)inputs = [sk1, ]info_sender = []message = {}while True: # select自动监听文件描述符，发生变化则放入r_list列表中 r_list, w_list, e_list = select.select(inputs, info_sender, [], 1) # print("正在监听的对象数量：%d" % len(inputs)) for sk in r_list: # sk 表示每个连接对象 if sk == sk1: # 有新用户建立连接 conn, address = sk.accept() conn.sendall(bytes("hello", encoding="utf-8")) inputs.append(conn) message[conn] = [] else: # 有老用户发送信息 try: date = str(sk.recv(1024), encoding="utf-8") except Exception as e: e_list.append(sk) else: if sk not in info_sender: info_sender.append(sk) message[sk].append(date) for sk in w_list: re = message[sk][0] del message[sk][0] sk.sendall(bytes(re + "hello", encoding="utf-8")) # 给我发送信息的对象，我回复了信息就要把它排除，不然前面有while循环，和for循环，就会不断给对方回复消息！ info_sender.remove(sk) for sk in e_list: inputs.remove(sk) - 客户端client(client1，client2，client3):当用户第一次连接时执行相同的操作，支持多用户与服务器交互，客户端断开连接，服务器不受影响
#!/usr/bin/env python# -*- coding;utf-8 -*-import socketsk1 = socket.socket()sk1.connect(("127.0.0.1", 8001))while True: content1 = str(sk1.recv(1024), encoding="utf-8") a = [] print(content1) while True: inp = input(">>>") if inp == "q": a.append(inp) break else: sk1.sendall(bytes(inp, encoding="utf-8")) content2 = str(sk1.recv(1024), encoding="utf-8") print(content2) if a == ["q"]: breaksk1.close()