python 基於UDP協議套接字通信的實現
一、UPD實現單用戶通信
服務端:
''' from socket import * server=socket(AF_INET,SOCK_DGRAM) - 這裡代指的是一種數據報協議,數據報協議指的就是udp協議(補充: 數據報就是自己utp協議中有自己的頭,有自己的數據部分) server.bind('IP', PORT) bytes類型的數據, client_addr = server.recvfrom(1024) - client_addr是一個2元組的形式: 第一個參數是客戶端的IP地址, 第二個參數是客戶端發送數據進程軟件的端口號. server.sendto(bytes類型處理過後的數據, client_addr) server.close() ''' from socket import * server=socket(AF_INET,SOCK_DGRAM) IP_PORT=('127.0.0.1',8123) server.bind(IP_PORT) while True: print("server wait...") data_bytes,client_addr=server.recvfrom(1024) server.sendto(data_bytes.upper(),client_addr) print('data_bytes:', data_bytes) print('client_addr:', client_addr) server.close()
客戶端:
''' from socket import * client=socket(AF_INET,SOCK_DGRAM) client.sendto(bytes類型的數據, ('服務端IP', 服務端端口)) data_bytes, client_addr = client.recvfrom(1024) client.close() ''' import socket client = socket.socket(family=socket.AF_INET, type=socket.SOCK_DGRAM) IP_PORT=('127.0.0.1',8123) while True: msg=input("請輸入要發送的消息》》》").strip() client.sendto(msg.encode("utf-8"),IP_PORT) data_bytes,server_addr=client.recvfrom(1024) print("data_bytes:",data_bytes) print("server_addr:",server_addr) client.close()
- UDP是無鏈接的,先啟動哪一端都不會報錯
- UDP協議是數據報協議,發空的時候也會自帶報頭,因此客戶端輸入空,服務端也能收到
二、UDP普遍無粘包問題
服務端:
import socket server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) # 數據報協議-》udp server.bind(('127.0.0.1', 8084)) data, client_addr = server.recvfrom(1024) # b'hello'==>b'h' print('第一次:', client_addr, data) data, client_addr = server.recvfrom(1024) # b'world' =>b'world' print('第二次:', client_addr, data) # data,client_addr=server.recvfrom(1024) print('第三次:',client_addr,data) server.close()
客戶端
import socket client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) # 數據報協議-》udp client.sendto('hello'.encode('utf-8'), ('127.0.0.1', 8084)) client.sendto('world'.encode('utf-8'), ('127.0.0.1', 8084)) client.sendto(''.encode('utf-8'),('127.0.0.1',8084)) client.close()
- UDP協議一般不用於傳輸大數據
- UDP普遍雖然沒有粘包問題,但是並不能替代TCP,因為UDP協議有一個缺陷:如果發送數據的途中發生數據丟失,則數據就真的丟失瞭,而TCP協議就不會有這種缺陷,因此一般UDP用於一些無關緊要的數據發送,例如QQ、微信聊天等…
三、總結:UDP與TCP的區別
區別一:UDP協議不會因為客戶端發送的數據為空,從而導致客戶端和服務端發生異常。
區別二:UDP協議服務端不會因為客戶端強制斷開連接,從而導致服務端發生異常
- UDP協議叫數據報協議,什麼叫數據報?報就分成頭和數據兩部分, 它是一個完整的整體. 它不是單純的數據
- 舉個例子: 基於UDP協議發送的數據, 每次的發都是一個集裝箱過去,並不是空的,所以,你的數據看起來是空,但是我會在數據報的基礎上,對你的數據進行一個處理,所以說服務端收到的並不是空.
- 數據報的概念: 當客戶端發送的數據雖然是空,但是數據報會以一個集裝箱的樣子給你發送到服務端過去,因此服務端收到的,其實並不是空的數據, 服務端收到的還有客戶端的Ip和端口
四、案例
1、基於UDP協議實現時間格式化服務器
服務端
from socket import * from time import strftime server=socket(AF_INET,SOCK_DGRAM) server.bind(("127.0.0.1",8908)) print("server run...") while True: msg,addr=server.recvfrom(1024) print(f"[{addr[0]}]鏈接成功") if not msg: fmt = "%Y-%m-%d %X" else: fmt=msg.decode("utf-8") time_fmt=strftime(fmt) server.sendto(time_fmt.encode("utf-8"),addr)
客戶端
from socket import * client=socket(AF_INET,SOCK_DGRAM) print("輸入時間格式,返回格式化後的時間") ip_port=("127.0.0.1",8908) while True: inp=input("請輸入時間格式(例:%Y-%m-%d)>>>:").strip() client.sendto(inp.encode("utf-8"),ip_port) date=client.recv(1024) print(date.decode("utf-8"))
2、基於udp協議是實現米聊功能
註意:聊天是客戶端與客戶端進行的聊天,客戶端把數據發送到瞭服務端,再有服務端轉發到客戶端,這樣就是實現瞭客戶端與客戶端之間的的聊天。
需求:基於UDP協議是實現一個多用戶通信,可回多個客戶端的信息, 回完一個緊接著可回下一個, 不需要連接
服務端:
#_*_coding:utf-8_*_ __author__="淘小欣" import socket ip_port = ('127.0.0.1', 8081) UDP_server_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) #買手機 UDP_server_sock.bind(ip_port) print("Server...") while True: ml_msg, addr = UDP_server_sock.recvfrom(1024) print('來自[%s:%s]的一條消息:\033[1;44m%s\033[0m' % (addr[0], addr[1], ml_msg.decode('utf-8'))) back_msg = input('回復消息: ').strip() UDP_server_sock.sendto(back_msg.encode('utf-8'), addr)
客戶端一:
#_*_coding:utf-8_*_ __author__="淘小欣" import socket BUFSIZE=1024 UDP_client_socket=socket.socket(socket.AF_INET,socket.SOCK_DGRAM) MiLiao_name_dic={ "淘小欣":("127.0.0.1",8881), "shawn":("127.0.0.1",8881), "派大星":("127.0.0.1",8881), "派大星的真心話":("127.0.0.1",8881) } while True: ml_name = input('請選擇聊天對象: ').strip() while True: msg = input('請輸入消息,回車發送: ').strip() if msg == 'quit': break if not msg or not ml_name or ml_name not in MiLiao_name_dic: continue UDP_client_socket.sendto(msg.encode('utf-8'), MiLiao_name_dic[ml_name]) back_msg, addr = UDP_client_socket.recvfrom(BUFSIZE) print('來自[%s:%s]的一條消息:\033[1;44m%s\033[0m' % (addr[0], addr[1], back_msg.decode('utf-8'))) UDP_client_socket.close()
客戶端二:
#_*_coding:utf-8_*_ __author__="淘小欣" import socket BUFSIZE=1024 UDP_client_socket=socket.socket(socket.AF_INET,socket.SOCK_DGRAM) MiLiao_name_dic={ "淘小欣":("127.0.0.1",8881), "shawn":("127.0.0.1",8881), "派大星":("127.0.0.1",8881), "派大星的真心話":("127.0.0.1",8881) } while True: ml_name = input('請選擇聊天對象: ').strip() while True: msg = input('請輸入消息,回車發送: ').strip() if msg == 'quit': break if not msg or not ml_name or ml_name not in MiLiao_name_dic: continue UDP_client_socket.sendto(msg.encode('utf-8'), MiLiao_name_dic[ml_name]) back_msg, addr = UDP_client_socket.recvfrom(BUFSIZE) print('來自[%s:%s]的一條消息:\033[1;44m%s\033[0m' % (addr[0], addr[1], back_msg.decode('utf-8'))) UDP_client_socket.close()
以上就是python 基於UDP協議套接字通信的實現的詳細內容,更多關於python 套接字通信的資料請關註WalkonNet其它相關文章!
推薦閱讀:
- Python實現UDP與TCP通信的示例詳解
- python SOCKET編程基礎入門
- Python制作簡易聊天器,搭建UDP網絡通信模型
- 使用python實現UDP通信方式
- python 實現syslog 服務器的詳細過程