zmqxsub/xpub实现消息订阅（一）

xpub/xsub官网的解释是增强了pub/sub模式&＃xff0c;并且支持双向消息收发。经过阅读其源码&＃xff0c;发现xpub/xsub不仅仅是增强了pub/sub&＃xff0c;还有些许改动&＃xff0c;如&＃xff1a;在xsub类型的socket上不能设置subscribe选项&＃xff1a;zmq_setsocket(socket,ZMQ_SUBSCRIBE,0x01);

会报不支持的错误&＃xff0c;那么&＃xff0c;xsub类型的socket到底该如何达到订阅消息的目的呢&＃xff1f;

1、官网的&＃xff1a;https://rfc.zeromq.org/spec/29/  竟然没有解释。。。。有点神操作了

2、http://api.zeromq.org/3-2%3azmq-socket#toc12  的ZMQ_XSUB有说明&＃xff0c;如下&＃xff08;不翻译了&＃xff09;&＃xff1a;

     Same as ZMQ_SUB except that you subscribe by sending subscription messages to the socket. Subscription message is a byte 1 (for subscriptions) or byte 0 (for unsubscriptions) followed by the subscription body.

做个简单的解释&＃xff1a;ZMQ_XSUB通过发送订阅消息来订阅topic——以1开 头的消息是订阅&＃xff0c;以0开头的消息是取消订阅&＃xff1b;

如&＃xff1a;1、发送1"md.sse"&＃xff0c;则表示订阅md.sse这个topic

        2、发送1"md",则表示订阅md这个topic                 

        3、发送1则表示订阅所有的消息&＃xff0c;默认不订阅消息&＃xff0c;所以会接收不到。。。。

   #1"md"没有写错&＃xff0c;可以建一个buf&＃xff0c;把1和topic写到buf中&＃xff0c;再发送&＃xff1b;如&＃xff1a;        

std::string msg(1,0x1);
msg.append("md.sse");
xsub_socket.send(msg);  #订阅了md.ssetopic    #这里使用的是zmqpp库&＃xff0c;直接使用libzmq也是类似的

解释以下&＃xff1a;

58行&＃xff1a;从输入的topics中查找有没有,&＃xff0c;如果有&＃xff0c;则说明包含了多个topic&＃xff0c;

60行&＃xff1a;以逗号为分割符分割topic&＃xff0c;并存储在topic中&＃xff0c;

65行&＃xff1a;订阅topic

70行&＃xff1a;订阅topic

实例代码后面再上传