如何用Python+ib_insync维持与IB TWS桌面端的持久连接？

核心问题分析 #

• TWS默认55秒无API请求会自动断开连接，这是超时问题的根本原因
• Watchdog未生效通常是两个原因：未正确绑定状态回调函数，或ib_insync事件循环与Qt GUI线程冲突，导致状态变更无法触发通知

正确使用Watchdog的实现方案 #

1. 关键优化点 #

• 将ib_insync的事件循环放入独立QThread，避免阻塞Qt GUI线程
• 用Qt信号槽传递连接状态，确保GUI更新操作在主线程执行（线程安全）
• 明确绑定Watchdog的连接、断开、重连回调，触发状态通知与控制台日志

2. 完整修改代码示例 #

基于你提供的基础逻辑，集成Watchdog并修复线程问题：

from PyQt6.QtWidgets import QMainWindow, QApplication
from PyQt6.QtCore import QThread, pyqtSignal
from ib_insync import IB, Watchdog
import sys

class IBWorker(QThread):
    # 定义信号，用于向GUI线程传递连接状态
    status_updated = pyqtSignal(str)

    def __init__(self):
        super().__init__()
        self.ib = IB()
        self.watchdog = None

    def run(self):
        # 初始化Watchdog并绑定回调
        self.watchdog = Watchdog(
            self.ib,
            host="127.0.0.1",
            port=7497,
            clientId=1,
            onConnected=self.on_connected,
            onDisconnected=self.on_disconnected,
            onReconnected=self.on_reconnected
        )
        # 启动Watchdog监控
        self.watchdog.start()
        # 运行ib_insync事件循环（阻塞线程直到退出）
        self.ib.run()

    def on_connected(self):
        self.status_updated.emit("已连接")
        print("Watchdog: 连接成功")

    def on_disconnected(self):
        self.status_updated.emit("已断开")
        print("Watchdog: 连接断开")

    def on_reconnected(self):
        self.status_updated.emit("重新连接成功")
        print("Watchdog: 重新连接成功")

    def stop(self):
        # 优雅断开流程：先停Watchdog，再断IB连接，最后终止事件循环
        if self.watchdog:
            self.watchdog.stop()
        if self.ib.isConnected():
            self.ib.disconnect()
        self.ib.stop()
        self.wait()

class MainWindow(QMainWindow):
    def __init__(self):
        super().__init__()
        self.ib_worker = IBWorker()
        self.init_ui()
        self.setup_connections()

    def init_ui(self):
        self.setWindowTitle("TWS连接状态: 未连接")
        self.resize(400, 300)

    def setup_connections(self):
        # 绑定状态更新信号到GUI函数
        self.ib_worker.status_updated.connect(self.update_window_title)
        # 启动IB工作线程
        self.ib_worker.start()

    def update_window_title(self, status):
        self.setWindowTitle(f"TWS连接状态: {status}")

    def closeEvent(self, event):
        # 关闭窗口时执行优雅断开
        self.ib_worker.stop()
        event.accept()

if __name__ == "__main__":
    app = QApplication(sys.argv)
    window = MainWindow()
    window.show()
    sys.exit(app.exec())

3. 代码说明 #

• 线程分离：ib_insync的事件循环在独立QThread中运行，不会卡住GUI
• 信号槽通信：通过pyqtSignal传递状态，避免跨线程直接操作GUI导致崩溃
• Watchdog日志：回调函数中添加打印，手动断开TWS时控制台会输出状态变化，方便调试

备选方案：手动发送心跳包 #

如果Watchdog仍有异常，可以手动定时发送API请求维持连接，比如每30秒请求一次账户信息：

# 在IBWorker类中添加定时心跳逻辑
from PyQt6.QtCore import QTimer

def run(self):
    # 先手动建立连接
    try:
        self.ib.connect("127.0.0.1", 7497, clientId=1)
        self.on_connected()
    except Exception as e:
        print(f"初始连接失败: {e}")
        self.status_updated.emit("连接失败")
    
    # 启动心跳定时器，每30秒发送一次请求
    self.heartbeat_timer = QTimer()
    self.heartbeat_timer.timeout.connect(self.send_heartbeat)
    self.heartbeat_timer.start(30000)  # 30秒间隔
    self.ib.run()

def send_heartbeat(self):
    if self.ib.isConnected():
        try:
            # 请求账户摘要作为心跳包
            self.ib.accountSummary()
            print("心跳包发送成功")
        except Exception as e:
            print(f"心跳包发送失败: {e}")
            self.status_updated.emit("连接异常")

优雅断开注意事项 #

• 必须在窗口closeEvent中调用ib.stop()终止ib_insync的事件循环，否则线程无法正常退出
• 断开顺序：先停Watchdog/定时器，再断开IB连接，避免资源泄漏

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