Python 抢票代码优化：重试机制、并发请求及扩展建议

本文将继续完善和延伸之前的抢票代码，并提供一些优化建议，帮助你打造更强大的抢票工具。

import requests
import time
import threading

def book_ticket(url, data, retries=3):
    for _ in range(retries):
        response = requests.post(url, data=data)
        if response.status_code == 200:
            result = response.json()
            if result.get('success'):
                print('抢票成功！订单号：', result['order_id'])
                return True
            else:
                print('抢票失败：', result.get('message'))
        else:
            print('请求失败，状态码：', response.status_code)
        
        # 添加适量的延迟，避免频繁请求
        time.sleep(1)
    
    print('抢票失败，重试次数超过限制')
    return False

def book_tickets_concurrently(url, data, num_threads=5, retries=3):
    def book_ticket_thread():
        book_ticket(url, data, retries)

    threads = []
    for _ in range(num_threads):
        thread = threading.Thread(target=book_ticket_thread)
        threads.append(thread)
        thread.start()

    for thread in threads:
        thread.join()

def main():
    event_id = '12345'  # 活动 ID
    url = f'https://api.example.com/book_tickets/{event_id}'  # 抢票接口 URL

    # 构造抢票请求数据
    data = {
        'user_id': 'user123',
        'ticket_type': 'VIP',
        'quantity': 2
    }

    # 并发抢票
    book_tickets_concurrently(url, data, num_threads=5, retries=3)

if __name__ == '__main__':
    main()

在这个版本中，我们进行了如下改进和扩展：

重试机制：book_ticket 函数中添加了重试机制，可以指定重试次数，并在请求失败时进行重试。
并发请求：添加了一个新的函数 book_tickets_concurrently，该函数按照指定的线程数并发地进行抢票请求。
调用并发函数：在 main 函数中调用 book_tickets_concurrently 并传递相应的参数，实现并发抢票。

进一步扩展

根据需求，你还可以进一步完善代码，例如：

添加验证码识别逻辑
使用线程池或异步库来控制并发
将抢票结果保存到文件
添加更详细的日志记录
完善错误处理机制

希望这些建议能帮助你继续完善和延伸抢票代码！如果你有其他问题，请随时提问。