java - 具有以相同字符串开头的过滤器的 ZeroMQ (cppzmq) 订阅者
问题描述
我在示例发布者中使用了两个主题。两者都以相同的字符串开头。当我仅使用两个主题之一过滤订阅者中的消息时,订阅者会收到两个主题
如果我使用两个不同的主题,它会起作用
我的示例发布者
try (ZContext context = new ZContext()) {
final ZMQ.Socket socket = context.createSocket(SocketType.PUB);
socket.bind("tcp://*:5555");
int i = 0;
while (!Thread.currentThread().isInterrupted() && !stopped) {
logger.debug("sending C1 message");
final String env = "topic";
final String msg = "Hello, world #" + i++;
socket.sendMore(env);
socket.send(msg);
logger.debug("sending C2 message");
final String env2 = "topic2";
final String msg2 = "Hello, world #" + i++;
socket.sendMore(env2);
socket.send(msg2);
try {
sleep(5000);
} catch (final InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
我的示例订阅者:
zmq::context_t ctx;
zmq::socket_t sock(ctx, zmq::socket_type::sub);
sock.connect("tcp://127.0.0.1:5555");
std::string filter="topic";
sock.setsockopt(ZMQ_SUBSCRIBE,filter.c_str(),filter.length());
while(true) {
zmq::message_t env;
sock.recv(&env);
std::string env_str = std::string(static_cast<char*>(env.data()), env.size());
std::cout << "Received Enveloppe '" << env_str << "'" << std::endl;
zmq::message_t msg;
sock.recv(&msg);
std::string msg_str = std::string(static_cast<char*>(msg.data()), msg.size());
std::cout << "Received '" << msg_str << "'" << std::endl;
}
我的订阅者应该只显示与主题“主题”相关的消息,而不是两者。
解决方案
声明: “我的订阅者应该只显示与主题“主题”相关的消息,而不是同时显示两者。”
不正确,恰恰相反。
文档很清楚。ZeroMQ API 明确指出:
非空
option_value
应订阅以指定前缀开头的所有消息。多个过滤器可以附加到单个 ZMQ_SUB 套接字,在这种情况下,如果一条消息与至少一个过滤器匹配,则应接受该消息。
+-----------+---------------+
| 期权价值类型 | 二进制数据 |
+-----------+---------------+
示例:
一条消息,在PUB
-side 发送为:
PUB.send( "123456------------" );
.recv()
将在以下任一订阅的 -s 上获得-ed SUB
:
SUB.setsockopt( zmq.SUBSCRIBE, "" ); // this one .recv()-es EVERY message
SUB.setsockopt( zmq.SUBSCRIBE, "1" ); // this one .recv()-es "1{0+[*]}"
SUB.setsockopt( zmq.SUBSCRIBE, "12" ); // this one .recv()-es "12{0+[*]}"
SUB.setsockopt( zmq.SUBSCRIBE, "123" );// this one .recv()-es "123{0+[*]}"
推荐阅读
- java - 接口序列化
- java - 如何从 Jenkins 启动 java 服务
- python - 有没有办法让 gensim LDA 自动选择最佳主题数量
- javascript - 将应用程序部署到 Heroku 后无法获取 API 数据(在本地完美运行)
- reactjs - 如何使用 React JS 在 Redirect 上执行函数
- php - 为什么无法识别用于重新登录的 Laravel League/ouath2 令牌
- javascript - 对数组对象内的数组元素执行操作
- php - 将对象数组转换为 Vue js 和 php 中的对象
- javascript - 画布在 60Hz 显示器上闪烁,在 144Hz 显示器上工作正常
- ansible - Openstack train aio 安装问题