我试图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;
}
我尝试将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.
注意机器有以下接口：
eth0（以太网）--inet 地址：10.1.1.8ib0(InfiniBand) -- inet 地址：10.1.3.8lo（本地环回）--inet 地址：127.0.0.1