vn.py量化社区
By Traders, For Traders.
Member
avatar
加入于:
帖子: 11
声望: 0

使用rpc_gateway接口的时候,在def connect()方法里面通过self.client.subscribe_topic("")设置过滤条件,不过设置什么都没有效果。
例子:
只监听心跳包
代码为 self.client.subscribe_topic("_keep_alive")
设置完毕后就收不到信息了,后台确定发送了,但是前台就接收不到,然后又实验了其他的(把后台信息都加上分类头部,但是都收不到)
对zmq不是很了解,请解答!

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

经过序列化以后这个过滤就无效了,对zmqapi不了解,看看有没有别的办法吧!

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

// pub
self.socket.send_multipart([b'status',pickle.dumps(msg2)])

// sub
socket.setsockopt(zmq.SUBSCRIBE, 'status')
[topic,msg] = socket.recv_multipart()
msg2 = pickle.loads(msg)

Administrator
avatar
加入于:
帖子: 2976
声望: 133

subscribe_topic过滤,要在启动连接前设置,检查下是不是这里的问题?

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

已经解决了!谢了

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