感谢蒋老师等高手，让我知道了redis和qmt，从10月开始开通券商、开通qmt权限，部署服务器、写收发代码，目前实盘运行正常，一点小经验分享一下： 1、需要聚宽策略、redis服务器（自己部署或者redis cloud）和qmt客户端（多个券商支持，有的听说不支持云服务器，那就只能用自己电脑跑，国金可以虚拟机）。我有一台六七年前的老群晖，安装了redis套件，经测试响应速度非常快，群晖上还装了一台win2016的虚拟机运行qmt，J3455的CPU居然也勉强能跑得动，而且下单飞快，测试期间曾经误操作十秒内下了上百个废单。 ``` 聚宽推送到redis服务器，qmt客户端接收指令进行交易，交易后删除redis信号 ``` 2、聚宽推redis： ``` import redis order = order_target_value(security, value) if order != None and order.filled > 0: #推送redis交易指令 push_redis('buy', security, order.filled) #buy或者sell def push_redis(action,stock,amount): rs = redis.Redis(host='redis服务器IP或域名，IPv6可能要改配置文件', port=6379, db=0, password='公网上怎么也得设置一个密码') qmt_order = {} qmt_order['strategy'] = '策略名' qmt_order['action'] = action # buy 或者 sell qmt_order['stock'] = stock[:7] + ('SH' if stock[-1]=='G' else 'SZ') qmt_order['amount'] = amount rs.xadd('myredis', qmt_order) rs.connection_pool.disconnect() ``` 3、qmt接收指令进行交易，这个不会死循环，可以并行其他策略，例如盘后闲置资金自动逆回购 ``` ContextInfo.run_time('redis_stream', '500nMilliSecond', '2023-10-28 20:58:00') #半秒检测一次信号足矣 def redis_stream(ContextInfo): r = redis.Redis(host='redis服务器', port=6379, db=0, password='密码', decode_responses=True) order_list = r.xrange('myredis') for order_info in order_list: if order_info[1]['action'] in ('buy', 'sell'): qmt交易函数 r.xdel('myredis', order_info[0]) #交易后删除信号 r.connection_pool.disconnect() ``` 4、有时候需要给一个实盘策略增减资金，那么先在研究里建一个文件：cashinout.txt，内容很简单：{"策略A": 0, "策略B": 0}，以后哪个策略想增减资金，就写正数或者负数，例如： {"策略A": 30000, "策略B": -20000} 然后每天盘前定时执行一下代码： ``` import json Cash_inout = json.loads(read_file('cashinout.txt')) if Cash_inout['策略名'] != 0: inout_cash(Cash_inout['策略名']) Cash_inout['策略名'] = 0 write_file('cashinout.txt',json.dumps(Cash_inout)) ``` 5、为了让实盘持仓与策略一致，目前我下单时用的是买五卖五，跟踪发现委托价和成交价相差最小的只有1分钱，那还是有不能成交的风险，不知道大家有什么保障成交的好办法。