一、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 套接字通信的资料请关注乐虎体育其它相关文章!

python 基于UDP协议套接字通信的实现的更多相关文章

  1. python使用scapy模块实现ARP扫描的过程

    前言上篇文章主要写了利用scapy实现ping扫描,这篇文章主要是利用scapy模块实现内网ARP扫描实现过程上篇文章中介绍了通过scapy来伪造包,那么ARP包的伪造过程这里不再详述,说一工具的简单整体流程1.首先,实现单个IP的ARP包的发送和接收2.其次,实现多进程同时多个ARP包的发送和接收......

  2. Python爬虫scrapy框架Cookie池(微博Cookie池)的使用

    下载代码Cookie池(这里主要是微博登录,也可以自己配置置其他的站点网址)下载代码GitHub:https://github.com/Python3WebSpider/CookiesPool下载安装过后注意看网页下面的相关基础配置和操作!!!!!!!!!!!!!自己的设置主要有下面几步:1、配置其......

  3. pandas groupby分组对象的组内排序解决方案

    问题:根据数据某列进行分组,选择其中另一列大小top-K的的所在行数据解析:求解思路很清晰,即先用groupby对数据进行分组,然后再根据分组后的某一列进行排序,选择排序结果后的top-K结果案例:取一下dataframe中B列各对象中C值最高所在的行df = pd.DataFrame({"......

  4. 用python制作个音乐下载器

    前言某个夜深人静的夜晚,我打开了自己的文件夹,发现了自己写了许多似乎很无聊的代码。于是乎,一个想法油然而生:“生活已经很无聊了,不如再无聊一点叭”。说干就干,那就开一个专题,我们称之为kimol君的无聊小发明。妙…啊~~~直奔主题!本文主题是用python做一个音乐下载器(MusicLover),直......

  5. python中编写函数并调用的知识点总结

    能够调用自己编写的函数,这在很多开发语言中,都会用到一个叫做mian的主函数,这个函数一般都是程序的入口,当程序启动时,首先执行这个函数。在Python中,main函数的主要作用就是你写的模块既可以导入到别的模块中用,也可以在模块本身执行使用。下面就来了解具体使用操作吧。编写简单的函数并调用:def......

  6. python 爬虫

    学习python就一直想做爬虫的东西,还要继续学 理论上的东西一要加强 #!/usr/bin/python#coding=utf-8import urllibimport redef getHtml(url): page = urllib.urlopen(u......

  7. python 窃取摄像头照片的实现示例

    python窃取摄像头照片源码+获取授权码方法+py打包成exe教你用python做一个属于自己的窃取摄像头照片的软件。需要安装python3.5以上版本,在官网下载即可。然后安装库opencv-python,安装方式为打开终端输入命令行。可以在使用pip的时候加参数-i http://pypi.t......

  8. python中openpyxl和xlsxwriter对Excel的操作方法

    前几天,项目中有个小需求:提供Excel的上传下载功能,使用模块:openpyxl 和 xlsxwriter,这里简单记录一下。1.简介Python中操作Excel的库非常多,为开发者提供了多种选择,如:xlrd、 xlwt、xlutils、xlwings、pandas、 win32com、open......

  9. python中lower函数实现方法及用法讲解

    之前小编介绍过python中将字符串小写字符转为大写的upper函数的使用方法(upper函数)。有将小写转为大写的需要,那也有将大写转为小写的情况。本文主要介绍在python中可以将字符串大写自摸转换为小写字母的lower函数。1、lower()转换字符串中所有大写字符为小写2、语法str.low......

  10. Python抓取淘宝IP地址数据

    def fetch(ip):url = 'http://ip.taobao.com/service/getIpInfo.php?ip=' + ipresult = []try:response = urllib.urlopen(url).read()jsondata = json.loads(res......

随机推荐

  1. 改进你的c#代码的5个技巧(四)

    像每一篇文章一样,我会重复几行。我在我的Core i3 CPU、4GB主内存和Windows 7平台上测试了以下代码。如果你在不同的硬件配置或使用不同的平台,那么你的输出可能会随着我的输出屏幕而变化,并且输出可能会根据当前运行的进程而变化。由于所有的点都是性能测试,我已经在发布模式下对它们进行了测试......

  2. C# 两个类的实例之间相同属性的值的复制

    在进行实体转换操作的时候通常需要在对两个实体之间两个属性字段相同的类要进行一个互相的转换,我们要把a对象的所有字段的值都复制给b对象,我们只能用b.属性=a.属性来写,如果属性字段太多的话,就要写很多行复制语句,并且还容易漏掉一些,这个时候可以利用c#的反射来实现复制。1.适用于创建实体的时候从一个......

  3. python爬虫利用代理池更换IP的方法步骤

    0. 前言周日在爬一个国外网站的时候,发现用协程并发请求,并且请求次数太快的时候,会出现对方把我的服务器IP封掉的情况。于是网上找了一下开源的python代理池,这里选择的是star数比较多的proxy_pool1. 安装环境# 安装python虚拟环境, python环境最好为python3.6,......

  4. 关于Vue v-model你需要知道的一切

    v-model是Vue的一个指令,它提供了input和form数据之间或两个组件之间的双向数据绑定。这在Vue开发中是一个简单的概念,但是v-model的真正威力需要一些时间才能理解。到本教程结束时,你将了解v-model的所有不同用例,并学习如何在自己的项目中使用它。准备好了吗?我也是。让我们编写......

  5. java mybatis框架配置详解

    一个框架的使用,必然离不开其中的组件支持。我们在下载完mybatis框架后,因为大部分的内部结构还没有启动,就要手动的对其进行配置。在之前有提到,mybatis框架的作用就有数据库方面的,所以本篇文章带来了数据库和sql方面的配置方法,大家一起往下面看看具体操作。1.配置数据库创建mybatis的配......

  6. Android使用 Coroutine + Retrofit打造简单的HTTP请求库

    基于 kotlin/coroutine/retrofit/jetpack 打造,100来行代码,用法超级简单舒适设置默认Retrofit工厂和全局错误处理程序HttpCall.init(retrofitFactory = {// ...}, errorHandler = { throwable -&......

  7. JavaScript 如何禁止用户保存图片

    场景 在业务需求中不希望用户保存图片,因为是一些供内部使用的图片。 思路 添加事件禁止选择、拖拽、右键(简单的禁止用户保存图片,但无法阻止用户打开控制台查看,或是直接抓包) 将之转换为 canvas(让浏览器认为不是图片以此禁止用户对之进行图片的操作,但无法阻止抓包) 禁止用户使用控......

  8. SQL SERVER 获取拼音简称的函数

    /*创建取拼音首字母函数*/ create function [dbo].[fn_ChineseToSpell](@strChinese varchar(500)='') returns varchar(500) as begin /*函数实现开始*/ de......

  9. Python获取Linux系统内存情况

    [Python]代码import subprocessimport rekeydic = {"MemTotal":"总内存(单位G)","MemFree":"剩余内存(单位G)","MemAvailable&q......

  10. 在nodejs中创建child process

    目录简介child process异步创建进程同步创建进程在nodejs中创建child process简介nodejs的main event loop是单线程的,nodejs本身也维护着Worker Pool用来处理一些耗时的操作,我们还可以通过使用nodejs提供的worker_threads来......