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 套接字通信的资料请关注我们其它相关文章!

(0)

相关推荐

  • Python网络编程之TCP与UDP协议套接字用法示例

    本文实例讲述了Python网络编程之TCP与UDP协议套接字用法.分享给大家供大家参考,具体如下: TCP协议 服务器端: #!/usr/bin/env python from socket import * from time import ctime HOST = '' PORT = 21567 BUFSIZ = 1024 ADDR = (HOST, PORT) tcpSerSock = socket(AF_INET, SOCK_STREAM) ##创建服务器TCP套接字 tcpSerSoc

  • python3实现UDP协议的服务器和客户端

    利用Python中的socket模块中的来实现UDP协议,这里写一个简单的服务器和客户端.为了说明网络编程中UDP的应用,这里就不写图形化了,在两台电脑上分别打开UDP的客户端和服务端就可以了. UDP:用户数据报协议,是一个面向无连接的协议.采用该协议不需要两个应用程序先建立连接.UDP协议不提供差错恢复,不能提供数据重传,因此该协议传输数据安全性差. 客户端 python3只能收发二进制数据,需要显式转码 from socket import * host = '192.168.48.128

  • 使用python编写udp协议的ping程序方法

    服务器端 import random from socket import * serverSocket = socket(AF_INET, SOCK_DGRAM)#建立udp协议的socket连接 serverSocket.bind(('', 12000)) while True: rand = random.randint(0, 10)#生成随机数,模拟udp环境下的丢包 message, address = serverSocket.recvfrom(1024)#接收客户端发送的信息,应该

  • Python+Socket实现基于UDP协议的局域网广播功能示例

    本文实例讲述了Python+Socket实现基于UDP协议的局域网广播功能.分享给大家供大家参考,具体如下: 服务器端: # udp_gb_server.py '''服务端(UDP协议局域网广播)''' import socket s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) s.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1) PORT = 1060 network = '<b

  • Python实现基于TCP UDP协议的IPv4 IPv6模式客户端和服务端功能示例

    本文实例讲述了Python实现基于TCP UDP协议的IPv4 IPv6模式客户端和服务端功能.分享给大家供大家参考,具体如下: 由于目前工作的需要,需要在IPv4和IPv6两种网络模式下TCP和UDP的连接,要做到客户端发包,服务端收包. 前几天写了代码,但是把UDP的客户端和服务端使用TCP模式的代码了.今天在公司使用该工具的时候,发现了问题,忘记了UDP不需要验证.疏忽,疏忽.不过刚刚接触编程,可以原谅. 现在在家,已经把代码改好了.经测试可以使用. 先运行客户端: python Mini

  • python实现UDP协议下的文件传输

    本文实例为大家分享了python实现UDP文件传输的具体代码,供大家参考,具体内容如下 UDP协议下文件传输: 服务端 import socket count = 0 s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) server_addr = ('127.0.0.1',9999) s.bind(server_addr) print('Bind UDP on 9999...') while True: if count == 0: data

  • python UDP(udp)协议发送和接收的实例

    需要建立2个文件,一个作为客户端,一个作为服务端 文件一 作为客户端client,文件二作为服务端server udp的特点是不需要建立连接 文件一客户端 #不需要建立连接 import socket #创建socket对象 #SOCK_DGRAM udp模式 s=socket.socket(socket.AF_INET,socket.SOCK_DGRAM) #发送数据 字节 s.sendto("你好".encode(),("169.254.184.146",800

  • python实现简单tftp(基于udp协议)

    本文实例为大家分享了python实现简单tftp的具体代码,供大家参考,具体内容如下 tftp是基于udp的协议 实现简单的tftp,首先要有tftp的协议图. tftp默认接收端口为69,但每次有连接过来后,tftp会随机分配一个端口来专门为这个连接来服务. 操作码:1.上传 2.下载 3.传数据 4.接收确认 5.错误码 tftp服务器简单实现: from threading import Thread from socket import * import struct def uploa

  • python网络编程 使用UDP、TCP协议收发信息详解

    UDP UDP是面向无连接的通讯协议,UDP数据包括目的端口号和源端口号信息,由于通讯不需要连接,所以可以实现广播发送. UDP传输数据时有大小限制,每个被传输的数据报必须限定在64KB之内. UDP是一个不可靠的协议,发送方所发送的数据报并不一定以相同的次序到达接收方. udp通信模型中,在通信开始之前,不需要建立相关的链接,只需要发送数据即可,类似于生活中,"写信". 客户端: from socket import socket,AF_INET,SOCK_DGRAM # 创建套接字

  • python实现的udp协议Server和Client代码实例

    直接上代码:Server端: 复制代码 代码如下: #!/usr/bin/env python # UDP Echo Server -  udpserver.py import socket, traceback host = '' port = 54321 s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) s.bind((hos

随机推荐