2

我尝试使用 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://。两个程序都在运行，但没有收到任何消息。我错过了什么？我不明白可能出了什么问题。

4

1 回答 1

0

对于问题的后来访问者，代码很好并且正在运行。要查看它是否适用于您的系统，请将 for 循环更改为一个循环，并将发布者中的邮政编码设置为 10001，如果您在没有参数的情况下启动订阅者。

于 2017-10-24T21:43:04.237 回答