主页
  • 主页
  • 分类
  • 热文
  • 教程
  • 面试
  • 标签
Python

Python 基础

Python 主页
Python 概述
Python 历史
Python 功能
Python 与 C++
Python Hello World
Python 应用领域
Python 解释器及其模式
Python 环境设置
Python 虚拟环境
Python 语法
Python 变量
Python 数据类型
Python 类型转换
Python Unicode 系统
Python 文字
Python 运算符
Python 算术运算符
Python 比较运算符
Python 赋值运算符
Python 逻辑运算符
Python 位运算符
Python 成员运算符
Python 身份运算符
Python 运算符优先级
Python 注释
Python 用户输入
Python 数字
Python 布尔值

Python 控制语句

Python 控制流
Python 决策
Python if 语句
Python if-else 语句
Python 嵌套 if 语句
Python match-case 语句
Python 循环
Python For 循环
Python for-else 循环
Python while 循环
Python break 语句
Python Continue 语句
Python pass 语句
Python 嵌套循环

Python 函数和模块

Python 函数
Python 默认参数
Python 关键字参数
Python 关键字专用参数
Python 位置参数
Python 仅限位置参数
Python 任意或可变长度参数
Python 变量作用域
Python 函数注释
Python 模块
Python 内置函数

Python 字符串

Python 字符串
Python 字符串切片
Python 字符串修改
Python 字符串连接
Python 字符串格式化
Python 转义字符
Python 字符串方法
Python 字符串练习

Python 列表

Python 列表
Python 访问列表项
Python 更改列表项
Python 添加列表项
Python 删除列表项
Python 循环列表
Python 列表推导式
Python 排序列表
Python 复制列表
Python 合并列表
Python 列表方法
Python 列表练习

Python 元组

Python 元组
Python 访问元组项
Python 更新元组
Python 解包元组项
Python 循环元组
Python 合并元组
Python 元组方法
Python 元组练习

Python 集合

Python 集合
Python 访问集合项
Python 添加集合项
Python 删除集合项
Python 循环集合
Python 合并集合
Python 复制集合
Python 集合运算符
Python 集合方法
Python 集合练习

Python 字典

Python 字典
Python 访问字典项
Python 更改字典项
Python 添加字典项
Python 移除字典项
Python 字典视图对象
Python 循环字典
Python 复制字典
Python 嵌套字典
Python 字典方法
Python 字典练习

Python 数组

Python 数组
Python 访问数组项
Python 添加数组项
Python 移除数组项
Python 循环数组
Python 复制数组
Python 反转数组
Python 排序数组
Python 合并数组
Python 数组方法
Python 数组练习

Python 文件处理

Python 文件处理
Python 文件写入
Python 文件读取
Python 重命名和删除文件
Python 目录
Python 文件方法
Python 文件/目录方法
Python OS.Path 方法

Python 面向对象编程

Python OOP 概念
Python 类和对象
Python 类属性
Python 类方法
Python 静态方法
Python 构造函数
Python 访问修饰符
Python 继承
Python 多态
Python 方法重写
Python 方法重载
Python 动态绑定
Python 动态类型
Python 抽象
Python 封装
Python 接口
Python 包
Python 内部类
Python 匿名类和对象
Python 单例类
Python 包装器类
Python 枚举
Python 反射

Python 错误和异常

Python 语法错误
Python 异常处理
Python Try-Except
Python Try-Finally
Python 抛出异常
Python 异常链
Python 嵌套 try
Python 用户定义异常
Python 日志记录
Python 断言
Python 内置异常

Python 多线程

Python 多线程
Python 线程生命周期
Python 创建线程
Python 启动线程
Python 合并线程
Python 命名线程
Python 线程调度
Python 线程池
Python 主线程
Python 线程优先级
Python 守护线程
Python 线程同步

Python 同步

Python 线程间通信
Python 死锁
Python 中断线程

Python 网络

Python 网络编程
Python 套接字编程
Python URL 处理
Python 泛型

Python 杂项

Python Date and Time
Python math模块
Python 迭代器
Python 生成器
Python 闭包
Python 装饰器
Python 递归
Python 正则表达式
Python Pip
Python 数据库访问
Python 弱引用
Python 序列化
Python 模板技术
Python 输出格式化
Python 性能测量
Python 数据压缩
Python 通用网关接口
Python XML 处理
Python 用户界面(GUI)
Python 命令行参数
Python Docstrings
Python JSON
Python 发送电子邮件
Python 进一步扩展
Python 工具/实用程序
Python GUI

Python 高级概念

Python 抽象基类
Python 自定义异常
Python 高阶函数
Python 对象的内部机制
Python 内存管理
Python 元类
Python 元编程
Python 模拟与桩
Python 猴子补丁
Python 信号处理
Python 类型提示
Python 进行自动化
Python Humanize包
Python 上下文管理器
Python 协程
Python 描述符
Python 内存泄漏
Python 不可变数据结构

基础

Python 主页
Python 概述
Python 历史
Python 功能
Python 与 C++
Python Hello World
Python 应用领域
Python 解释器及其模式
Python 环境设置
Python 虚拟环境
Python 语法
Python 变量
Python 数据类型
Python 类型转换
Python Unicode 系统
Python 文字
Python 运算符
Python 算术运算符
Python 比较运算符
Python 赋值运算符
Python 逻辑运算符
Python 位运算符
Python 成员运算符
Python 身份运算符
Python 运算符优先级
Python 注释
Python 用户输入
Python 数字
Python 布尔值

控制语句

Python 控制流
Python 决策
Python if 语句
Python if-else 语句
Python 嵌套 if 语句
Python match-case 语句
Python 循环
Python For 循环
Python for-else 循环
Python while 循环
Python break 语句
Python Continue 语句
Python pass 语句
Python 嵌套循环

函数和模块

Python 函数
Python 默认参数
Python 关键字参数
Python 关键字专用参数
Python 位置参数
Python 仅限位置参数
Python 任意或可变长度参数
Python 变量作用域
Python 函数注释
Python 模块
Python 内置函数

字符串

Python 字符串
Python 字符串切片
Python 字符串修改
Python 字符串连接
Python 字符串格式化
Python 转义字符
Python 字符串方法
Python 字符串练习

列表

Python 列表
Python 访问列表项
Python 更改列表项
Python 添加列表项
Python 删除列表项
Python 循环列表
Python 列表推导式
Python 排序列表
Python 复制列表
Python 合并列表
Python 列表方法
Python 列表练习

元组

Python 元组
Python 访问元组项
Python 更新元组
Python 解包元组项
Python 循环元组
Python 合并元组
Python 元组方法
Python 元组练习

集合

Python 集合
Python 访问集合项
Python 添加集合项
Python 删除集合项
Python 循环集合
Python 合并集合
Python 复制集合
Python 集合运算符
Python 集合方法
Python 集合练习

字典

Python 字典
Python 访问字典项
Python 更改字典项
Python 添加字典项
Python 移除字典项
Python 字典视图对象
Python 循环字典
Python 复制字典
Python 嵌套字典
Python 字典方法
Python 字典练习

数组

Python 数组
Python 访问数组项
Python 添加数组项
Python 移除数组项
Python 循环数组
Python 复制数组
Python 反转数组
Python 排序数组
Python 合并数组
Python 数组方法
Python 数组练习

文件处理

Python 文件处理
Python 文件写入
Python 文件读取
Python 重命名和删除文件
Python 目录
Python 文件方法
Python 文件/目录方法
Python OS.Path 方法

面向对象编程

Python OOP 概念
Python 类和对象
Python 类属性
Python 类方法
Python 静态方法
Python 构造函数
Python 访问修饰符
Python 继承
Python 多态
Python 方法重写
Python 方法重载
Python 动态绑定
Python 动态类型
Python 抽象
Python 封装
Python 接口
Python 包
Python 内部类
Python 匿名类和对象
Python 单例类
Python 包装器类
Python 枚举
Python 反射

错误和异常

Python 语法错误
Python 异常处理
Python Try-Except
Python Try-Finally
Python 抛出异常
Python 异常链
Python 嵌套 try
Python 用户定义异常
Python 日志记录
Python 断言
Python 内置异常

多线程

Python 多线程
Python 线程生命周期
Python 创建线程
Python 启动线程
Python 合并线程
Python 命名线程
Python 线程调度
Python 线程池
Python 主线程
Python 线程优先级
Python 守护线程
Python 线程同步

同步

Python 线程间通信
Python 死锁
Python 中断线程

网络

Python 网络编程
Python 套接字编程
Python URL 处理
Python 泛型

杂项

Python Date and Time
Python math模块
Python 迭代器
Python 生成器
Python 闭包
Python 装饰器
Python 递归
Python 正则表达式
Python Pip
Python 数据库访问
Python 弱引用
Python 序列化
Python 模板技术
Python 输出格式化
Python 性能测量
Python 数据压缩
Python 通用网关接口
Python XML 处理
Python 用户界面(GUI)
Python 命令行参数
Python Docstrings
Python JSON
Python 发送电子邮件
Python 进一步扩展
Python 工具/实用程序
Python GUI

高级概念

Python 抽象基类
Python 自定义异常
Python 高阶函数
Python 对象的内部机制
Python 内存管理
Python 元类
Python 元编程
Python 模拟与桩
Python 猴子补丁
Python 信号处理
Python 类型提示
Python 进行自动化
Python Humanize包
Python 上下文管理器
Python 协程
Python 描述符
Python 内存泄漏
Python 不可变数据结构

Python 套接字编程


上一章 下一章

Socket 编程是一种技术,我们可以在其中在网络中通信的两个节点之间进行通信,其中服务器节点监听来自客户端节点的传入请求。

在 Python 中,使用 socket 模块来进行 socket 编程。标准库中的 socket 模块包含了硬件级别上服务器与客户端之间通信所需的功能。

该模块提供了对 BSD socket 接口的访问。它适用于所有操作系统,如 Linux、Windows、MacOS。

什么是 Socket?

Socket 是双向通信信道的端点。Socket 可以在进程内、同一机器上的进程之间或者不同大陆上的进程之间进行通信。

一个 Socket 由 IP 地址和端口号的组合来识别。通信开始前两端应正确配置。

connection

Socket 可能实施于不同的通道类型之上:Unix 域套接字、TCP、UDP 等等。套接字库提供了处理常见传输的具体类以及处理其余部分的通用接口。

术语 Socket 编程意味着编程设置 Socket 以便能够发送和接收数据。

有两种类型的通信协议:

  • 面向连接的协议
  • 无连接的协议

TCP 或者传输控制协议是一种面向连接的协议。数据由服务器以包的形式传输,并由接收方按照传输顺序组装。由于通信两端的 Socket 需要在开始前设置,因此这种方法更加可靠。

UDP 或用户数据报协议是无连接的。该方法不可靠,因为 Socket 不需要建立任何连接和终止过程来传输数据。

Python socket 模块

socket 模块用于创建和管理网络中连接节点的 Socket 编程。socket 模块提供了一个 socket 类。你需要使用 socket.socket() 构造函数来创建一个 Socket。

socket 类的对象表示主机名和端口号的配对。

语法

以下是 socket.socket() 构造函数的语法:

socket.socket(socket_family, socket_type, protocol=0)

参数

  • family - 默认为 AF_INET。其他值 - AF_INET6(八组四位十六进制数字)、AF_UNIX、AF_CAN(控制器局域网)或 AF_RDS(可靠数据报套接字)。
  • socket_type - 应为 SOCK_STREAM(默认),SOCK_DGRAM、SOCK_RAW 或者可能是其他 SOCK_ 常量之一。
  • protocol - 数字通常为零,可以省略。

返回类型

此方法返回一个 socket 对象。

一旦有了 socket 对象,那么就可以使用所需的方法来创建你的客户端或服务器程序。

服务器 Socket 方法

在服务器上实例化的 Socket 被称为服务器 Socket。以下方法可用于服务器上的 Socket 对象:

  • bind() 方法 - 此方法将 Socket 绑定到指定的 IP 地址和端口号。
  • listen() 方法 - 此方法启动服务器并运行监听循环以查找来自客户端的连接请求。
  • accept() 方法 - 当连接请求被服务器截获时,此方法接受它并标识客户端 Socket 及其地址。

要创建一个服务器上的 Socket,请使用以下代码片段:

import socket
server = socket.socket()
server.bind(('localhost', 12345))
server.listen()
client, addr = server.accept()
print("connection request from: " + str(addr))

默认情况下,服务器绑定到本地机器的 IP 地址 'localhost' 并监听任意空闲端口。

客户端 Socket 方法

类似地,在客户端也设置了 Socket。它主要向在其 IP 地址和端口号上监听的服务器 Socket 发送连接请求。

  • connect() 方法 - 此方法接受一个两元素的元组对象作为参数。两个元素分别是服务器的 IP 地址和端口号。
obj = socket.socket()
obj.connect((host, port))

一旦连接被服务器接受,两个 Socket 对象都可以发送和/或接收数据。

  • send() 方法 - 服务器使用其截取的地址将数据发送给客户端。客户端 Socket 将数据发送给与其建立了连接的 Socket。
  • sendall() 方法 - 类似于 send()。但是,与 send() 不同的是,此方法会继续发送 bytes 直到所有数据都被发送或出现错误。成功时返回 None。
  • sendto() 方法 - 此方法仅在 UDP 协议的情况下使用。
  • recv() 方法 - 此方法用于检索发送给客户端的数据。对于服务器来说,它使用已接受请求的远程 Socket。
  • recvfrom() 方法 - 此方法仅在 UDP 协议的情况下使用。

Python - Socket 服务器

为了编写 Internet 服务器,我们在 socket 模块中使用 socket 函数来创建一个 socket 对象。然后使用该 socket 对象调用其他函数来设置 socket 服务器。

现在调用 bind(hostname, port) 函数来指定在给定主机上的端口用于你的服务。

接下来,调用返回对象的 accept 方法。此方法等待直到客户端连接到你指定的端口,然后返回一个代表与该客户端连接的连接对象。

服务器 Socket 示例

import socket
host = "127.0.0.1"
port = 5001
server = socket.socket()
server.bind((host, port))
server.listen()
conn, addr = server.accept()
print("Connection from: " + str(addr))
while True:
   data = conn.recv(1024).decode()
   if not data:
      break
   data = str(data).upper()
   print(" from client: " + str(data))
   data = input("type message: ")
   conn.send(data.encode())
conn.close()

Python - Socket 客户端

让我们编写一个非常简单的客户端程序,它打开一个连接到给定端口 5001 和给定本地主机的连接。使用 Python 的 socket 模块函数创建一个 socket 客户端非常简单。

socket.connect(hosname, port) 打开到 hostname 上端口的 TCP 连接。一旦你打开了一个 socket,你可以像处理任何 IO 对象一样从中读取数据。完成后,记得关闭它,就像关闭一个文件一样。

客户端 Socket 示例

import socket
host = '127.0.0.1'
port = 5001
obj = socket.socket()
obj.connect((host, port))
message = input("type message: ")
while message != 'q':
   obj.send(message.encode())
   data = obj.recv(1024).decode()
   print('Received from server: ' + data)
   message = input("type message: ")
obj.close()

首先运行服务器代码。它开始监听。

然后启动客户端代码。它发送请求。

请求被接受。客户端地址被识别。

输入一些文本并按 Enter 键。

接收到的数据被打印。发送数据到客户端。

从服务器接收的数据。

当输入 'q' 时,循环终止。

下面显示了服务器-客户端的交互:

服务器_客户端_交互

我们已经在本地机器上使用 socket 模块实现了客户端-服务器通信。要把服务器和客户端代码放在网络上的两台不同机器上,我们需要找到服务器机器的 IP 地址。

在 Windows 上,你可以通过运行 ipconfig 命令来找到 IP 地址。Ubuntu 上的 ifconfig 命令是等效命令。

ipv4_地址

更改服务器和客户端代码中的主机字符串为 IPv4 地址值,并像以前一样运行它们。

Python 文件传输与 Socket 模块

下面的程序演示了如何使用 socket 通信从服务器传输文件到客户端。

socket服务器模块

服务器代码

建立连接的代码与之前相同。在接受连接请求之后,服务器上以二进制模式打开一个文件进行读取,并逐次读取字节并发送到客户端流,直到文件结束。

import socket
host = "127.0.0.1"
port = 5001
server = socket.socket()
server.bind((host, port))
server.listen()
conn, addr = server.accept()
data = conn.recv(1024).decode()
filename = 'test.txt'
f = open(filename, 'rb')
while True:
   l = f.read(1024)
   if not l:
      break
   conn.send(l)
   print('Sent ', repr(l))
f.close()
print('File transferred')
conn.close()

客户端代码

在客户端,以 wb 模式打开一个新文件。从服务器接收的数据流写入到文件中。随着流的结束,输出文件关闭。将在客户端机器上创建一个新文件。

import socket

s = socket.socket()
host = "127.0.0.1"
port = 5001

s.connect((host, port))
s.send("Hello server!".encode())

with open('recv.txt', 'wb') as f:
   while True:
      print('receiving data...')
      data = s.recv(1024)
      if not data:
         break
      f.write(data)
      
f.close()
print('Successfully received')
s.close()
print('connection closed')

Python 标准库中的 socketserver 模块

Python 标准库中的 socketserver 模块是一个框架,用于简化编写网络服务器的任务。模块中有以下类代表同步服务器:

这些类与相应的 RequestHandler 类一起工作以实现服务。BaseServer 是模块中所有 Server 对象的超类。

TCPServer 类使用互联网 TCP 协议,在客户端和服务器之间提供连续的数据流。构造函数自动尝试调用 server_bind() 和 server_activate()。其他参数传递给 BaseServer 基类。

你还必须创建 StreamRequestHandler 类的子类。它提供 self.rfile 和 self.wfile 属性来读取或写入获取请求数据或将数据返回给客户端。

UDPServer 和 DatagramRequestHandler — 这些类是用于 UDP 协议的。

DatagramRequestHandler 和 UnixDatagramServer — 这些类使用 Unix 域套接字;它们在非 Unix 平台上不可用。

服务器代码

你必须编写一个 RequestHandler 类。每当有连接到服务器时,都会实例化一次,并且必须覆盖 handle() 方法来实现与客户端的通信。

import socketserver

class MyTCPHandler(socketserver.BaseRequestHandler):
    def handle(self):
        self.data = self.request.recv(1024).strip()
        host, port = self.client_address
        print("{}:{} wrote:".format(host, port))
        print(self.data.decode())
        msg = input("enter text .. ")
        self.request.sendall(msg.encode())

在服务器分配的端口号上,TCPServer 类的对象调用 forever() 方法将服务器置于监听模式并接受来自客户端的传入请求。

if __name__ == "__main__":
    HOST, PORT = "localhost", 9999
    with socketserver.TCPServer((HOST, PORT), MyTCPHandler) as server:
        server.serve_forever()

客户端代码

在使用 socketserver 时,客户端代码与 socket 客户端应用程序或多或少是相似的。

import socket
import sys

HOST, PORT = "localhost", 9999

while True:
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
        # 连接到服务器并发送数据
        sock.connect((HOST, PORT))
        data = input("enter text .. ")
        sock.sendall(bytes(data + "\n", "utf-8"))
        
        # 从服务器接收数据并关闭
        received = str(sock.recv(1024), "utf-8")
        print("Sent: {}".format(data))
        print("Received: {}".format(received))

在其中一个命令提示符终端中运行服务器代码。为客户端实例打开多个终端。你可以模拟服务器与多个客户端之间的并发通信。

服务器 | 客户端-1 | 客户端-2

D:\socketsrvr>python myserver.py

127.0.0.1:54518 wrote:

from client-1

enter text ..

hello

127.0.0.1:54522 wrote:

how are you

enter text ..

fine

127.0.0.1:54523 wrote:

from client-2

enter text ..

hi client-2

127.0.0.1:54526 wrote:

good bye

enter text ..

bye bye

127.0.0.1:54530 wrote:

thanks

enter text ..

bye client-2

D:\socketsrvr>python myclient.py

enter text .. .

from client-1

Sent:

from client-1

Received: hello

enter text .. .

how are you

Sent:

how are you

Received: fine

enter text .. .

good bye

Sent: good bye

Received: bye bye

enter text .. .

D:\socketsrvr>python myclient.py

enter text .. .

from client-2

Sent:

from client-2

Received: hi client-2

enter text .. .

thanks

Sent: thanks

Received:

bye client-2

enter text .. .
上一章 下一章
阅读号二维码

关注阅读号

联系二维码

联系我们

© 2024 Yoagoa. All rights reserved.

粤ICP备18007391号

站点地图