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

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

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

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

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

// 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
加入于:
帖子: 4550
声望: 325

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

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

已经解决了!谢了

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

请问您是怎么操作的呢?我也遇到这个问题了

Member
avatar
加入于:
帖子: 5080
声望: 306

可以参考4楼

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

沪公网安备 31011502017034号

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