Не получайте сообщения с epgm://, а с tcp:// do. Зачем?

Question

Я пытаюсь использовать пример погоды из руководства ZeroMQ, с epgm:// транспорт класса. Сначала мой код:

// Publisher

#include "zhelpers.h"

int main (void) {
    //  Prepare our context and publisher
    void *context = zmq_ctx_new ();
    void *publisher = zmq_socket ( context, ZMQ_PUB );
    // int rc = zmq_bind ( publisher, "tcp://*:5556" );
       int rc = zmq_bind ( publisher, "epgm://192.168.1.4;224.0.0.251:5556" );
    assert ( rc == 0 );

    //  Initialize random number generator
    srandom ( (unsigned) time (NULL) );
    while (1) {
        //  Get values that will fool the boss
        int zipcode, temperature, relhumidity;
        zipcode     = randof (100000);
        temperature = randof (215) - 80;
        relhumidity = randof (50) + 10;

        //  Send a message to all subscribers
        char update [20];
        sprintf ( update, "%05d %d %d", zipcode, temperature, relhumidity );
        s_send ( publisher, update );
    }
    zmq_close ( publisher );
    zmq_ctx_destroy ( context );
    return 0;
}

---

    // Subscriber
    #include "zhelpers.h"

    int main ( int argc, char *argv [] )
    {
        //  Socket to talk to server
        printf ( "Collecting updates from weather server…\n" );
        void *context = zmq_ctx_new ();
        void *subscriber = zmq_socket ( context, ZMQ_SUB );
        // int rc = zmq_connect ( subscriber, "tcp://192.168.1.4:5556" );
           int rc = zmq_connect ( subscriber, "epgm://192.168.1.9;224.0.0.251:5556" );
        assert ( rc == 0 );

        //  Subscribe to zipcode, default is NYC, 10001
        char *filter = ( argc > 1 )? argv [1]: "10001 ";
        rc = zmq_setsockopt ( subscriber, ZMQ_SUBSCRIBE,
                              filter, strlen (filter) );
        assert ( rc == 0 );

        //  Process 100 updates
        int update_nbr;
        long total_temp = 0;
        for ( update_nbr = 0; update_nbr < 100; update_nbr++ ) {
            char *string = s_recv ( subscriber );

            int zipcode, temperature, relhumidity;
            sscanf ( string, "%d %d %d",
                    &zipcode, &temperature, &relhumidity );
            total_temp += temperature;
            free ( string );
        }
        printf ( "Average temperature for zipcode '%s' was %dF\n",
            filter, (int) ( total_temp / update_nbr ) );

        zmq_close ( subscriber );
        zmq_ctx_destroy ( context );
        return 0;
    }

1. Я пробовал этот код с tcp:// на тех же хостах (см. комментарии) и работает нормально.
2. Я попробовал многоадресный адрес в этом примере Openbook Linux (с моим многоадресным адресом), и я получил сообщения.
3. Я установил ZeroMQ с pgm:// (до того, как я получил ошибки утверждения).
4. Мои хосты - системы Ubuntu 16.04
5. Я использую ZeroMQ 4

Моя проблема в том, что я не получаю никаких сообщений с epgm://, Обе программы работали, но сообщения не были получены. Что мне не хватает? Я не понимаю, что может быть не так.

Answer 1

Для более поздних посетителей вопроса, код в порядке и работает. Чтобы проверить, работает ли он в вашей системе, измените цикл for на один цикл и установите почтовый индекс в издателе на 10001, если вы запускаете подписчика без аргумента.