vnpy/docs/rpc_service.md
2019-07-31 17:01:04 +08:00

3.9 KiB
Raw Blame History

RPC服务

由于全局锁GIL的存在单进程的Python程序只能利用CPU单核的算力为了突破这一限制解决方案就是多进程分布式的程序架构。但每个进程之间的数据在操作系统内默认是独立隔离的无法直接访问。RPC全称Remote-Procedure-Call中文“远程过程调用”是最常用的跨进程通讯方式之一。

以下是单进程架构的一些不足:

以下是RPC服务框架图示

由一个特定的vnpy进程与外部交易接口例如CTP等建立连接然后充当Server的角色在本地物理机或者局域网内部进行事件的推送推送给其他独立的vnpy客户端进程。

RPC服务器

加载模块

在vnpy/app/目录下有rpc_service文件夹里面定义了Rpc引擎对象用于将一个特定的vnpy进程包装成RPC服务器从而进行推送服务端所有事件和处理客户端请求。在加载这个模块时有两种操作方式

  • 使用vnstation登录vnpy的用户在勾选加载模块时将RpcService选中即可。:不要忘记加载所需的外部交易接口。

  • 使用run.py启动Vn Trader的用户在导入模块时额外写from vnpy.app.rpc_service import RpcServiceApp以及在main函数里加载该模块即可main_engine.add_app(RpcServiceApp):不要忘记加载所需的外部交易接口如from vnpy.gateway.ctp import CtpGateway以及在main函数里写main_engine.add_gateway(CtpGateway)

启动运行

按上述步骤成功启动Vn Trader后首先对用户所需的外部交易接口如CTP等进行连接然后点击菜单栏“功能”->“Rpc服务”在如下跳出的窗口中点击“启动”即可运行RPC服务。

RPC服务不仅支持同一物理机多进程通讯还支持局域网内部通讯若在同一台机器上运行无需修改任何参数。

RPC客户端

加载接口

在vnpy/gateway文件夹下定义了rpc的gateway模块有两种不同的加载方式

  • 使用vnstation登录vnpy的用户在勾选底层接口时将RPC服务选中即可。

  • 使用run.py启动Vn Trader的用户在导入模块时额外写from vnpy.gateway.rpc import RpcGateway以及在main函数加载一下即可main_engine.add_gateway(RpcGateway)

连接使用

从客户端的视角看RpcGateway就是一个和CtpGateway等一样的Gateway只是不需要再额外输入账户等信息因为统一在服务端已经完成只需要和服务器端进行连接即可。

在vntrader打开后点击菜单栏”系统“->”连接RPC“在弹出的窗口中点击”连接“即可。

参考样例

位于examples/server_client目录下。

服务器进程

样例提供了run_server.py文件里面定义了main_ui和main_terminal函数分别用于GUI模式和无界面模式启动可以根据需要修改这两个函数然后选择运行某一个函数即可。 GUI模式GUI模式启动和上面提到的run.py启动完全一致只是run_server.py已经默认加载了RPC模块用户只需修改加载的外部交易接口即可。   无界面模式需要提前配置好连接CTP等交易接口所需的个人信息如图

客户端进程

样例提供了run_client.py和上述提到的run.py启动Vn Trader方式完全一致只是这里已经默认加载了Rpc接口。