文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

深入Python中的网络通信

2024-12-03 17:21

关注

 TCP/IP

计算机与网络设备两情侣要谈恋爱,相互通信,那么双方就必须有规则。基于相同的方法,不同的硬件、操作系统之间的通信,都需要一种规则。而我们就把这种规则称为协议(protocol)。

TCP/IP 是互联网相关各类协议族的总称。TCP/IP是指TCP和IP这两种协议。TCP/IP是在IP协议的通信过程中,使用到的协议族的统称。

TCP/IP协议族按层次分别为 应用层,传输层,网络层,数据链路层,物理层。可以按照不同的模型分4层或者是7层。

将TCP/IP分为5层,越靠下越接近硬件。

应用层:应用程序收到传输层的数据后,接下来就是要进行解读,解读必须要先规定好格式,而应用层就是规定应用程序的数据格式,主要协议有HTTP等。

传输层:该层为两台主机上的应用程序提供端到端的通信,传输层有两个传输协议为TCP(传输控制协议)和UDP(用户数据报协议),TCP是一个可靠的面向连接的协议,UDP是不可靠或者说无连接的协议。

网络层:决定如何将数据从发送方到接收方,是建立主机到主机的通信。

数据链路层:控制网络层与物理层之间的通信,主要功能是保证物理线路上进行可靠的数据传递。

物理层:该层负责物理传输,与链路有关,也与传输的介质有关。


客户端和服务器具体的

HTTP

图片出自《图解HTTP》书籍

三次握手,四次挥手

TCP三次握手,四次挥手,Runsen也不会怎么说,就把网上最通俗的图放在下面 了,还是别看我很牛逼,牛逼的是做图的大佬。

三次握手

四次挥手


图片出自公众号(程序员小小溪),更多的名词和概念查找参考公众号程序员小小溪的文章~[1]

Socket

网络编程有一个重要的概念 socket(套接字),应用程序可以通过它发送或接收数据,套接字允许应用程序将 I/O 插入到网络中,并与网络中的其他应用程序进行通信。

我是来偷窥Python中的网络通信Socket,不小心偷窥到了一个非常不错的Socket好图


将上面的图片整理步骤

建立连接:

通信:收一发:recv(1024)<---send(byte)/sendall(byte)

关闭连接:close()

实现简单的通讯程序

服务端,server.py

  1. #导入socket模块 
  2. import socket 
  3. #创建套接字 或使用server = socket.socket() 
  4. server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
  5. #定义绑定的ip和端口,用元组定义 
  6. ip_port = ('127.0.0.1', 8888) 
  7. #绑定监听:bind(address),在AF_INET下,以元组(ip,port)的形式表示地址 
  8. server.bind(ip_port) 
  9. #设置最大连接数,默认为1 
  10. server.listen(5) 
  11. #不断接受连接:one by one 
  12. while True
  13.     print("等待数据连接中……"
  14.     #接受客服端数据请求 
  15.     conn, address = server.accept() 
  16.     ''
  17.     向客服端返回信息 
  18.     (注意:python3.x以上,网络数据的发送接收都是byte类型, 
  19.     发送接收String类型数据时需要对数据进行编码(发送:messages.enconde();接收后转为String类型:messages.deconde()),pyhon2.x则直接发送数据无须编码) 
  20.     ''
  21.     messages = "连接成功!" 
  22.     conn.send(messages.encode()) 
  23.     #计数信息条数 
  24.     count = 0 
  25.     #一个连接中,不断的接受客户端发来的数据 
  26.     while True
  27.         data = conn.recv(1024) 
  28.         #打印客户端发来的数据信息 
  29.         print(data.decode()) 
  30.         #判断是否退出当前连接,等在下一个连接 
  31.         if data == b'exit'
  32.           break 
  33.         #处理客户端数据(如:响应请求等) 
  34.         count = count + 1 
  35.         string = "第" + str(count) + "条信息:" + data.decode() 
  36.         conn.send(string.encode()) 
  37.         #主动关闭连接 
  38.     conn.close() 

客户端,client.py

  1. import socket 
  2.  
  3. #创建套接字 
  4. client = socket.socket() 
  5. #访问的服务器的ip和端口,用元组定义 
  6. ip_port = ("127.0.0.1", 8888) 
  7. #连接服务器主机 
  8. client.connect(ip_port) 
  9. #同一链接中,不断向服务器发生数据或请求 
  10. while True
  11.     #接收服务器发送或响应的数据 
  12.     data = client.recv(1024) 
  13.     #打印接收的数据;python3.x以上数据要编码(发送:data.enconde();接收后转为String类型:data.deconde()) 
  14.     print(data.decode()) 
  15.     messages = input("请输入发生或请求的数据(exit退出):"
  16.     client.send(messages.encode()) 
  17.     if messages == 'exit'
  18.         break 
  19.     ''
  20.     #接收服务器发送或响应的数据 
  21.     data = client.recv(1024) 
  22.     #打印接收的数据;python3.x以上数据要编码,发送enconde();接收deconde() 
  23.     print(data.decode()) 
  24.     ''
  25. #关闭连接 
  26. client.close() 

具体效果如下图所示。


多线程通信TCP服务器与多个TCP客户端同时进行连续通信,只需要通过threading创建多线程任务handle_client就可以了。

  1. import socket 
  2. import threading 
  3. import random 
  4.  
  5.  
  6. def handle_client(): 
  7.     # 接受客户端请求链接 
  8.     client, address = server.accept() 
  9.     print("[*] Accept connection from: %s:%d" % (address[0], address[1])) 
  10.     messages = "Hello World!" 
  11.     client.send(messages.encode()) 
  12.     # 连续与当前连接的客户端通信 
  13.     while True
  14.         # 接受客户端数据 
  15.         request = (client.recv(1024)).decode() 
  16.         # 判断是否结束通信 
  17.         if request == 'exit'
  18.             break 
  19.         print("[*] Received from %s:%d : %s" % (address[0], address[1], request)) 
  20.         # 发送响应信息给客户端 
  21.         client.send((str(random.randint(1, 1000)) + ":" + "ACK!").encode()) 
  22.     # 关闭当前连接 
  23.     client.close() 
  24.  
  25.  
  26. if __name__ == "__main__"
  27.     # 创建套接字 
  28.     server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
  29.     # 定义绑定ip和端口 
  30.     ip = '127.0.0.1' 
  31.     port = 8888 
  32.     # 绑定监听 
  33.     server.bind((ip, port)) 
  34.     # 设置最大连接数,默认为1 
  35.     server.listen(5) 
  36.     print("[*] Listening on %s:%d" % (ip, port)) 
  37.     # 循环开启线程,接受多个客户端的链接通信 
  38.     while True
  39.         # 创建一个线程 
  40.         client_handler = threading.Thread(target=handle_client) 
  41.         # 开启线程 
  42.         client_handler.start() 

 

python3.x以上,网络数据messages的发送接收都是byte类型,若要发送接收String类型数据时需要通过messages.enconde()对数据进行编码,接收后通过messages.deconde()转为String类型。pyhon2.x则直接发送数据无须编码。

本文已收录 GitHub,传送门~[2] ,里面更有大厂面试完整考点,欢迎 Star。

Reference
[1] 参考公众号程序员小小溪的文章:
https://mp.weixin.qq.com/s/KK1dnNoHrbjMyuhQptaBAQ

[2] 传送门~:
https://github.com/MaoliRUNsen/runsenlearnpy100

 

来源:Python之王内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯