我正在编写一个想要订阅zeromq pubsub套接字的Nginx模块,并根据收到的消息更新内存中的数据结构.为了节省带宽,有意义的是只有一个进程应该进行订阅,并且数据结构应该是shm,以便所有进程都可以使用它.对我来说,一个进程应该是主人似乎很自然(因为如果它是一个工人,代码必须以某种方式决定哪个工人).

但是当我从init_master或init_module回调调用ngx_get_connection时,它会出现段错误,显然是由于ngx_cycle尚未初始化.谷歌搜索在主进程中工作的插件似乎非常悲观.是否有更好的方法来实现我的目标,即每个服务器与pubsub套接字建立单个传出连接,无论它有多少工作者？

这是一个在工作者上下文中工作的代码示例,但不是来自master：

void *zmq_context = zmq_ctx_new();
void *control_socket = zmq_socket(zmq_context,ZMQ_SUB);
int control_fd;
size_t fdsize = sizeof(int);
ngx_connection_t *control_connection;

zmq_connect(control_socket,"tcp://somewhere:1234");
zmq_setsockopt(control_socket,ZMQ_SUBSCRIBE,"",0);
zmq_getsockopt(control_socket,ZMQ_FD,&control_fd,&fdsize);
control_connection = ngx_get_connection(control_fd,cycle->log);
control_connection->read->handler = my_read_handler;
control_connection->read->log = cycle->log;
ngx_add_event(control_connection->read,NGX_READ_EVENT,0);

和其他地方

void my_read_handler (ngx_event_t *ev) {
    int events;
    size_t events_size = sizeof(events);

    zmq_getsockopt(control_socket,ZMQ_EVENTS,&events,&events_size);
    while (events & ZMQ_POLLIN) {
        /* ...
           read a message,do something with it
        ... */
        events = 0;
        zmq_getsockopt(control_socket,&events_size);
    }
}