当前位置： 首页 > news >正文

Python-简单网络编程 I

news 2025/5/14 6:39:21

目录

  • 一、UDP 网络程序
    • 1. 通信结构图
    • 2. Python 代码实现
      • 1）服务器端
      • 2）客户端
    • 3. 注意
  • 二、TCP 网络程序
    • 1. 通信结构图
    • 2. Python 代码实现
      • 1）服务器端
      • 2）客户端
    • 3. 注意
  • 三、文件下载
    • 1. PyCharm 程序传参
      • 1）图形化界面传参
      • 2）命令行运行传参
    • 2. Python 代码实现
      • 1）服务器端
      • 2）客户端
  • 四、使用 epoll 实现即时聊天
    • 1. 原理与步骤
    • 2. Python 代码实现 (Linux 下运行)
      • 1）服务器端
      • 2）客户端
    • 3. PyCharm 连接远程服务器步骤
      • 1）启用相关插件
      • 2）添加 SSH 解释器

一、UDP 网络程序

1. 通信结构图

创建一个基于 UDP 的网络程序流程很简单，具体步骤如下：

  • 创建一个套接字（socket.socket()）

  • 服务器绑定 ip 和 port（bind()）

  • 发送 / 接收数据（sendto() 和 recvfrom()）

  • 关闭套接字（close()）

2. Python 代码实现

1）服务器端

import socket# 先运行
# 创建udp socket对象，AF_INET代表IPv4，SOCK_DGRAM代表UDP
server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# 服务器地址（本机ip+指定端口号），用 ipconfig 命令查看本机ip地址
address = ('10.204.6.120', 8080)  # 写1024以上的端口
try:# 绑定地址，利用 netstat -an|grep 8080 命令查看端口是否被占用# 绑定后才能发送接收，绑定失败直接抛异常server.bind(address)# 接收数据，参数为缓冲区大小data, addr = server.recvfrom(1024)print(f"Received message: '{data.decode("utf-8")}' from {addr}")# 发送数据server.sendto('nice to meet you'.encode("utf-8"), addr)
except OSError:print("Binding failed, the port is occupied or the IP address is invalid.")
finally:# 关闭udp socket对象server.close()

2）客户端

import socket# 后运行
# 创建客户端udp socket对象
client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# 目标服务器的IP和端口
dest_addr = ('10.204.6.120', 8080)
# 不绑定端口，系统会自动分配一个临时端口
try:# 发送数据client.sendto(b'nice to meet you too', dest_addr)# 打印自动分配的端口号print("Local socket address:", client.getsockname()[1])# 接收数据，设置超时防止阻塞过久client.settimeout(5)data, addr = client.recvfrom(1024)print(f"Received message: '{data.decode("utf-8")}' from {addr}")
except socket.timeout:print("No response received within timeout.")
finally:client.close()

3. 注意

  • 如果出现 OSError: [Errno 98] Address already in use 的情况，说明端口已被其他进程占用，因此 bind 失败，换一个端口号即可。

  • 使用 lsof 命令查看端口。

  • UDP 中 recvform 内部要接收的大小必须大于发送的字节数。否则：

    • 对于英文字符：在 Windows 下会直接报错；在 Linux 下不会报错，没有接收到的数据直接丢弃。
    • 对于中文字符：不管在 Windows 下还是 Linux 下都直接报错。

  • 对于 UDP ：sendto 和 recvfrom 的次数要完全对等。

UDP 发送接收数据的特点：
每 sendto 一次，就往内核里放了一个队列结点；每 recvfrom 一次，就拿走一个队列结点，同时内核删除该结点。因此，recvfrom 的大小要大于 sendto 发送的报文大小，否则在获取时 Linux 会直接丢弃（在 Windows 下会报异常）。

  • UDP 网络程序的服务器端需要绑定 IP 地址和端口号，而客户端可以不绑定端口号。
    • 如果不显式调用绑定（bind）端口号的操作，操作系统会自动帮程序分配一个随机的 “临时端口号” ，因此，如果重新运行程序，端口可能会发生变化。
    • 如果显式调用绑定操作，指定某个固定的 IP 地址和端口号，操作系统就会把收到的发往这个端口号的 UDP 数据包交给该程序处理。

总结：不绑定端口，系统分配随机端口，端口会变；绑定端口，端口固定，程序用该端口接收数据。
换句话说，端口号是程序接收数据的 “身份标识” ，只要绑定成功，这个端口号就是程序的固定入口，其他程序或设备给该端口发的 UDP 数据都会被该程序接收。

二、TCP 网络程序

1. 通信结构图

在程序中，如果想要完成一个 TCP 服务器的功能，需要的流程如下：

  • 创建一个套接字（socket.socket()）

  • 服务器绑定 ip 和 port（bind()）

  • 将服务器的套接字从主动连接变为被动连接（listen()）

  • 服务器等待客户端的连接（accept()）

  • 客户端连接服务器（connect()）

  • 接收 / 发送数据（send() 和 recv()）

  • 关闭套接字（close()）

2. Python 代码实现

1）服务器端

import socket  def tcp_server():  # 创建tcp socket对象，SOCK_STREAM代表TCPserver = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 服务器地址（本机ip+端口号）  address = ('10.204.6.120', 8080)  # 写1024以上的端口  # 绑定地址，此时端口没有激活  server.bind(address)  # 服务器端开始监听，此时端口激活# 参数是socket可以排队的最大连接个数server.listen(128)  # 等待客户端连接，跟客户端进行后续通信的是new_clientnew_client, client_addr = server.accept()  # 发送数据  new_client.send('你好'.encode('utf-8'))  # 接收数据data = new_client.recv(1024)  print(f'接收到的数据：{data.decode("utf-8")}')  # 关闭tcp socket对象  new_client.close()  server.close()  if __name__ == '__main__':  
tcp_server()

2）客户端

import socket  def tcp_client():  # 创建客户端tcp socket对象  client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 服务器地址  dest_addr = ('10.204.6.120', 8080)  # 连接服务器  client.connect(dest_addr)  # 接收数据  data = client.recv(1024)  print(f'接收到的数据：{data.decode("utf-8")}')# 发送数据  client.send('Hello'.encode('utf-8'))  # 关闭tcp socket对象  client.close()  if __name__ == '__main__':  tcp_client()

3. 注意

  • TCP 网络程序的服务器端需要绑定 IP 地址和端口号，否则客户端找不到该服务器。

  • TCP 网络程序的客户端不需要进行绑定操作，因为需要客户端主动连接服务器，所以只要确定好服务器的 IP 地址和 Port 等信息，而本地客户端的信息可以随机。

  • TCP 服务器调用 listen() 操作将主动套接字变为被动套接字，导致套接字从 CLOSED 状态转换为 LISTEN 状态，等待接受来自其他主动套接字的连接请求。

  • 当客户端需要连接服务器时，就需要调用 connect() 操作，UDP 是直接发送的，可以不需要连接；但是 TCP 只有连接成功后才能通信。当一个 TCP 客户端连接服务器时，服务器端会产生一个新的套接字，该套接字用来标记这个客户端，单独为这个客户端服务。

listen() 操作将主动套接字变为被动套接字，用于接收客户端的连接请求；
accept() 操作返回的新套接字用于标记新客户端。

  • 关闭 listen() 后的套接字又从被动套接字变回主动套接字，会导致新的客户端不能连接服务器，但之前已经成功连接的客户端仍可正常通信。

  • 关闭 accept() 返回的套接字意味着这个客户端已经服务完毕。

  • 当客户端的套接字调用 close() 操作关闭连接后，服务器端的 recv() 解堵塞，并且返回的长度为 0，因此服务器可以通过返回数据的长度来判断客户端是否已经下线。

如果服务器之前执行 recv() 时因为套接字没有数据而阻塞（等待数据），那么当客户端关闭连接后，服务器端的 recv() 不再阻塞，会立即返回。recv() 函数返回值代表接收到的数据长度，如果返回 0，表示 “连接被关闭” ，即对端已经关闭了连接。服务器通过检查 recv() 的返回值，判断是否为 0，如果是 0，就能确定客户端已经正常关闭了连接（客户端下线）。

三、文件下载

基本协议设计：

  • 客户端（Client）send 文件名 → recv 文件内容 → 内容写入文件

  • 服务器（Server）recv 文件名 → 读文件内容 → send 文件内容

1. PyCharm 程序传参

sys.argv 是参数列表（需要 import sys），len(sys.argv) 计算参数列表的长度。

1）图形化界面传参

  • 选择需要传参的程序，点击 “编辑配置…” 。

  • 在如下图所示的位置填写需要填写的参数。例如我填写了本机的 IP 地址和一个随机的端口号，最后点击 “确定” 即可。

  • 运行下面程序可知参数传入成功。

2）命令行运行传参

打开 PyCharm 终端，运行 python [运行的程序] [传递的参数] 命令，如下图所示。

PyCharm 启动时用的是绝对路径，而在命令行执行的是相对路径。

2. Python 代码实现

1）服务器端

from socket import *
import sysdef get_file_content(file_name):  # 获取文件的内容try:with open(file_name, "rb") as f:content = f.read()f.close()return contentexcept:print(f'没有名为《{file_name}》的文件')return Nonedef file_tcp_server():if len(sys.argv) != 3:print("请先在终端进行传参操作：python server.py IP地址 端口号")returnelse:ip = sys.argv[1]  # '10.204.6.120' (str)port = int(sys.argv[2])  # 7890 (int)# 创建 sockettcp_server_socket = socket(AF_INET, SOCK_STREAM)# 本地信息address = (ip, port)# 绑定本地信息tcp_server_socket.bind(address)# 128 表示等待连接的最大数量tcp_server_socket.listen(128)# 等待客户端的连接，即为这个客户端发送文件client_socket, client_addr = tcp_server_socket.accept()# 接收对方发送过来的数据recv_data = client_socket.recv(1024)  # 接收 1024 个字节file_name = recv_data.decode("utf-8")print("对方请求下载的文件名为: %s" % file_name)# 获取文件的内容file_content = get_file_content(file_name)# 发送文件的数据给客户端# 因为获取打开文件时是以 rb 方式打开，所以 file_content 中的数据已经是二进制的格式，因此不需要 encode 编码if file_content is not None:client_socket.send(file_content)# 关闭这个套接字client_socket.close()# 关闭监听套接字tcp_server_socket.close()if __name__ == "__main__":file_tcp_server()

2）客户端

from socket import *def file_tcp_client():# 创建 sockettcp_client_socket = socket(AF_INET, SOCK_STREAM)# 目的信息# server_ip = input("请输入服务器 ip:")server_ip = '10.204.6.120'# server_port = int(input("请输入服务器 port:"))server_port = 7890# 连接服务器tcp_client_socket.connect((server_ip, server_port))# 输入需要下载的文件名file_name = input("请输入要下载的文件名：")# 发送文件下载请求tcp_client_socket.send(file_name.encode("utf-8"))# 接收对方发送过来的数据，最大接收 1024 个字节（1K）recv_data = tcp_client_socket.recv(1024)if recv_data:print('接收到的数据为:', recv_data.decode('utf-8'))else:print('没有接收到数据')# 关闭套接字tcp_client_socket.close()if __name__ == "__main__":file_tcp_client()

注：

  • 运行时先运行服务器端（server），再运行客户端（client）。
  • 服务器的 IP 请根据实际情况自行修改（cmd 中使用 ipconfig 命令查看），端口号也可以自行填写（2000 以上的均可）。
  • 传参在配置中修改。

四、使用 epoll 实现即时聊天

epoll 是对 select 和 poll 模型的改进，提高了网络编程的性能，广泛应用于大规模并发请求的 C/S 架构中。它的触发方式是边缘触发 / 水平触发，只适用于 Unix / Linux 操作系统，如果想在 PyCharm 上运行，需要连接远程服务器。

1. 原理与步骤

  • 创建一个 epoll 对象：
    导入 select 模块：import select
    创建一个 epoll 对象：epoll = select.epoll()

  • 让 epoll 对象在指定的 socket 上监听指定的事件：
    注册要监控的文件描述符和事件：epoll.register(文件描述符, 事件类型)

(I) 返回 epoll 的控制文件描述符：epoll.fileno()
(II) 事件类型：
可读事件 select.EPOLLIN ；
可写事件 select.EPOLLOUT ；
错误事件 select.EPOLLERR ；
客户端断开事件 select.EPOLLHUP 。

  • 轮询 epoll 对象，哪些 socket 发生了哪些指定的事件：
    epoll.poll(timeout) ：当文件句柄发生变化时，会以列表的形式主动报告给用户进程

timeout 为超时时间，默认为 -1 ，即一直等待直到文件句柄发生变化；如果指定为 1 ，那么 epoll 每 1 秒汇报一次当前文件句柄的变化情况，如果无变化则返回空。

  • 在这些 socket 上执行一些操作。

  • 让 epoll 对象修改并监控 socket 列表和 / 或事件。

  • 重复以上步骤 ，直至完成。

  • 销毁 epoll 对象：
    关闭 epoll 对象的控制文件描述符：epoll.close()
    销毁文件描述符：epoll.unregister(文件描述符)

2. Python 代码实现 (Linux 下运行)

1）服务器端

# !/usr/bin/python
# -*- coding:utf-8 -*-import socket
import select
import sysclass ChatServer:def __init__(self, ip, port):self.ip = ipself.port = port# 创建socketself.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 设置端口复用self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)# 绑定本地信息self.sock.bind((self.ip, self.port))# 开始监听self.sock.listen(10)# 创建一个epoll对象self.epoll = select.epoll()def chat(self):# 注册并监控self.sockself.epoll.register(self.sock.fileno(), select.EPOLLIN)# 注册并监控标准输入self.epoll.register(sys.stdin.fileno(), select.EPOLLIN)while True:events = self.epoll.poll(-1)  # 轮询注册的事件for fd, event in events:if fd == self.sock.fileno():  # 如果是socket创建的套接字# 等待客户端连接client_socket, client_addr = self.sock.accept()  # 接收连接print("New connected by:", client_addr)# 注册并监控新连接的可读事件self.epoll.register(client_socket.fileno(), select.EPOLLIN)elif fd == sys.stdin.fileno():  # 如果是标准输入# 服务器端先读标准输入msg = input()# 然后将标准输入发送给客户端client_socket.send(msg.encode("utf-8"))elif fd == client_socket.fileno():  # 如果是客户端发送过来的数据# 接收客户端发送过来的数据data = client_socket.recv(1024).decode("utf-8")if data:print("Received from client:", data)else:print("Client has been closed.")self.epoll.unregister(client_socket.fileno())  # 取消注册client_socket.close()breakif __name__ == "__main__":s = ChatServer("192.168.200.128", 8080)s.chat()

2）客户端

# !/usr/bin/python
# -*- coding:utf-8 -*-import socket
import select
import sysclass ChatClient:def __init__(self, ip, port):self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)self.sock.connect((ip, port))self.epoll = select.epoll()def chat_client(self):# 让epoll监控self.sock套接字的可读事件self.epoll.register(self.sock.fileno(), select.EPOLLIN)self.epoll.register(sys.stdin.fileno(), select.EPOLLIN)while True:events = self.epoll.poll(-1)for fd, event in events:if fd == self.sock.fileno():data = self.sock.recv(1024).decode("utf-8")if not data:print("Server has been closed.")self.epoll.unregister(self.sock.fileno())self.sock.close()breakelse:print("Received from server:", data)elif fd == sys.stdin.fileno():msg = input()self.sock.send(msg.encode("utf-8"))if __name__ == "__main__":c = ChatClient("192.168.200.128", 8080)c.chat_client()

3. PyCharm 连接远程服务器步骤

1）启用相关插件

首先，确保 PyCharm 是专业版的。

步骤：

  • 打开 PyCharm ，进入 “文件 File” → “设置 Settings” → “插件 Plugins” 。

  • 在 “已安装 Installed” 标签下，确保 “部署 Deployment” 中的 “FTP/SFTP/WebDAV Connectivity” 和 “其他工具 Other Tools” 中的 “Terminal” 已勾选。如果没有这两个插件，前往 “Marketplace” 中下载。

勾选 “FTP/SFTP/WebDAV Connectivity” 可以解决 “工具 Tools” 下没有 “部署 Deployment” 的问题。

  • 如果未勾选，则勾选后需重启 PyCharm 。

2）添加 SSH 解释器

步骤：

  • 打开 PyCharm ，进入 “文件 File” → “设置 Settings” → “项目 Project: [项目名称]” → “Python 解释器 Interpreter” 。

  • 点击右上角的添加解释器 Add ，选择 “基于 SSH …” 并进行配置。
    注：确保虚拟机已开启。

主机如何填写？

打开 VMware Workstation Pro 中的虚拟机，点击虚拟机右上角的倒三角 ▼ ，选择 “网络” ，按下图所示步骤查看 IPv4 地址，将该地址复制并填入主机处。

连接 SSH 服务器的详细步骤：

  • 选择 “新建” ，并填写主机和用户名信息，点击三次 “下一步” 。
    此时一定要确保虚拟机是开启状态，否则将无法成功连接 SSH 服务器。

  • 选择 “系统解释器” ，可以自行选择是否修改远程路径，最后点击 “创建” 即可。
    例如：我将远程路径改为 /home/kusunoki/PyCharm_SSH

  • 此时就可以通过右下角随时切换解释器和默认部署服务器了。
    注意在切换 SSH 解释器时需要确保虚拟机开启。

http://www.xdnf.cn/news/425629.html

相关文章：

  • 前端学习（3）—— CSS实现热搜榜
  • 通过anaconda安装jupyter
  • uni-app学习笔记五-vue3响应式基础
  • 国标GB28181视频平台EasyGBS实现路况精准呈现，打造智慧出行新体验
  • 微信小程序 密码框改为text后不可见，需要点击一下
  • 基于STM32、HAL库的TLV320AIC3204IRHBR音频接口芯片驱动程序设计
  • k8s之k8s集群部署
  • 互信息与KL散度：差异与应用全解析
  • 基于C语言实现网络爬虫程序设计
  • Docker常用命令及示例大全
  • Rimworld Mod教程 武器Weapon篇 近战章 第二讲：生物可用的近战来源
  • Houdini安装SideFX Labs工具架
  • c语言第一个小游戏：贪吃蛇小游戏07
  • 为什么hadoop不用Java的序列化？
  • Git命令起别名
  • OPC UA 协议介绍
  • Java—— 双列集合 Map
  • Logisim实验--华科计算机组成原理(保姆级教程) 头歌-存储系统设计实验（汉字库存储芯片扩展实验、MIPS寄存器文件设计）
  • 【Unity】协程的同步使用
  • 第六天 车载应用开发
  • 【速通RAG实战：进阶】10.RAG 进化论：Advanced与Modular架构解锁智能问答新维度
  • 激光雷达定位算法在FPGA中的实现——section3 Matlab实现和校验
  • HarmonyOS 【诗韵悠然】AI古诗词赏析APP开发实战从零到一系列（一、开篇，项目介绍）
  • 【LeetCode 热题 100】二叉树的最大深度 / 翻转二叉树 / 二叉树的直径 / 验证二叉搜索树
  • React vs Vue：点击外部事件处理的对比与实现
  • 用vite脚手架建立 前端工程
  • 服务器制造业中，L2、L6、L10等表示什么意思
  • Shell脚本实践(修改文件，修改配置文件，执行jar包)
  • 互联网大厂Java求职面试：优惠券服务架构设计与AI增强实践-4
  • R²AIN SUITE 如何破解制造业效率难题，制造业效率提升新思路​