如何使用 Python 实现 UDP 通信?

1. UDP通信基础

UDP(用户数据报协议)是一种无连接的传输层协议,它提供了一种不可靠的数据传输服务,但具有较低的延迟和较小的开销。在Python中,可以使用socket模块来实现UDP通信。

2. 实现UDP服务端
import socketdef start_server(host='127.0.0.1', port=65432):"""启动一个UDP服务端:param host: 服务端监听的IP地址,默认为本地回环地址:param port: 服务端监听的端口"""with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s:s.bind((host, port))print(f"Server listening on {host}:{port}")while True:data, addr = s.recvfrom(1024)  # 接收数据和客户端地址print(f"Received from {addr}: {data.decode()}")s.sendto(data, addr)  # 将接收到的数据发送回客户端if __name__ == "__main__":start_server()

代码解释

  • socket.socket(socket.AF_INET, socket.SOCK_DGRAM):创建一个UDP套接字。
  • s.bind((host, port)):绑定IP地址和端口。
  • s.recvfrom(1024):接收数据,最多1024字节,并返回数据和客户端地址。
  • s.sendto(data, addr):将数据发送到指定的客户端地址。
3. 实现UDP客户端
import socketdef start_client(host='127.0.0.1', port=65432):"""启动一个UDP客户端:param host: 服务端的IP地址:param port: 服务端的端口"""with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s:while True:message = input("Enter a message to send: ")s.sendto(message.encode(), (host, port))data, _ = s.recvfrom(1024)  # 接收服务端发送的数据print(f"Received from server: {data.decode()}")if __name__ == "__main__":start_client()

代码解释

  • socket.socket(socket.AF_INET, socket.SOCK_DGRAM):创建一个UDP套接字。
  • s.sendto(message.encode(), (host, port)):发送数据到指定的服务端地址。
  • s.recvfrom(1024):接收服务端发送的数据,并返回数据和服务器地址。
4. 日常开发中的合理化使用建议
  1. 数据完整性:由于UDP是不可靠的,如果需要确保数据的完整性,应在应用层实现重传机制和校验和。
  2. 流量控制:UDP没有内置的流量控制机制,应根据网络状况和应用需求自行实现。
  3. 安全性:对于敏感数据的传输,应考虑使用DTLS(Datagram Transport Layer Security)进行加密。
  4. 广播和组播:UDP支持广播和组播,适用于需要向多个接收者发送数据的场景。
5. 实际开发过程中需要注意的点
  1. 资源管理:确保在通信结束后正确关闭套接字和其他资源,避免资源泄漏。
  2. 数据格式:在发送和接收数据时,应明确数据的格式(如JSON、XML等),并进行相应的序列化和反序列化操作。
  3. 错误处理:捕获和处理可能的异常,如网络错误、数据格式错误等。
  4. 性能优化:根据应用需求,优化数据包的大小和发送频率,以提高通信效率。
6. 错误处理示例
import socketdef start_server(host='127.0.0.1', port=65432):with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s:s.bind((host, port))print(f"Server listening on {host}:{port}")while True:try:data, addr = s.recvfrom(1024)print(f"Received from {addr}: {data.decode()}")s.sendto(data, addr)except Exception as e:print(f"Error: {e}")if __name__ == "__main__":start_server()

代码解释

  • 使用try-except块捕获可能的异常,并打印错误信息。
7. 广播示例
import socketdef start_client(host='255.255.255.255', port=65432):with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s:s.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)  # 启用广播while True:message = input("Enter a message to send: ")s.sendto(message.encode(), (host, port))data, _ = s.recvfrom(1024)print(f"Received from server: {data.decode()}")if __name__ == "__main__":start_client()

代码解释

  • s.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1):启用广播功能。
8. 组播示例
import socketdef start_client(host='224.0.0.1', port=65432):with socket.socket(socket.AF_INET, socket.SOCK_DGRAM) as s:group = socket.inet_aton(host)mreq = group + socket.inet_aton('0.0.0.0')s.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq)  # 加入组播组while True:message = input("Enter a message to send: ")s.sendto(message.encode(), (host, port))data, _ = s.recvfrom(1024)print(f"Received from server: {data.decode()}")if __name__ == "__main__":start_client()

代码解释

  • s.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq):加入指定的组播组。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/63794.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【保姆级】Mac如何安装+切换Java环境

本文从如何下载不同版本的JDK,到如何丝滑的切换JDK,以及常见坑坑的处理方法,应有尽有,各位看官走过路过不要错过~~~ 下载⏬ 首先上官网: https://www.oracle.com/ 打不开的话可以使用下面👇这个中文的 https://www.oracle.com/cn/java/technologies/downloads/a…

Android -- WebView之loadData加载html字符串显示网页

目录 前言1. loadUrl 加载网页地址2. loadData 加载Html字符来显示网页3. loadDataWithBaseURL4. 总结 前言 最近在给一个老项目做64位so文件的适配,当应用发布到应用市场上后,用户反馈64位手机上的网页加载不出内容,但32位的手机上是正常…

WebSocket解读

WebSocket是一种网络通信协议,它允许在单个TCP连接上进行全双工通信,即服务器和客户端可以同时发送和接收数据。这种协议非常适合需要实时数据交换的应用场景,如在线聊天、实时数据更新、协同办公等。 WebSocket的工作原理 握手阶段&#x…

Docker在Ubuntu和CentOS系统下的安装

目录 1. 各版本平台支持情况2. 在Ubuntu系统下安装docker3. 常见报错4. Docker的镜像源修改5. Docker目录修改6. 在CentOS系统下安装docker 1. 各版本平台支持情况 (1)平台支持情况如下: Server 版本 桌面版本 2. 在Ubuntu系统下安装docker…

Ansible-Playbook基础学习

一.Ansible Playbook基本介绍 1.Playbook 介绍 Ansible Playbook 是 Ansible 的核心组件之一,它是一个用于配置管理、应用部署和任务自动化的文本文件,使用 YML格式编写。YML 的语法简洁明了,易于阅读和编写,使得用户可以方便地…

基于PHP课堂签到系统的设计与实现

摘 要 随着教育业的迅速发展和学生人数的不断增加,导致在班级登记制度中传统的“点到”方式不能适应学校的实际需要。从而需要设计一个好的课堂签到系统将会对课堂签到管理工作带来事半功倍的效果。文章着重介绍了基于实践应用的班级签到系统的开发流程&#xff0c…

MTK android12 user版本默认开启root权限,添加su

1、需求 : 客户要求在user版中默认开启root权限,添加su。2、实现: From cc066de135c93975d4a50b71c63447c50065195b Mon Sep 17 00:00:00 2001 From: ***** Date: Wed, 11 Dec 2024 16:33:36 0800 Subject: [PATCH] ?UTF-8?q?[root]user…

openjdk17 jvm加载class文件,解析字段和方法,C++源码展示

##构造方法ClassFileParser,parse_stream解析文件流 ClassFileParser::ClassFileParser(ClassFileStream* stream,Symbol* name,ClassLoaderData* loader_data,const ClassLoadInfo* cl_info,Publicity pub_level,TRAPS) :_stream(stream),_class_name(NULL),_load…

蓝桥杯我来了

最近蓝桥杯报名快要截止了,我们学校开始收费了,我们学校没有校赛,一旦报名缴费就是省赛,虽然一早就在官网上报名了,但是一直在纠结,和家人沟通,和朋友交流,其实只是想寻求外界的支持…

Nginx 缓存那些事儿:原理、配置和最佳实践

Nginx 缓存那些事儿:原理、配置和最佳实践 在当今的互联网世界,网站的访问量和数据处理量不断攀升,如何确保用户能够快速、稳定地访问我们的网站,已经成为每个运维工程师面临的挑战。幸运的是,Nginx 作为一款高性能的…

【智体OS】官方上新发布智体电视:基于rtpc和rttouchpad实现智体电视的手机遥控-可安装任意PC应用用于智体电视

【智体OS】官方上新发布智体电视:基于rtpc和rttouchpad实现智体电视的手机遥控-可安装任意PC应用用于智体电视 dtns.network是一款主要由JavaScript编写的智体世界引擎(内嵌了three.js编辑器的定制版-支持以第一视角浏览3D场馆),…

ES(elasticsearch)整合Spring boot使用实例

1.1通过docker安装es详细教程参考 docker部署elasticsearch(内涵集群部署的compose文件)-CSDN博客 2.1创建MySQL数据库,通过sql命令进行表的创建与数据的写入(sql命令如下) /*Navicat Premium Data TransferSource Server : localSo…

GitHub使用

太久不用GitHub发现自己又有些不会了,突发奇想为何不把每次看到的有指导意义的博客收录一下以便下次查阅呢 如何上传文件夹到GitHub上(配图详解)?_github上傳資料夾-CSDN博客 github上如何删除自己的仓库_github删除仓库-CSDN博…

单独测试 pyautogui 的鼠标点击功能,确保它能够在当前环境中正常工作,鼠标自动点击的录制回放功能

感谢您提供的详细日志信息。根据您的反馈,问题可能出在 pyautogui 没有正确获取鼠标焦点或无法在预期的位置执行点击操作。我们将采取以下步骤来进一步诊断和解决这个问题: 1. **确保 pyautogui 正确执行点击操作**: - 我们将添加更多的调…

保姆级教学 uniapp绘制二维码海报并保存至相册,真机正常展示图片二维码

一、获取二维码 uni.request({url: https://api.weixin.qq.com/wxa/getwxacode?access_token${getStorage("token")},responseType: "arraybuffer",method: "POST",data: {path: "/pages/index/index"},success(res) {// 转换为 Uint…

coco数据集转换SAM2格式

coco是一个大json汇总了所有train的标签 SAM2训练一张图对应一个json标签 import json import os from pycocotools import mask as mask_utils import numpy as np import cv2def poly2mask(points, width, height):points_array np.array(points, dtypenp.int32).reshape(-…

Vue.createApp的对象参数

目录 template 属性 data 属性 methods 属性 疑问 function 函数的两种写法 methods 属性中 this 的指向 总结 Vue 实例是通过 Vue.createApp() 创建的,该函数需要接收一个对象作为参数,该对象可添加 template、data、methods 等属性。 template …

LLM大语言模型私有化部署-OpenEuler22.03SP3上容器化部署Ollama与OpenWebUI

背景 你是不是也有私有化部署大模型的需求?如今有了 Ollama , HuggingFace , ModelScope 等开源平台,我们可以非常方便地搭建一个属于自己的大模型,如果网速给力,真是分分钟~~。简单起见,这篇文…

使用字典进行动态编程

在你的程序中,你想要执行各种计算,例如计算卫星的总数。 此外,当你进行更高级的编程时,你可能会发现你需要从文件或数据库中加载此类信息,而不是直接编码到 Python 中。 为了帮助支持这些场景,Python 使你…

Linux——rootfs根文件系统构建

根文件系统也叫做rootfs FATFS这类的文件系统属于Linux内核的一部分,属于软件代码,所以ROOTFS不等于FATFS。 Linux的根文件系统实际上是一个文件夹或者叫目录,这个目录下会有许多子目录,这些目录中存放许多Linux运行所必须的文件…