基于UDP協(xié)議的套接字

user datagram protocal 數(shù)據(jù)報(bào)協(xié)議

無雙向通道、自帶報(bào)頭、類似發(fā)短信、不會(huì)粘包

不可靠：數(shù)據(jù)發(fā)送時(shí)，丟就丟了

UDP socket:

服務(wù)端：

import socket server = socket.socket(type=socket.SOCK_DGRAM) # UDP協(xié)議 server.bind(('127.0.0.1', 8080))# 無半連接池概念，不需要listen # 無雙向通道，直接通信循環(huán)while True:data, addr = server.recvfrom(1024) # 直接接受客戶端消息print(data)print(addr)server.sendto(data.decode('utf-8').upper().enco

客戶端：

import socket client = socket.socket(type=socket.SOCK_DGRAM) # 無雙向通道，不需要連接，直接進(jìn)入通信循環(huán) server_address = ('127.0.0.1', 8080) while True:data = input('>>>').strip()client.sendto(data.encode('utf-8'), server_address)server_data, server_addr = client.recvfrom(1024)print(server_data)print(server_addr)

應(yīng)用：簡單版qq

服務(wù)端：

import socketserver = socket.socket(type=socket.SOCK_DGRAM) server.bind(('127.0.0.1', 8080))while True:data, addr = server.recvfrom(1024)print('你收到了一條消息：{0}'.format(data.decode('utf-8')))msg = input('回信：>>>').strip()server.sendto(msg.encode('utf-8'), addr)

客戶端：

import socket client = socket.socket(type=socket.SOCK_DGRAM)server_address = ('127.0.0.1', 8080,) while True:msg = input('輸入你發(fā)送的消息>>>').strip()client.sendto(msg.encode('utf-8'), server_address)data, addr = client.recvfrom(1024)print('服務(wù)器回信：{0}'.format(data.decode('utf-8')))

socketserver模塊

創(chuàng)建基于TCP協(xié)議的套接字：

服務(wù)端

import socketserverclass MyServer(socketserver.BaseRequestHandler):def handle(self):print('服務(wù)端的handler')while True:data = self.request.recv(1024)print(self.client_address)print(data)self.request.send(data.upper())if __name__ == '__main__':# 只要有客戶端連接，就會(huì)自動(dòng)交給handler類中的handle處理server = socketserver.ThreadingTCPServer(('127.0.0.1', 8000), MyServer) #創(chuàng)建一個(gè)基于TCP的對(duì)象server.serve_forever() # 啟動(dòng)該服務(wù)對(duì)象

客戶端：

import socketclient = socket.socket() client.connect(('127.0.0.1', 8000))while True:msg = input('>>>').strip()client.send(msg.encode('utf-8'))data = client.recv(1024)print('客戶端收到的數(shù)據(jù)',data)

創(chuàng)建基于UDP的套接字

服務(wù)端：

import socketserverclass MyServer(socketserver.BaseRequestHandler):def handle(self):# print('來啦 老弟')while True:data,sock = self.requestprint(self.client_address) # 客戶端地址print(data.decode('utf-8'))sock.sendto(data.upper(),self.client_address)if __name__ == '__main__':"""只要有客戶端連接 會(huì)自動(dòng)交給自定義類中的handle方法去處理"""server = socketserver.ThreadingUDPServer(('127.0.0.1',8080),MyServer) # 創(chuàng)建一個(gè)基于TCP的對(duì)象server.serve_forever() # 啟動(dòng)該服務(wù)對(duì)象

客戶端：

import socket import timeclient = socket.socket(type=socket.SOCK_DGRAM) server_address = ('127.0.0.1',8080)while True:client.sendto(b'hello',server_address)data,addr = client.recvfrom(1024)print(data.decode('utf-8'),addr)time.sleep(1)

轉(zhuǎn)載于:https://www.cnblogs.com/KbMan/p/11328821.html

總結(jié)

以上是生活随笔為你收集整理的基于UDP协议的套接字+socketserver模块的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。