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)