Libtorrent 2.0.7 技术问题咨询（Python 3.8环境）

1. 未加载torrent时获取待上传文件，已加载时获取已上传文件路径 #

未加载torrent时 #

如果是读取本地已有的torrent文件，直接构造torrent_info对象遍历所有文件即可：

import libtorrent as lt

# 读取本地torrent文件
ti = lt.torrent_info("your_torrent_file.torrent")
# 遍历所有待上传文件
for file in ti.files():
    print(f"待上传文件: {file.path()}")

如果是自己创建待上传的种子，需先收集本地文件列表，再通过create_torrent生成种子，此时文件列表就是你传入的路径集合。

已加载torrent时 #

通过torrent handle获取种子信息，结合保存路径得到完整文件路径，同时通过文件进度判断是否已上传完成：

import libtorrent as lt

# handle为已加载的torrent_handle对象
ti = handle.torrent_info()
save_path = handle.save_path()
file_progress = handle.file_progress()  # 获取每个文件的已上传字节数

for idx, file in enumerate(ti.files()):
    full_path = f"{save_path}/{file.path()}"
    # 判断文件是否完全上传
    if file_progress[idx] == file.size():
        print(f"已上传文件路径: {full_path}")

2. get_torrent_info()的替代方案 #

直接使用torrent_handle.torrent_info()方法即可，它是get_torrent_info()的替代接口，功能完全一致：

# 替代废弃的handle.get_torrent_info()
ti = handle.torrent_info()

3. 全局session下载速度限制的替代方法 #

原download_rate_limit()方法拆分为设置和获取两个独立接口：

• 设置全局下载限速（单位：字节/秒）：调用session.set_download_rate_limit(limit)
• 获取当前全局下载限速：调用session.download_rate_limit()

示例代码：

import libtorrent as lt

ses = lt.session()
# 设置全局下载限速为1MB/s（1*1024*1024字节）
ses.set_download_rate_limit(1048576)
# 获取当前限速值
current_limit = ses.download_rate_limit()
print(f"当前全局下载限速: {current_limit} 字节/秒")

4. 单torrent排队下载实现方法 #

通过维护下载队列+定期状态检查实现串行下载：

1. 用队列存储待下载的torrent_handle对象，添加时先暂停任务
2. 仅保持一个活跃下载任务，定期检查其状态
3. 活跃任务完成后，自动启动队列中的下一个任务

示例代码：

import libtorrent as lt
from collections import deque
import time

ses = lt.session()
download_queue = deque()
current_active_handle = None

def add_torrent_to_queue(torrent_path):
    global current_active_handle
    # 添加torrent到session并暂停
    ti = lt.torrent_info(torrent_path)
    params = {"save_path": "./downloads", "ti": ti}
    handle = ses.add_torrent(params)
    handle.pause()
    download_queue.append(handle)
    # 无活跃任务时直接启动第一个
    if not current_active_handle:
        start_next_in_queue()

def start_next_in_queue():
    global current_active_handle
    if download_queue:
        current_active_handle = download_queue.popleft()
        current_active_handle.resume()
        print(f"开始下载: {current_active_handle.torrent_info().name()}")
    else:
        current_active_handle = None
        print("所有下载任务已完成")

# 每秒检查一次任务状态
while True:
    if current_active_handle:
        status = current_active_handle.status()
        # 任务完成状态包括播种或已完成
        if status.state in [lt.torrent_status.seeding, lt.torrent_status.completed]:
            print(f"任务完成: {current_active_handle.torrent_info().name()}")
            start_next_in_queue()
    time.sleep(1)

内容的提问来源于stack exchange，提问作者Wintreist