NotZhang

Python 实现

import requests
from concurrent.futures import ThreadPoolExecutor, as_completed
import time

def send_request(payload):
"""发送 HTTP POST 请求到指定的 URL"""
try:
response = requests.post('你的 URL', json=payload)
# 注意：这里我们不处理响应内容
except Exception as e:
print(f"请求发送异常: {e}")

def load_payloads(file_path):
"""从文件中读取每行作为单独的 payload"""
with open(file_path, 'r') as file:
return [line.strip() for line in file]

def main(file_path, max_workers=20):
"""主函数：读取 payloads 并并发发送请求"""
payloads = load_payloads(file_path)
start_time = time.time()
with ThreadPoolExecutor(max_workers=max_workers) as executor:
# 将每个 payload 提交到线程池
future_to_payload = {executor.submit(send_request, payload): payload for payload in payloads}

# 等待所有的请求完成（这一步是可选的，只是为了能够处理可能的异常）
for future in as_completed(future_to_payload):
payload = future_to_payload[future]
try:
future.result() # 如果请求产生异常，这里会抛出
except Exception as exc:
print(f'{payload} 生成了一个异常: {exc}')

print(f"所有请求发送完毕，耗时：{time.time() - start_time:.2f}秒")

if __name__ == "__main__":
main("yourfile.txt")