VeighNa量化社区
你的开源社区量化交易平台
Member
avatar
加入于:
帖子: 3
声望: 0

rpc服务器客户端采用的是zmq的pub sub模式,在这里如果客户端要订阅(subscribe)某一个主题由于其send_pyobj方法的序列化问题无法订阅特定主题,只能通过subscribe“”来订阅所有主题再分类,这样显然是有问题的,请问有合适的解决方案吗?比如send_pyobj应该选取什么形式的订阅/过滤topic?代码如下,是一个rpc client
/#client
from vnpy.rpc import RpcClient
from time import sleep
KEEP_ALIVE_TOPIC: str = "_keep_alive"
rpc_cli = RpcClient()
rpc_cli.subscribe_topic("") /#问题在这里,下面那条语句是没用的,必须订阅全部主题
rpc_cli.subscribe_topic("_keep_alive")

req_address = "tcp://127.0.0.1:22014" /#fill in your real IP
sub_address = "tcp://127.0.0.1:41007"
rpc_cli.start(req_address, sub_address)

print("Interval")
sleep(100)

Member
avatar
加入于:
帖子: 4618
声望: 284

是在启动连接前设置的subscribe_topic过滤吗?

Member
avatar
加入于:
帖子: 3
声望: 0

xiaohe wrote:

是在启动连接前设置的subscribe_topic过滤吗?
是的

Member
avatar
加入于:
帖子: 4618
声望: 284

看你1楼的写法好像不是在启动连接前设置的呀

© 2015-2022 上海韦纳软件科技有限公司
备案服务号:沪ICP备18006526号

沪公网安备 31011502017034号

【用户协议】
【隐私政策】
【免责条款】