Python入门【TCP建立连接的三次握手、 TCP断开连接的四次挥手、套接字编程实战、 TCP编程的实现、TCP双向持续通信】(二十七)

👏作者简介:大家好,我是爱敲代码的小王,CSDN博客博主,Python小白
📕系列专栏:python入门到实战、Python爬虫开发、Python办公自动化、Python数据分析、Python前后端开发
📧如果文章知识点有错误的地方,请指正!和大家一起学习,一起进步👀
🔥如果感觉博主的文章还不错的话,请👍三连支持👍一下博主哦
🍂博主正在努力完成2023计划中:以梦为马,扬帆起航,2023追梦人

🔥🔥🔥 python入门到实战专栏:从入门到实战 

🔥🔥🔥 Python爬虫开发专栏:从入门到实战

🔥🔥🔥 Python办公自动化专栏:从入门到实战

🔥🔥🔥 Python数据分析专栏:从入门到实战

🔥🔥🔥 Python前后端开发专栏:从入门到实战

目录

TCP建立连接的三次握手

 TCP断开连接的四次挥手

 数据包与处理流程

 数据包处理流程

 套接字编程实战

 UDP编程介绍

 UDP编程的实现

持续通信

TCP编程介绍

 TCP编程的实现

TCP双向持续通信

 结合多线程实现TCP双向传送(自由聊天)


TCP建立连接的三次握手

 TCP是面向连接的协议,也就是说,在收发数据前,必须和对方建立可靠的连接。 一个TCP连接必须要经过三次“对话”才能建立起来,其中的过程非常复杂, 只简单的描述下这三次对话的简单过 程:

1)主机A向主机B发出连接请求:“我想给你发数据,可以吗?”,这是第一次对话;

2)主机B向主机A发送同意连接和要求同步 (同步就是两台主机一个在发送,一个在接收,协调工作)的数据包 :“可以,你什么时候 发?”,这是第二次对话;

3)主机A再发出一个数据包确认主机B的要求同步:“我现在就发, 你接着吧!”, 这是第三次握手。 三次“对话”的目的是使数据包的发送和接收同步, 经过三次“对话” 之后,主机A才向主机B正式发送数据。

 

 

 1、第一步,客户端发送一个包含SYN即同步(Synchronize)标志的TCP报文,SYN同步报文会指明客户端使用的端口以及TCP连接的初始序号。

2、第二步,服务器在收到客户端的SYN报文后,将返回一个SYN+ACK的报文,表示客户端的请求被接受,同时TCP序号被加一,ACK即确认(Acknowledgement)

3、第三步,客户端也返回一个确认报文ACK给服务器端,同样TCP序列号被加一,到此一个TCP连接完成。然后才开始通信的第二步:数据处理。

这就是所说的TCP的三次握手(Three-way Handshake)。

 为什么TCP协议有三次握手,而UDP协议没有?

    因为三次握手的目的是在client端和server端建立可靠的连接。保证双方发送的数据对方都能接受到,这也是TCP协议的被称为可靠的数据传输协议的原因。而UDP就不一样,UDP不提供可靠的传输模式,发送端并不需要得到接收端的状态,因此 UDP协议就用不着使用三次握手。

 TCP断开连接的四次挥手

 TCP建立连接要进行3次握手,而断开连接要进行4次:

第一次: 当主机A完成数据传输后,将控制位FIN置1,提出停止TCP连接的请求 ;

第二次: 主机B收到FIN后对其作出响应,确认这一方向上的TCP连接将关闭,将ACK置1;

第三次: 由B 端再提出反方向的关闭请求,将FIN置1 ;

第四次: 主机A对主机B的请求进行确认,将ACK置1,双方向的关闭结束.。

 由TCP的三次握手和四次断开可以看出,TCP使用面向连接的通信方式, 大大提高了数据通信的可靠性,使发送数据端和接收端在数据正式传输前就有了交互, 为数据正式传输打下了可靠的基础。

 数据包与处理流程

什么是数据包

通信传输中的数据单位,一般也称“数据包”。在数据包中包括: 包、帧、数据包、段、消息。

网络中传输的数据包由两部分组成:一部分是协议所要用到的首部,另一部分是上一层传过来的数据。首部的结构由协议的具体规范详细定义。在数据包的首部,明确标明了协议应该如何读取数 据。反过来说,看到首部,也就能够了解该协议必要的信息以及所要处理的数据。包首部就像协议的脸。

 

 数据包处理流程

 套接字编程实战

socket编程介绍

TCP协议和UDP协议是传输层的两种协议。Socket是传输层供给应用层的编程接口,所以Socket编程就分为TCP编程和UDP编程两类。

 Socket编程封装了常见的TCP、UDP操作,可以实现非常方便的网络编程。

 socket()函数介绍

在Python语言标准库中,通过使用socket模块提供的socket对象, 可以在计算机网络中建立可以互相通信的服务器与客户端。在服务器端需要建立一个socket对象,并等待客户端的连接。客户端使用socket对象与服务器端进行连接,一旦连接成功,客户端和服务器端就可以进行通信了。

 ⚠️上图中,我们可以看出socket通讯中,发送和接收数据,都是通过操作系统控制网卡来进行。因此,我们在使用之后,必须关闭socket。

 在Python 中,通常用一个Socket表示“打开了一个网络连接”,语法格式如下:

socket.socket([family[, type[, proto]]])

family : 套接字家族可以使 AF_UNIX 或者 AF_INET

AF 表示ADDRESS FAMILY 地址族

AF_INET(又称 PF_INET)是 IPv4 网络协议的套接字类型;而 AF_UNIX 则是 Unix 系统本地通信

 type : 套接字类型可以根据是面向连接的还是非连接分为 SOCK_STREAM SOCK_DGRAMprotocol : 一般不填,默认为0。

Socket主要分为面向连接的Socket和无连接的Socket。 无连接Socket的主要协议是用户数据报协议,也就是常说的UDP, UDP Socket的名字是 SOCK_DGRAM 。创建套接字UDP/IP套接字,可以 调用 socket.socket() 。示例代码如下: udpSocket=socket.socket (AF_INET,SOCK_DGRAM)

 socket对象的内置函数和属性

在Python语言中socket对象中,提供如表所示的内置函数。

 

 UDP编程介绍

UDP协议时,不需要建立连接,只需要知道对方的IP地址和端口 号,就可以直接发数据包。但是,能不能到达就不知道了。虽然用 UDP传输数据不可靠,但它的优点是和TCP比,速度快,对于不要求可靠到达的数据,就可以使用UDP协议。

创建Socket时, SOCK_DGRAM 指定了这个Socket的类型是UDP。绑定端口和TCP一样,但是不需要调用 listen() 方法,而是直接接收来自任何客户端的数据。 recvfrom() 方法返回数据和客户端的地址与端口,这样,服务器收到数据后,直接调用 sendto() 就可以把数据用UDP发给客户端。

 UDP编程的实现

【示例】UDP接收数据

#coding=utf-8
from socket import *
s = socket(AF_INET, SOCK_DGRAM) #创建套接字
#绑定接收信息端口
s.bind(('127.0.0.1', 8888))  #绑定一个端口,ip地址和端⼝号
print("等待接收数据!")
redata = s.recvfrom(1024)  #1024表示本次接收的最⼤字节数
print(redata)
print(f'收到远程信息:{redata[0].decode("gbk")}, from {redata[1]}')
s.close()

【示例】UDP发送数据

from socket import *
s = socket(AF_INET, SOCK_DGRAM) #创建套接字
addr = ('127.0.0.1', 8888) #准备接收方地址
data = input("请输入:")
#发送数据时,python3需要将字符串转成byte
s.sendto(data.encode('gbk'),addr) #默认的网络助手使用的编码是gbk
s.close()

持续通信

【示例】UDP接收数据

#coding=utf-8
from socket import *
s = socket(AF_INET,SOCK_DGRAM)  #创建UDP类型的套接字
s.bind(("127.0.0.1",8888))  #绑定端口,ip可以不写
print("等待接收数据!")
while True:recv_data = s.recvfrom(1024)    #1024表示本次接收的最大字节数recv_content = recv_data[0].decode('gbk')print(f"收到远程信息:{recv_content},from {recv_data[1]}")if recv_content == "88":print("结束聊天!")break
s.close()

【示例】UDP发送数据

#coding=utf-8
from socket import *
s = socket(AF_INET,SOCK_DGRAM)  #创建UDP类型的套接字
addr = ("127.0.0.1",8888)
while True:data = input("请输入:")s.sendto(data.encode("gbk"),addr)if data == "88":print("结束聊天!")break
s.close()

结合多线程实现UDP双向自由通信

UDP 不同于 TCP,不存在请求连接和受理过程,因此在某种意义上无法明确区分服务器端和客户端,只是因为其提供服务而称为服务器端。

 如下服务端、客户端代码几乎一模一样,注意接收和发送端口对应,即可。

 【示例】UDP实现多线程服务端

#coding=utf-8
from socket import *
from threading import Thread
udp_socket=socket(AF_INET,SOCK_DGRAM)
#绑定接收信息端口
udp_socket.bind(('127.0.0.1',8989))
#不停接收
def recv_data():while True:redata = udp_socket.recvfrom(1024)print(f'收到信息: {redata[0].decode("gbk")}, from {redata[1]}')
#不停发送
def send_data():while True:data=input('输入信息:')addr=('127.0.0.1',8080)udp_socket.sendto(data.encode('gbk'),addr)
if __name__=='__main__':# 创建两个线程t1=Thread(target=send_data)t2=Thread(target=recv_data)t2.start()t1.start()t1.join()t2.join()

【示例】UDP实现多线程客户端

#coding=utf-8
from socket import *
from threading import Thread
udp_socket=socket(AF_INET,SOCK_DGRAM)
#绑定接收信息端口
udp_socket.bind(('127.0.0.1',8080))
#不停接收
def recv_data():while True:redata = udp_socket.recvfrom(1024)print(f'收到信息: {redata[0].decode("gbk")}, from {redata[1]}')
#不停发送
def send_data():while True:data=input('输入信息:')addr=('127.0.0.1',8989)udp_socket.sendto(data.encode('gbk'),addr)
if __name__=='__main__':# 创建两个线程t1=Thread(target=send_data)t2=Thread(target=recv_data)t2.start()t1.start()t1.join()t2.join()

TCP编程介绍

面向连接的Socket使用的协议是TCP协议。TCP的Socket名称是 SOCK_STREAM 。创建套接字TCP套接字,可以调用 socket.socket() 。示例代码如下:

tcpSocket=socket.socket(AF_INET,SOCK_STREAM)

 TCP编程的实现

在Python语言中创建Socket服务端程序,需要使用socket模块中的 socket类。创建Socket服务器程序的步骤如下:

(1) 创建Socket对象。

(2) 绑定端口号。

(3) 监听端口号。

(4) 等待客户端Socket的连接。

(5) 读取客户端发送过来的数据。

(6) 向客户端发送数据。

(7) 关闭客户端Socket连接。

(8) 关闭服务端Socket连接。

 【示例】TCP服务器端接收数据

#coding=utf-8
from socket import *
server_socket = socket(AF_INET, SOCK_STREAM)
server_socket.bind(("", 8899))
server_socket.listen(5)
client_socket, client_info =
server_socket.accept()
#clientSocket 表示这个新的客户端
#clientInfo 表示这个新的客户端的ip以及port
recv_data = client_socket.recv(1024)
print(f"收到信息:{recv_data.decode('gbk')},来自:{client_info}")
client_socket.close()
server_socket.close()

【示例】TCP客户端发送数据到服务端

#coding=utf-8
from socket import *
client_socket = socket(AF_INET, SOCK_STREAM)
client_socket.connect(("127.0.0.1", 8899))
#注意:
# 1. tcp客户端已经链接好了服务器,所以在以后的数据发
送中,不需要填写对方的ip和port----->打电话
# 2. udp在发送数据的时候,因为没有之前的链接,所以需
要在每次的发送中,都要填写接收方的ip和port----->写信 
client_socket.send("haha".encode("gbk"))
client_socket.close()

TCP双向持续通信

【示例】TCP:双向通信Socket之服务器端

#coding=utf-8
'''
双向通信Socket之服务器端读取客户端发送的数据,将内容输出到控制台将控制台输入的信息发送给客户器端
'''
#导入socket模块
from socket import *
#创建Socket对象
tcp_server_socket=socket(AF_INET,SOCK_STREAM)
#绑定端口
tcp_server_socket.bind(('', 8888))
#监听客户端的连接
tcp_server_socket.listen()
print("服务端已经启动,等待客户端连接!")
#接收客户端连接
tcp_client_socket,
host=tcp_server_socket.accept()
print("一个客户端建立连接成功!")
while True:#读取客户端的消息re_data=tcp_client_socket.recv(1024).decode('gbk')#将消息输出到控制台print('客户端说:',re_data)if re_data=='end':break#获取控制台信息msg=input('>')tcp_client_socket.send(msg.encode('gbk'))
tcp_client_socket.close()
tcp_server_socket.close()

【示例】TCP:双向通信Socket之客户端

#coding=utf-8
'''
双向通信Socket之客户端将控制台输入的信息发送给服务器端读取服务器端的数据,将内容输出到控制台
'''
#导入socket模块
from socket import *
#创建客户端Socket对象
tcp_client_socket=socket(AF_INET,SOCK_STREAM)
#连接服务器端
tcp_client_socket.connect(('127.0.0.1',8888))
while True:msg=input('>')#向服务器发送数据tcp_client_socket.send(msg.encode('gbk'))if msg=='end':break#接收服务器端数据re_data=tcp_client_socket.recv(1024)print('服务器端说:',re_data.decode('gbk'))
tcp_client_socket.close()

首先运行示例启动服务器端程序,然后运行示例客户端程序。执行结果如下图所示:

 

 结合多线程实现TCP双向传送(自由聊天)

【示例】TCP服务端结合多线程实现自由收发信息

#coding=utf-8
'''
双向通信Socket之服务器端读取客户端发送的数据,将内容输出到控制台将控制台输入的信息发送给客户器端
'''
#导入socket模块
from socket import *
from threading import Thread
def recv_data():while True:# 读取客户端的消息re_data =
tcp_client_socket.recv(1024).decode('gbk')# 将消息输出到控制台print(f'客户端说:{re_data}')if re_data == 'end':break
def send_data():while True:# 获取控制台信息msg = input('>')tcp_client_socket.send(msg.encode('gbk'))
if __name__ == '__main__':# 创建Socket对象tcp_server_socket = socket(AF_INET,SOCK_STREAM)# 绑定端口tcp_server_socket.bind(('', 8888))# 监听客户端的连接tcp_server_socket.listen()print("服务端已经启动,等待客户端连接!")# 接收客户端连接tcp_client_socket, host = tcp_server_socket.accept()print("一个客户端建立连接成功!")t1 = Thread(target=recv_data)t2 = Thread(target=send_data)t1.start()t2.start()t1.join()t2.join()tcp_client_socket.close()tcp_server_socket.close()

【示例】TCP客户端结合多线程实现自由收发信息

#coding=utf-8
'''
双向通信Socket之客户端将控制台输入的信息发送给服务器端读取服务器端的数据,将内容输出到控制台
'''
#导入socket模块
from socket import *
from threading import Thread
def recv_data():while True:# 接收服务器端数据re_data = tcp_client_socket.recv(1024)print(f'\n服务器端说: {re_data.decode("gbk")}')
def send_data():while True:msg = input('>')# 向服务器发送数据tcp_client_socket.send(msg.encode('gbk'))if msg == 'end':break
if __name__ == '__main__':# 创建客户端Socket对象tcp_client_socket = socket(AF_INET,SOCK_STREAM)# 连接服务器端tcp_client_socket.connect(('127.0.0.1',8888))t1 = Thread(target=recv_data)t2 = Thread(target=send_data)t1.start()t2.start()t1.join()t2.join()tcp_client_socket.close()

关于http协议和服务器的授课顺序说明

由于大家还没有学习网页内容,考虑到更好的和实战结合。 所以,在讲服务器编程时,详细展开。

 

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

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

相关文章

【c语言】通讯录(动态版+文件+背景音乐)含源码

开饭了,之前写的通讯录,是否会有人觉得申请1000人的空间是不是有点用不上呀,怎么才能做到要多少申请多少个呢??我们学完动态内存管理,和文件的相关操作,终于可以继续完善我们的通讯录了 船新版本…

数据结构:二叉树的递归实现(C实现)

个人主页 : 个人主页 个人专栏 : 《数据结构》 《C语言》 文章目录 前言一、树的概念二、二叉树二叉树的概念二叉树的性质 三、二叉树链式结构实现二叉树节点定义创建二叉树节点遍历二叉树先序遍历二叉树(BinaryTreePrevOrder)中序遍历二叉树(BinaryTree…

Air780EG —— 合宙4G定位解决方案

定位模式: 外部单片机控制模式(常见于AT固件客户): 开机 -> 搜星 -> 定位成功 -> 上报 -> 关机 780E自行控制模式(常见于二次开发客户,AT用户也可以使用): 开机 -> 搜星 -> 定位成功 -> 模块休眠,关闭GP…

亿发创新中医药信息化解决方案,自动化煎煮+调剂,打造智能中药房

传统中医药行业逐步复兴,同时互联网科技和人工智能等信息科技助力中医药行业逐步实现数字化转型。利用互联网、物联网、大数据等科技,实现现代科学与传统中医药的结合,提供智能配方颗粒调配系统、中药自动化调剂系统、中药煎配智能管理系统、…

如何切换goland之中的版本号(升级go 到1.20)

go 安装/版本切换_go 切换版本_云满笔记的博客-CSDN博客 用brew就行: echo export PATH"/opt/homebrew/opt/go1.20/bin:$PATH" >> ~/.zshrc

Linux6.40 Kubernetes 配置资源管理

文章目录 计算机系统5G云计算第三章 LINUX Kubernetes 配置资源管理一、Secret1.Secret 四种类型1)kubernetes.io/service-account-token2)Opaque3)kubernetes.io/dockerconfigjson4)kubernetes.io/tls 2.Pod 需要先引用才能使用某…

React入门 jsx学习笔记

一、JSX介绍 概念:JSX是 JavaScript XML(HTML)的缩写,表示在 JS 代码中书写 HTML 结构 作用:在React中创建HTML结构(页面UI结构) 优势: 采用类似于HTML的语法,降低学…

因果推断(四)断点回归(RD)

因果推断(四)断点回归(RD) 在传统的因果推断方法中,有一种方法可以控制观察到的混杂因素和未观察到的混杂因素,这就是断点回归,因为它只需要观察干预两侧的数据,是否存在明显的断点…

【C++入门到精通】C++入门 —— list (STL)

阅读导航 前言一、list简介1.概念2.特点 二、list的使用1.list的构造2.常见的操作⭕std::list类型的增、删、查、改 三、list与vector的对比温馨提示 前言 文章绑定了VS平台下std::list的源码,大家可以下载了解一下😍 前面我们讲了C语言的基础知识&…

C语言实例_获取文件MD5值

一、MD5介绍 MD5(Message Digest Algorithm 5)是一种常用的哈希函数算法。将任意长度的数据作为输入,并生成一个唯一的、固定长度(通常是128位)的哈希值,称为MD5值。MD5算法以其高度可靠性和广泛应用而闻名…

全球磁强计市场价值约为16.2亿美元,预测期内将以超过5.21%的增长率增长

磁强计是一种用于测量磁场强度和方向的仪器。它可以检测和测量地球磁场、物体的磁性、地下矿藏、磁性材料等。磁强计在地球科学、物理学、地质学、勘探、矿业等领域具有广泛的应用。 根据阿谱尔(APO)的统计及预测,2022年全球磁强计市场价值约…

ts与vue

ts与Vue 如果你已经学习了typeScript,但不知道如何在vue项目中使用,那么这篇文章将会很适合你。参考千峰教育 kerwin视频 1.会自动推导,隐士推导。提示 类型系统。 独立模块。 isolatedModules选项:是否配置为独立的模块。 减少报错 let …

dispatcherServlet在tomcat启动时如何被加载(1)

目录 在springboot工程中, 如何添加一个servlet呢? 方法1 : 使用WebServlet注解 方法2 : 使用ServletRegistrationBean进行注册 springmvc 采用的就是方式2和springboot集成的, 看一下源码 springboot 字段装配里面有这个类, 看一下源码 90行, 创建了一个DispatcherServlet对象…

解决Adobe Flash Player已被屏蔽

问题:该插件不支持 原因:现在浏览器默认禁用flash 博主当前使用的是谷歌浏览器Chrome 2个主要方法都已经失效 搜索一圈后,之前博客给出的2个主要方法都已经失效。 1、flash.cn 下载本地播放器 2、在chrome中打开flash的禁用开关 2023年解…

LangChain源码逐行解密之系统(二)

LangChain源码逐行解密之系统 20.2 serapi.py源码逐行剖析 我们可以看一下Google查询的例子,在LangChain中有多种实现的方式。 如图20-5所示,在utilities的serpapi.py代码文件中实现了SerpAPIWrapper。 图20- 5 utilities的serpapi.py的SerpAPIWrapper 在langchain目录的se…

如何避免爬虫IP被屏蔽

各位爬友们好,作为一名专业的爬虫代理提供者,我要和大家分享一些避免爬虫IP被屏蔽的实用技巧。你知道吗,当我们爬取数据的时候,很容易被目标网站识别出来并封禁我们的IP地址,导致无法继续爬取数据。这个问题困扰了很多…

7. 实现 API 自动生成

目录 1. pom.xml中引用依赖 2. 引入相关的依赖 3. 编写配置类 4. application.yml 中添加配置 5. API 常用注解 6. 访问 API 列表 7. API 导入 Postman 使用 Springfox Swagger生成 API,并导入 Postman,完成API单元测试。 Swagger 简介:Swag…

执行Lua脚本后一直查询不到Redis中的数据(附带问题详细排查过程,一波三折)

文章目录 执行Lua脚本后一直查询不到Redis中的数据(附带详细问题排查过程,一波三折)问题背景问题1:Lua脚本无法切库问题2:RedisTemlate切库报错问题3:序列化导致数据不一致问题4:Lua脚本中单引号…

Flask Web开发实战(狼书)| 笔记第1、2章

前言 2023-8-11 以前对网站开发萌生了想法,又有些急于求成,在B站照着视频敲了一个基于flask的博客系统。但对于程序的代码难免有些囫囵吞枣,存在许多模糊或不太理解的地方,只会照葫芦画瓢。 而当自己想开发一个什么网站的时&…

ubuntu部署haproxy

HAProxy是可提供高可用性、负载均衡以及基于TCP和HTTP应用的代理. 1、更新系统报 通过在终端中运行以下命令,确保所有系统包都是最新的 sudo apt updatesudo apt upgrade2、安装Haproxy sudo apt install haproxy设置开机自动启动haproxy服务 sudo systemctl en…