c++ - ZeroMQ:使用EPGM传输

我正在尝试在简单的发布者－订阅者程序中使用epgm传输，但无法这样做。据我了解，我无法在bind和connect语句中提供正确的地址字符串。

发布者和订阅者可以在相同或不同的计算机上运行。

以下是使用tcp传输并正常工作的必需代码。它使用cppzmq:https://github.com/zeromq/cppzmq。

发布者代码:

#include <zmq.hpp>
#include <stdio.h>
#include <stdlib.h>
#include <time.h>
#include <unistd.h>

int main () {
  zmq::context_t context (1);
  zmq::socket_t publisher (context, ZMQ_PUB);
  publisher.bind("tcp://10.1.1.8:5000");

  int i = 0;
  while (1) {
    int topic = 101;

    zmq::message_t message(50);
    snprintf ((char *) message.data(), 50, "%03d %10d %10d", topic, i, i);
    //fprintf(stderr, "message: %s\n", (char *) message.data());

    publisher.send(message);
    ++i;
  }
  return 0;
}

订户代码:

#include <zmq.hpp>
#include <iostream>
#include <sstream>
#include <unistd.h>
#include <cassert>

int main (int argc, char *argv[]) {
  zmq::context_t context (1);

  zmq::socket_t subscriber (context, ZMQ_SUB);
  subscriber.connect("tcp://10.1.1.8:5000");

  const char *filter = "101 ";
  subscriber.setsockopt(ZMQ_SUBSCRIBE, filter, strlen (filter));

  zmq::message_t tp;

  int maxx = 0;
  for (int i = 0; i < 1000; ++i) {
    zmq::message_t update;
    int topic, a, b;
    if(subscriber.krecv(&update, ZMQ_DONTWAIT)) {
      //fprintf(stderr, "size of data received: %zd\n", sizeof(update.data()));
      std::istringstream iss(static_cast<char*>(update.data()));
      iss >> topic >> a >> b;
      assert(a == b);
    }
    else {
      --i;
    }

    maxx = a > maxx ? a : maxx;
  }

  fprintf(stderr, "maxx = %d\n", maxx);
  return 0;
}

订户中使用的krecv方法:

inline bool krecv (message_t *msg_, int flags_ = 0) {
  int nbytes = zmq_msg_recv (&(msg_->msg), ptr, flags_);
  if (nbytes >= 0)
    return true;
  if (zmq_errno () == EAGAIN)
    return false;
  return false;
}

我尝试将Publisher中的bind语句更改为以下内容:

publisher.bind("epgm://10.1.1.8:5000");

publisher.bind("epgm://224.1.1.1:5000");

publisher.bind("epgm://eth0;224.1.1.1:5000");

publisher.bind("epgm://10.1.1.8;224.1.1.1:5000");

publisher.bind("epgm://localhost:5000");

对于所有5种情况，该程序均使用Assertion failed: false (src/pgm_socket.cpp:165)崩溃。对于第5种情况(epgm://localhost:5000)，我还会在崩溃时收到以下警告:

Warn: Interface lo reports as a loopback device.
Warn: Interface lo reports as a non-multicast capable device.

我该如何解决这个问题？我猜地址的更改在发布者和订阅者中都一样吗？

我正在使用libpgm 5.2.122和zeromq-4.1.3。

请注意，该机器具有以下接口(interface):

eth0(以太网)-inet地址:10.1.1.8

ib0(InfiniBand)-inet地址:10.1.3.8

lo(本地环回)-inet地址:127.0.0.1

最佳答案

在您的绑定(bind)中尝试239.0.0.0/8 IP:
publisher.bind("epgm://;239.0.0.1:5000");
Wikipedia:

关于c++ - ZeroMQ:使用EPGM传输，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/33489552/