使用rpc_gateway接口的时候,在def connect()方法里面通过self.client.subscribe_topic("")设置过滤条件,不过设置什么都没有效果。
例子:
只监听心跳包
代码为 self.client.subscribe_topic("_keep_alive")
设置完毕后就收不到信息了,后台确定发送了,但是前台就接收不到,然后又实验了其他的(把后台信息都加上分类头部,但是都收不到)
对zmq不是很了解,请解答!
使用rpc_gateway接口的时候,在def connect()方法里面通过self.client.subscribe_topic("")设置过滤条件,不过设置什么都没有效果。
例子:
只监听心跳包
代码为 self.client.subscribe_topic("_keep_alive")
设置完毕后就收不到信息了,后台确定发送了,但是前台就接收不到,然后又实验了其他的(把后台信息都加上分类头部,但是都收不到)
对zmq不是很了解,请解答!
经过序列化以后这个过滤就无效了,对zmqapi不了解,看看有没有别的办法吧!
// 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)
subscribe_topic过滤,要在启动连接前设置,检查下是不是这里的问题?
已经解决了!谢了
请问您是怎么操作的呢?我也遇到这个问题了
可以参考4楼