Пример C ++ и Python ZeroMQ 4.x PUB / SUB не работает

_{«Я думаю, я должен получить все, если я не установлю это, верно?«}

_{Нет, это неверное предположение. Вам может понравиться коллекция из моих других сообщений ZeroMQ здесь, о {обычная строка | Юникод | сериализация} -популярные и {производительность- | Traffic-} — влияет на текущую политику ( SUB-обработка стороннего тематического фильтра в ранних версиях ZeroMQ и / или PUB-боковая обработка для более свежих) можно встретиться при проектировании гетерогенных распределенных систем с использованием ZeroMQ.}

_{(Любая другая масштабируемая модель архетипа формального общения, подобная наблюдаемой PUSH/PULL, ничего не делает с политикой подписки, поэтому будет работать независимо от обработки сопоставления подписки с заданным списком фильтра тем. )}

Шаг 0: сначала проверьте RTO отправляющей части, если он .send()Что-нибудь вообще

Давайте смоделируем быстрый питонический приемник, чтобы увидеть, действительно ли отправитель отправляет что-либо по линии:

import zmq

aContext = zmq.Context()                                          # .new Context
aSUB     = aContext.socket( zmq.SUB )                             # .new Socket
aSUB.connect( "tcp://127.0.0.1:5563" )                            # .connect
aSUB.setsockopt( zmq.LINGER, 0 )                                  # .set ALWAYS!
aSUB.setsockopt( zmq.SUBSCRIBE, "" )                              # .set T-filter

MASK = "INF: .recv()-ed this:[{0:}]\n:     waited {1: > 7d} [us]"aClk = zmq.Stopwatch();

while True:
try:
aClk.start(); print MASK.format( aSUB.recv(),
aClk.stop()
)
except ( KeyboardInterrupt, SystemExit ):
pass
break
pass
aSUB.close()                                                     # .close ALWAYS!
aContext.term()                                                  # .term  ALWAYS!

Это должно сообщать обо всем PUB-отправитель на самом деле .send()— по телеграфу, а также по фактическому времени прибытия сообщений (в [us]Я рад, что ZeroMQ включил этот инструмент для отладки и настройки производительности / задержки.

Если ACK-ред, как вы видите в прямом эфире INF:-сообщения на самом деле тикают на экране, продолжайте работать, и теперь имеет смысл перейти к следующему шагу.

Шаг 1: Проверьте код получающей части следующим образом:

#include <zmq.h>
void *aContext = zmq_ctx_new();
void *aSUB     = zmq_socket(     aContext, ZMQ_SUB );               std::cout << "INF: .. zmq_ctx_new() done" << std::endl;
zmq_connect(    aSUB,    "tcp://127.0.0.1:5563" ); std::cout << "INF: .. zmq_connect() done" << std::endl;
zmq_setsockopt( aSUB,     ZMQ_SUBSCRIBE, "", 0 );  std::cout << "INF: .. zmq_setsockopt( ZMQ_SUBSCRIBE, ... ) done" << std::endl;
zmq_setsockopt( aSUB,     ZMQ_LINGER,        0 );  std::cout << "INF: .. zmq_setsockopt( ZMQ_LINGER, ...    ) done" << std::endl;
int rc;
while (true) {
zmq_msg_t       msg;                            /*       Create an empty ØMQ message */
rc = zmq_msg_init  (&msg);          assert (rc ==  0 && "EXC: in zmq_msg_init() call" );
std::cout << "INF: .. zmq_msg_init() done" << std::endl;
rc = zmq_msg_recv  (&msg, aSUB, 0); assert (rc != -1 && "EXC: in zmq_msg_recv() call" );
std::cout << "INF: .. zmq_msg_recv() done: received [" << (char * ) zmq_msg_data( &msg ) << "]" << std::endl;
zmq_msg_close (&msg);                           /*       Release message */
std::cout << "INF: .. zmq_msg_close()'d" << std::endl;
}
zmq_close(    aSUB );                          std::cout << "INF: .. aSUB was zmq_close()'d" << std::endl;
zmq_ctx_term( aContext );                      std::cout << "INF: .. aCTX was zmq_ctx_term()'d" << std::endl;