node.js - 为什么ZeroMQ消息会被扰乱？

Question

我正在使用nodejs调用我的tcp订阅者来读取消息。

var zmq = require("zeromq"),
sock = zmq.socket("sub");
sock.connect("tcp://pubsub.besteffortc.com:7658");
sock.subscribe("/ASD/Travel");
console.log("Subscriber connected to port 3000");

sock.on("message", function(topic, message) {
  console.log(
    "received a message related to:",
    topic.toString(),
    "containing message:",
    message.toString()
  );
});

我得到的输出如下。可能是什么问题？- 难道我的 IP 地址需要列入白名单才能看到实际数据吗？

注意:主题和 URL 名称不是实际值，而是虚拟值。

Answer 1

Q : What might be the issue ?

ZeroMQ 中有一个确定点 - 如果消息完全被传递(Zen-of-Zero 对此不构成任何保证)，那么它肯定是消息的精确逐位副本，发起者(本例中的 PUB )打算 .send()

如果您 .recv() 任何内容(无论是通过 native API 级别 .recv() 方法还是提供的包装器 .on( "message ", f(...){...} )-handler )，请确保它携带由发起者提供的有效负载的 1:1 位图(除非您的语言包装器做了一个肮脏的工作来混淆您的使用记录的 ZeroMQ API，产生一些令人讨厌的垃圾(我不会打赌，但这可能是一个问题 - 尝试任何其他 ZeroMQ 消息源，这是在你自己的控制下，看看这种情况是否发生))

Q : can it be that my IP address needs to be whitelisted to see actual data ?

正如上面详细解释的，这个项目不是 ZeroMQ 问题。如果您的应用程序级别/ISO-OSI-above-5 行为取决于签订某种形式的 abonnement，只有在此之后您才获得“访问验证”(无论是通过白名单还是其他类型)，那么您的问题仍然存在于业务领域，而不是编程。

ZeroMQ 与此无关。 ZMQ/RFC 文档在每个 ZeroMQ 服务组合上都是明确的，并为随机或未记录的行为留下零空间。