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")