基于UDP协议 的socket套接字编程
1.UDP套接字简单示例
1.1服务端
import socketserver = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) # 建立一个UDP协议的服务器 server.bind(("127.0.0.1",8080))while True:data,addr = server.recvfrom(1024)server.sendto(data.upper(),addr)server.close()
1.2客户端
import socketclient = socket.socket(socket.AF_INET,socket.SOCK_DGRAM) # 建立一个UDP协议的客户端while True:msg = input("请输入传输内容:>>").strip()client.sendto(msg.encode("utf8"),("127.0.0.1,8080"))data,addr = client.recvfrom(1024)print(data)client.close()
- UDP是无链接的,先启动那一端都不会报错- UDP协议是数据报协议.发空的时候也会自带报头,因此客户端输入空,服务器也能收到
2.UDP套接字无粘包问题
2.1服务端
import socketserver = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)server.bind(("127.0.0.1",8080))data,addr = server.recvfrom(1024)print("第一次:",data)data,addr = server.recvfrom(1024)print("第二次:",data)server.close()
2.2客户端
import socketclient = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)client.sendto("hello".encode("utf8"),("127.0.0.1",8080))client.sendto("word".encode("utf8"),("127.0.0.1",8080))client.close()
- UDP协议一般不用于传输大数据- UDP套接字虽然没有粘包问题,但是不能代替TCP套接字,因为UDP协议有一个缺陷:如果数据发送途中,数据丢失,则数据就丢失了,而TCP协议不会有这种缺陷,因此一般UDP套接字编程只用于无关紧要的数据发送.例如qq聊天
基于socketserver实现并发的socket编程
"本质是导入socketserver库,重写handle函数,在handle函数中写入传递信息的语句"
1.基于TCP协议
- 基于tcp的套接字,关键就是两个循环,一个链接循环,一个通信循环- socketserver模式中分为两大类:server类(解决链接问题)和request类(解决通信问题)
1.1服务端
import socketserverclass My_socket(socketserver.BaseRequestHandler): # 必须继承括号里面的父类def handle(self): # 必须重写handle方法while True: # 这里包括以下是正常使用的之前的方法去写接收和发送数据try:data = self.request.recv(1024)except Exception:continueif len(data) == 0: # 这一句在linux系统才可以运行breakprint(data)self.request.send(data.upper())if __name__ == '__main__':s = socketserver.ThreadingTCPServer(("192.168.11.30", 8080),My_socket) # 用封装的方法创建一个TCP的服务器s.serve_forever() # 循环连接 封装好的方法,直接拿来使用,就是创建一个线程
- 循环建立连接,每建立一个连接就会启动一个线程 + 调用MyHandler类产生一个对象,调用该对象下的handle方法,专门与刚刚建立好的连接做通信循环.
1.2客户端
- 因为这个封装socket就是对服务器进行创建多线程的操作,所以客户端不需要这个库去改写,只要正常的客户端就欧克啦.
import socketclient = socket.socket()client.connect(("192.168.11.30", 8080))while True:msg = input("请输入消息:").strip()if msg == "q":breakclient.send(msg.encode("utf8"))data = client.recv(1024)print(data)client.close()
2.基于UDP协议
2.1服务端
import socketserverclass My_Udp_server(socketserver.BaseRequestHandler):def handle(self):data = self.request[0]print(f"收到来自{self.client_address}的数据:{data}")self.request[1].sendto(data.upper(),self.client_address) # self.request[1] 是一个对象if __name__ == '__main__':s = socketserver.ThreadingUDPServer(("192.168.11.30", 8080),My_Udp_server) # 创建一个UDP协议的服务器s.serve_forever() # 循环连接,这里学的比较浅的多线程就得使用这个库中封装的这个方法
2.2客户端
import socketclient = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)while True:msg = input('请输入需要传递的信息:').strip()if msg == "q":breakclient.sendto(msg.encode("utf8"),("192.168.11.30", 8080))data = client.recvfrom(1024)print(data)client.close()
