Python 笔记02 （网络交互 TCP/UDP）

一 socket网络及差别介绍

TCP（传输控制协议）和UDP（用户数据报协议）是两种常见的互联网传输协议，它们之间有很多区别，包括以下几个主要方面：

1.1 TCP

TCP是传输控制协议，是面向连接的通讯协议（如：打电话），通过三次握手建立连接，通讯完成时四次挥手，一般应用在对安全性、完整性有严格要求的场景,如FTP、SMTP、HTTP等

  1. 优点：TCP 具有高可靠性，确保传输数据的正确性，不出现丢失或乱序
  2. 缺点：TCP相对于UDP速度慢一点，效率低，而且要求系统资源较多，每个连接都会占用系统的CPU、内存等硬件资源

1.2 UDP

UDP是用户数据报协议，是面向无连接的通讯协议（如：发短信）

  1. 优点：UDP速度快、操作简单、要求系统资源较少
  2. 缺点：不可靠，可能会出现丢包、乱序、数据不完整

1.3 TCP 与 UDP 的区别：

  1. 连接 TCP 是面向连接的传输层协议，传输数据前先要建立连接。UDP 是不需要连接，即刻传输数据。
  2. 服务对象 TCP 是一对一的两点服务，即一条连接只有两个端点。UDP 支持一对一、一对多、多对多的交互通信
  3. 可靠性 TCP 是可靠交付数据的，数据可以无差错、不丢失、不重复、按序到达。UDP 是尽最大努力交付，不保证可靠交付数据。
  4. 拥塞控制、流量控制 TCP 有拥塞控制和流量控制机制，保证数据传输的安全性。UDP 则没有，即使网络非常拥堵了，也不会影响 UDP 的发送速率。
  5. 首部开销 TCP 首部长度较长，会有一定的开销，首部在没有使用「选项」字段时是 20 个字节，如果使用了「选项」字段则会变长的。UDP 首部只有 8 个字节，并且是固定不变的，开销较小，对系统资源要求较少。
  6. 实时性 UDP 具有较好的实时性，工作效率比 TCP 协议高。

1.4 应用场景

  1. 由于 TCP 是面向连接，能保证数据 的可靠性交付，因此经常用于：(20/21端口)FTP 文件传输、HTTP / HTTPS(80端口) 、SMTP(简单邮件传送协议)、TELNET(远程终端协议)
  2. 由于 UDP 面向无连接，它可以随时发送数据，再加上UDP本身的处理既简单又高效，因此经常用于：包总量较少的通信，如 DNS 、SNMP、TFTP(简单文件传输协议) 等、视频、音频等多媒体通信、广播通信

1.5 Socket数据传输方式

常用的有两种：

  1. SOCK_STREAM：表示面向连接的数据传输方式。数据可以准确无误地到达另一台计算机，如果损坏或丢失，可以重新发送，但效率相对较慢。常见的 http 协议就使用 SOCK_STREAM 传输数据，因为要确保数据的正确性，否则网页不能正常解析。针对于面向连接的TCP服务应用；
  2. SOCK_DGRAM：表示无连接的数据传输方式。计算机只管传输数据，不作数据校验，如果数据在传输中损坏，或者没有到达另一台计算机，是没有办法补救的。也就是说，数据错了就错了，无法重传。因为 SOCK_DGRAM 所做的校验工作少，所以效率比 SOCK_STREAM 高。对应于无连接的 UDP服务应用。

1.6 服务器端

from socket import *
server = socket(AF_INET, SOCK_DGRAM)
server_host_port = ('127.0.0.1', 6000)   # 服务器的IP地址和端口# 接收数据前绑定端口
server.bind(server_host_port)while True:# 接收数据data = server.recvfrom(1024)# print('data:', data)  # (b'\xe4\xbd\xa0\xe5\xa5\xbd', ('127.0.0.1', 61328))print('访问者:', data[0].decode('utf-8'))  # 你好# print(f'客户端的IP：{data[1][0]}  \n客户端的端口：{data[1][1]}')"""重新发送数据"""send_data = input('客服说：')server.sendto(send_data.encode('utf-8'), data[1])# server.close()

1.7 客户端

from socket import *
client = socket(AF_INET, SOCK_DGRAM)
server_host_port = ('127.0.0.1', 6000)   # 指定数据接收方while True:data = input('访问者：')data = data.encode('utf-8')client.sendto(data, server_host_port)   # 发送数据if data.decode('utf-8') == 'bye':break"""接收返回数据数据"""recv_data = client.recvfrom(1024)print(f"客服说：{recv_data[0].decode('utf-8')}")print('程序关闭')
client.close()

二 UDP协议

udp的交互使用：sendto 和 recvfrom

SOCK_DGRAM：表示无连接的数据传输方式。计算机只管传输数据，不作数据校验，如果数据在传输中损坏，或者没有到达另一台计算机，是没有办法补救的。也就是说，数据错了就错了，无法重传。因为 SOCK_DGRAM 所做的校验工作少，所以效率比 SOCK_STREAM 高。对应于无连接的 UDP服务应用。

2.1 服务器代码

from socket import *
import struct
server_socket = socket(AF_INET, SOCK_DGRAM)host_port = ('localhost', 8888)   # 端口号# 开始监听
server_socket.bind(host_port)# 接收数据
data = server_socket.recvfrom(1024)
print(data, type(data))# 解析操作码
recv_data = data[0]
new_data = struct.unpack('!H', recv_data[:2])
print('客户端请求的操作码：', new_data)# 解析文件名
file_name = recv_data[2:-7].decode('utf-8')
print('客户端请求下载的文件名：', file_name)
server_socket.close()

2.2 客户端代码

from socket import *
import struct
client_socket = socket(AF_INET, SOCK_DGRAM)host_port = ('localhost', 8888)   # 端口号file_name = input('请输入需要上传的文件名：').encode('utf-8')
print('file_name:', file_name, len(file_name))
data = struct.pack('!H%dsb5sb' % len(file_name), 1, file_name, 0, 'octet'.encode('utf-8'), 0)# 发送数据
client_socket.sendto(data, host_port)
client_socket.close()

三 TCP协议

tcp的交互使用：send 和 recv

SOCK_STREAM：表示面向连接的数据传输方式。数据可以准确无误地到达另一台计算机，如果损坏或丢失，可以重新发送，但效率相对较慢。常见的 http 协议就使用 SOCK_STREAM 传输数据，因为要确保数据的正确性，否则网页不能正常解析。针对于面向连接的TCP服务应用；

3.1 TCP服务器代码

from socket import *
import random# 创建SOCKET对象
server_socket = socket(AF_INET, SOCK_STREAM)# 绑定IP和端口
host_port = ('', 6666)   # 不写本机所有
server_socket.bind(host_port)# 设置listen
server_socket.listen(5)while True:# 等待客户端连接client_socket, addr = server_socket.accept()print('客户端已连接，3次握手完成！ ')# print('client_socket:', client_socket)# 接收数据data = client_socket.recv(1024).decode('utf8')print('data:', data)oper_code = data.split(':')[0]  # 操作码recv_data = data.split(':')[1]  # 需要上传和下载的文件if oper_code == '1':  # 下载操作file_read = open(recv_data, 'r', encoding='utf8')data = file_read.read()# 将数据发给客户端client_socket.send(data.encode('utf-8'))file_read.close()elif oper_code == '2':  # 上传操作file_write = open(str(random.randint(1000, 9999)) + '.txt', 'w', encoding='utf-8')file_write.write(recv_data)file_write.close()print('服务器接收完成！')elif oper_code == '0':  # 已退出print(recv_data)

3.2 客户端代码

from socket import *while True:client_socket = socket(AF_INET, SOCK_STREAM)# 指定要连接的IPhost_port = ('127.0.0.1', 6666)# 开始连接服务器client_socket.connect(host_port)choice = eval(input('请选择操作： 0.退出  1.下载  2.上传  \n'))if choice == 1:file_name = input('请输入要下载的文件名：')# 告诉服务器要下载的文件名join_data = (str(choice) + ':' + file_name).encode('utf-8')# 发送数据client_socket.send(join_data)# 接收服务器返回的数据recv_data = client_socket.recv(1024).decode('utf-8')# 写入本地磁盘download = open(file_name, 'w', encoding='utf-8')download.write(recv_data)download.close()print('下载完成')elif choice == 2:  # 上传path_name = input('请输入要上传的文件名：')# 本地读取upload = open(path_name, 'r', encoding='utf-8')upload_data = upload.read()# 拼接数据结构data = (str(choice) + ':' + upload_data).encode('utf-8')# 向服务器发送数据client_socket.send(data)upload.close()print('数据上传成功！')elif choice == 0:# 告诉服务器已退出client_socket.send((str(choice) + ':' + '客户端已退出').encode('utf-8'))breakprint('客户端关闭')

TCP连接时三次握手：

  • 第一次：客户端向服务器端发送连接报文（SYN=1），同时选择一个初始序列号 seq=x，一起发送

  • 第二次：服务器收到报文后向客户端发报文，确认报文为：(ACK=1，SYN=1)，确认号为ack=x+1，同时服务器初始化一个序列号：seq=y，一起发送

  • 第三次：客户端向服务器端发送报文（ACK=1），同时发送：ack=x+1,seq=y+1进行确认

TCP断开时四次挥手：开时四次挥手：

  • 第一次：客户端发送释放报文并停止发送数据（FIN=1），带上序列号 seq=u，客户端进入终止等待状态（FIN-WAIT-1）

  • 第二次：服务器收到报文后释放报文，发出确认报文（ACK=1，ack=u+1），并且带上序列号 seq=v，服务器进入关闭等待状态(CLOSE-WAIT)

  • 第三次：服务器在数据传输完毕后发送连接释放报文（FIN=1，ack=u+1），同时发送序列号：seq=w，服务器进入最后确认状态（LAST-ACK）

  • 第四次：客户端收到释放报文后，向服务器发送报文（ACK=1，ack=w+1），发送序列号 seq=u+1，客户端进入时间等待状态（TIME-WAIT）。服务器接收到报文后直接关闭，客户端需要等2**MSL（最长报文段寿命）后结束

四 使用TCP传输较大的文件

4.1 服务端代码

from socket import *
import struct
server_socket = socket(AF_INET, SOCK_STREAM)  # TCPhost_port = ('', 6666)
server_socket.bind(host_port)server_socket.listen(1024)
# 开始监听
conn_socket, addr = server_socket.accept()
print('查看服务器接收到的请求地址：', addr)# 接收数据
data_header = conn_socket.recv(4)
# 解包
size = struct.unpack('!i', data_header)[0]
print('size:', size)# 将收到的数据上传到磁盘
file = open('a.pptx', 'wb')
recv_size = 0
while recv_size < size:data_pack = conn_socket.recv(1024)recv_size += len(data_pack)file.write(data_pack)file.close()
print('服务器接收完成')
conn_socket.close()
server_socket.close()

4.2 客户端代码

from socket import *
import os.path
import structclient_socket = socket(AF_INET, SOCK_STREAM)
client_socket.connect(('192.168.146.1', 6666))# 发送内容
file_path = './111.pptx'# 获取文件大小
size = os.path.getsize(file_path)
print('size:', size)# 对struct数据进行打包
data = struct.pack('!i', size)
# 发送数据
client_socket.send(data)file = open(file_path, 'rb')
# 循环读取 1024
while True:data_pack = file.read(1024)if not data_pack:breakclient_socket.send(data_pack)   # 直接发client_socket.close()

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

如若内容造成侵权/违法违规/事实不符，请联系一条长河网进行投诉反馈，一经查实，立即删除！

相关文章

Databend 源码阅读：配置管理

Databend 源码阅读：配置管理

作者&#xff1a;尚卓燃&#xff08;PsiACE&#xff09;澳门科技大学在读硕士&#xff0c;Databend 研发工程师实习生 Apache OpenDAL(Incubating) Committer https://github.com/PsiACE 对于 Databend 这样复杂的数据库服务端程序&#xff0c;往往需要支持大量的可配置选项&am…
阅读更多...
k8s安装master节点遇到问题解决

k8s安装master节点遇到问题解决

1、安装k8s-1.19安装文档地址&#xff1a; https://kuboard.cn/install/history-k8s/install-k8s-1.19.x.html 2、按照文档中内容执行完master节点的操作报异常&#xff1a; 在执行&#xff1a; curl -sSL https://kuboard.cn/install-script/v1.19.x/init_master.sh | sh …
阅读更多...
npm安装心得（依赖库Python及node-sass依赖环境）

npm安装心得（依赖库Python及node-sass依赖环境）

在使用vue的开发环境过程中&#xff0c;总会遇到这样哪样的安装或者打包错误&#xff0c; vue运行或打包常见错误如下&#xff1a; 1. npm install时 node-sass npm ERR command failed &#xff08;可能是node.js的版本和node-sass的版本不符&#xff0c;就是卸掉原来的node.…
阅读更多...
[滴水逆向]03-12 pe头字段说明课后作业，输出pe结构

[滴水逆向]03-12 pe头字段说明课后作业，输出pe结构

#include <iostream> #include <windows.h> using namespace std; #pragma warning(disable:4996) //DOC结构 typedef struct _DOC_HEADER {WORD e_magic;WORD e_cblp;WORD e_cp;WORD e_crlc;WORD e_cparhar;WORD e_minalloc;WORD e_maxalloc;WORD e_ss;WO…
阅读更多...
RHCE---Web 服务器

RHCE---Web 服务器

文章目录 目录 文章目录 前言 一.Web服务器概述 网址及HTTP协议概述&#xff1a; HTTP协议请求过程&#xff1a; 二.搭建动态HTTP网页 动态网页概述&#xff1a; 搭建动态的HTTP协议网页&#xff1a; 总结 前言 通过上一个章节的学习了解了时间服务器以及远程连接服务器&a…
阅读更多...
C++中实现雪花算法来在秒级以及毫秒及时间内生成唯一id

C++中实现雪花算法来在秒级以及毫秒及时间内生成唯一id

1、雪花算法原理 雪花算法&#xff08;Snowflake Algorithm&#xff09;是一种用于生成唯一ID的算法&#xff0c;通常用于分布式系统中&#xff0c;以确保生成的ID在整个分布式系统中具有唯一性。它的名称来源于雪花的形状&#xff0c;因为生成的ID通常是64位的整数&#xff0…
阅读更多...
Prometheus-Rules 实战

Prometheus-Rules 实战

文章目录 1 node rules2 nginx rule2.1 Nginx 4xx 错误率太多2.2 Nginx 5xx 错误率太多2.3 Nginx 延迟高 3 mysql rule3.1 MySQL 宕机3.2 实例连接数过多3.3 MySQL高线程运行3.4 MySQL 从服务器 IO 线程没有运行3.5 MySQL 从服务器 SQL 线程没有运行3.6 MySQL复制滞后3.7 慢查询…
阅读更多...
作为SiteGPT替代品，HelpLook的优势是什么？

作为SiteGPT替代品，HelpLook的优势是什么？

在当今快节奏的数字化世界中&#xff0c;企业不断寻求创新方式来简化运营并增强客户体验。由于聊天机器人能够自动化任务、提供快速响应并提供个性化互动&#xff0c;它们在业务运营中的使用变得非常重要。因此&#xff0c;企业越来越意识到像SiteGPT和HelpLook这样高效的聊天机…
阅读更多...
I/O

I/O

IO 流简介 IO 即 Input/Output&#xff0c;输入和输出。数据输入到计算机内存的过程即输入&#xff0c;反之输出到外部存储&#xff08;比如数据库&#xff0c;文件&#xff0c;远程主机&#xff09;的过程即输出。IO 流在 Java 中分为输入流和输出流&#xff0c;而根据数据的…
阅读更多...
Spring事务不生效的场景的解决方案

Spring事务不生效的场景的解决方案

一、前言 在Java Web开发中&#xff0c;使用Spring框架可以大大简化开发人员的工作。其中&#xff0c;事务管理是Spring框架中的一个重要功能&#xff0c;它可以确保多个数据库操作要么全部成功&#xff0c;要么全部失败。但是&#xff0c;在实际开发中&#xff0c;我们可能会…
阅读更多...
基于微信小程序的明星应援小程序设计与实现(源码+lw+部署文档+讲解等)

基于微信小程序的明星应援小程序设计与实现(源码+lw+部署文档+讲解等)

文章目录 前言系统主要功能&#xff1a;具体实现截图论文参考详细视频演示为什么选择我自己的网站自己的小程序&#xff08;小蔡coding&#xff09;有保障的售后福利 代码参考源码获取 前言 &#x1f497;博主介绍&#xff1a;✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计…
阅读更多...
浅谈研发与制造运营双端之间的数字化探索

浅谈研发与制造运营双端之间的数字化探索

一、传统中小型制造企业的发展变革与信息化建设背景 以往&#xff0c;传统的中小型制造企业常以大批量、重复性生产制造为主&#xff0c;依赖于人力设备&#xff0c;通过扩大产能发展壮大&#xff0c;信息化能力弱。伴随市场环境的变化及厂商竞争压力&#xff0c;企业谋生存求…
阅读更多...
【网络八股】TCP八股

【网络八股】TCP八股

网络八股 请简述TCP/IP模型中每层的作用&#xff0c;典型协议和典型设备介绍一下三次握手的过程介绍一下四次挥手的过程必须三次握手吗&#xff0c;两次不行吗&#xff1f;为什么ACK数据包消耗TCP的序号吗三次握手中可以携带应用层数据吗四次挥手时&#xff0c;可以携带应用层数…
阅读更多...
UE蓝图学习(从Unity3D而来)

UE蓝图学习(从Unity3D而来)

一、UE组件对比Unity3D&#xff0c;从Unity3D过渡来学的角度出发&#xff0c;可以理解为在 空物体下放置子物体。UE没有U3D那种可以将组件挂在自身空物体上面。 二、UE 蓝图的情境提示&#xff0c;必须先找到相应的类型&#xff0c;对象对象、事件事件&#xff0c;才能找到相应…
阅读更多...
Vue iconfont-阿里巴巴矢量图标库用法

Vue iconfont-阿里巴巴矢量图标库用法

一、vue使用 选择心仪的图标 加入购物车 点击右上角购物车&#xff0c;点击添加至项目 在资源管理 可以看到我的项目 进入项目设置勾选彩色 点击下载到本地 解压压缩包 在main.js文件内导入css文件 import "/assets/font_icon/iconfont.css"; 使用&#xff1a; 复…
阅读更多...
Hive 数据仓库介绍

Hive 数据仓库介绍

目录 ​编辑 一、Hive 概述 1.1 Hive产生的原因 1.2 Hive是什么&#xff1f; 1.3 Hive 特点 1.4 Hive生态链关系 二、Hive架构 2.1 架构图 2.2 架构组件说明 2.2.1 Interface 2.2.1.1 CLI 2.2.1.2 JDBC/ODBC 2.2.1.3 WebUI 2.2.2 MetaData 2.2.3 MetaStore 2.2…
阅读更多...
postman怎么进行参数化？

postman怎么进行参数化？

一、先准备好参数化数据 &#xff08;参数化数据可以使用Excel或者txt的文件。 注意如果使用的是txt的文件&#xff0c;一定要使用英文的逗号&#xff0c;不然的话会报错&#xff01;&#xff09; 注意&#xff1a;填写好的数据后&#xff0c;保存的时候需要另存为&#xff0c…
阅读更多...
PayPal面经

PayPal面经

文章目录 初战AI Infra团队广泛收集信息&#xff0c;增加对面试相关团队的了解Paypal的AI infra Engineer 极客时间演讲视频&#xff1a;AI在金融应用HR面试首面 zhang chao首先让我介绍自己和项目基础知识出题 lettcode 1and0s 二面 luwen没有让我重复介绍自己那好&#xff0c…
阅读更多...
如何快速重置模型原点

如何快速重置模型原点

1、什么是模型原点&#xff1f; 模型原点是三维建模中的概念&#xff0c;它是指在一个虚拟三维空间中确定的参考点。模型原点通常位于模型的几何中心或基本组件的中心位置。如图所示&#xff1a; 可以看到模型的原点在模型的几何中心 2、模型原点的作用 知道了什么是模型原点&…
阅读更多...
LCR 101. 分割等和子集——力扣——背包问题、动态规矩

LCR 101. 分割等和子集——力扣——背包问题、动态规矩

问题描述 代码展示 class Solution:def canPartition(self, nums: List[int]) -> bool:if len(nums) < 1:return Falsetotal_sum sum(nums)if total_sum % 2 ! 0: # 总和为奇数&#xff0c;无法分成两个相等的子集return Falsetarget_sum total_sum // 2dp [[False]…
阅读更多...
最新文章

Copyright @ 2022~2023