cfdaily
72 lines
1.9 KiB
Python
72 lines
1.9 KiB
Python
#!/usr/bin/env python3
|
|
"""
|
|
VNPY RPC 交易核心服务启动脚本
|
|
启动 vnpy 交易核心，开启 RPC 服务端，供 VNPY Web Trader 连接
|
|
|
|
按照 vnpy 官方标准双进程架构：
|
|
- 这个进程：交易核心 + RPC 服务端 (端口 2018/4102)
|
|
- 另一个进程：VNPY Web Trader (端口 8000)
|
|
"""
|
|
|
|
from vnpy.trader.event_engine import EventEngine
|
|
from vnpy.trader.main_engine import MainEngine
|
|
from vnpy.rpc import RpcServer
|
|
|
|
# 导入你的 gateway
|
|
from vnpy_ctp import CtpGateway
|
|
# from vnpy_tap import TapGateway
|
|
# from vnpy_ib import IbGateway
|
|
# 其他 gateway 根据需要添加
|
|
|
|
# 导入你的策略应用
|
|
from vnpy_ctastrategy import CtaStrategyApp
|
|
# from vnpy_portfoliostrategy import PortfolioStrategyApp
|
|
# from vnpy_spreadtrading import SpreadTradingApp
|
|
|
|
|
|
def main():
|
|
# 创建事件引擎和主引擎
|
|
event_engine = EventEngine()
|
|
main_engine = MainEngine(event_engine)
|
|
|
|
# 添加 gateway
|
|
main_engine.add_gateway(CtpGateway)
|
|
# 如果你有其他gateway，在这里添加
|
|
# main_engine.add_gateway(TapGateway)
|
|
|
|
# 添加策略应用
|
|
main_engine.add_app(CtaStrategyApp)
|
|
# 如果需要其他应用，在这里添加
|
|
# main_engine.add_app(PortfolioStrategyApp)
|
|
|
|
# 启动 RPC 服务端
|
|
# 请求端口: 2018，订阅端口: 4102
|
|
rpc_server = RpcServer(
|
|
main_engine,
|
|
("0.0.0.0", 2018),
|
|
("0.0.0.0", 4102)
|
|
)
|
|
|
|
print("=" * 50)
|
|
print("VNPY RPC 交易核心服务启动")
|
|
print(f"RPC 请求地址: tcp://0.0.0.0:2018")
|
|
print(f"RPC 订阅地址: tcp://0.0.0.0:4102")
|
|
print("请确保已经在 vnpy 配置中配置好你的 gateway")
|
|
print("=" * 50)
|
|
|
|
# 启动 RPC 服务
|
|
rpc_server.start()
|
|
|
|
# 保持进程运行
|
|
print("RPC 服务已启动，按 Ctrl+C 退出")
|
|
try:
|
|
input()
|
|
except (KeyboardInterrupt, EOFError):
|
|
pass
|
|
|
|
print("RPC 服务退出")
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|