ZeroMQ接口函数之 :zmq_poll - I/O多路技术

简介:

Name

zmq_poll - I/O多路技术

Synopsis

int zmq_poll (zmq_pollitem_t *items, int nitems, long timeout);

Description

zmq_poll()函数为应用程序提供了一种对一组socket进行多路I/O事件水平触发的机制。items参数指向的数组中的每一个元素都是一个zmq_pollitem_t结构体。nitems参数指定了items数组里面的元素个数。zmq_pollitem_t结构的敌营如下所示:

复制代码
typedef struct
{
    void //*socket//;
    int //fd//;
    short //events//;
    short //revents//;
} zmq_pollitem_t;
复制代码

对每一个zmq_pollitem_t项,zmq_poll()函数都会对socket指定的socket或者fd指定的标准socket文件描述符检查其events.参数。如果socketfd的值都进行了设置,则socket参数指定的ZMQ socket会进行优先检查,fd则会被忽略。

对每一个zmq_pollitem_t项,zmq_poll() 函数会首先清除 revents成员变量,然后为任何发生了改变的事件设置当前事件对应的位来指明哪个事件发生了什么变化。

如果在zmq_pollitem_t项中,没有一个请求事件发生,zmq_poll()函数将会等待timeout毫秒后返回。如果timeout参数的值是0zmq_poll()函数会立即返回。如果timeout值是 -1zmq_poll()则会进入无限阻塞等待状态,直到至少一个zmq_pollitem_t项上请求的事件发生了。

zmq_pollitem_t结构中的eventsrevents成员是由以下标志进行位与和或操作组成的:

  ZMQ_POLLIN

    对于ZMQ socket来说,至少有一个消息在这个socket上被非阻塞的接收到了。对于标准socket来说,此标志和系统调用的poll()函数的POLLIN标志等价,而且通常意味着,fd文件描述符上至少非阻塞的接收到了1B的数据。

  ZMQ_POLLOUT

    对于ZMQ socket来说,至少有一个消息使用非阻塞模式发送了。对于标准socket来说,此标志和系统调用poll()函数的POLLOUT标志等价,这通常意味着至少有1B的数据使用非阻塞模式写到了fd文件描述符里面。

  ZMQ_POLLERR

    对于标准socket来说,这个标志通过zmq_poll()传递给底层的系统调用poll(),通常此标志意味着fd上出现了一些错误。对于ZMQ socket来说,这个标志在events中不会造成影响,而且此标志不会出现在revents中被zmq_poll()返回。

字应用的时候应该优先使用zmq_poll()而不是系统调用poll()。在使用poll()函数的时候有些方法可能会受到本文档中没有定义的限制。

Return value

如果执行成功,zmq_poll()函数会返回被标记了事件的zmq_pollitem_t结构体的数目,如果返回0,说明没有事件发生。如果执行失败,则返回 -1, 并且设置errno的值为下列定义的值。

Errors

  ETERM

    在items给出的数组中,至少有一个socket相联系的ZMQ context已经被终结了。

  EFAULT

    items参数不可用(NULL

  EINTR

    在任何事件响应之前,这个操作被系统信号中断了。

Example

  阻塞方式响应ZMQ socket和标准系统socket

复制代码
zmq_pollitem_t items [2];
/* First item refers to ØMQ socket 'socket' */
items[0].socket = socket;
items[0].events = ZMQ_POLLIN;
/* Second item refers to standard socket 'fd' */
items[1].socket = NULL;
items[1].fd = fd;
items[1].events = ZMQ_POLLIN;
/* Poll for events indefinitely */
int rc = zmq_poll (items, 2, -1);
assert (rc >= 0); /* Returned events will be stored in items[].revents */
复制代码

See also

zmq_socket(3) zmq_send(3) zmq_recv(3) zmq(7)

你操作系统中对poll()系统调用的文档。

Authors

This page was written by the ØMQ community. To make a change please read the ØMQ Contribution Policy at http://www.zeromq.org/docs:contributing.

Web site design and content is copyright (c) 2007-2012 iMatix Corporation. Contact us for professional support. Site content licensed under the Creative Commons Attribution-Share Alike 3.0 License. ØMQ is copyright (c) Copyright (c) 2007-2012 iMatix Corporation and Contributors. ØMQ is free software licensed under the LGPL. ØMQ, ZeroMQ, and 0MQ are trademarks of iMatix Corporation. Terms of Use — Privacy

Policy

 


本文转自郝峰波博客园博客,原文链接:http://www.cnblogs.com/fengbohello/p/4257438.html,如需转载请自行联系原作者

相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
3月前
|
网络协议 数据处理 C语言
利用C语言基于poll实现TCP回声服务器的多路复用模型
此代码仅为示例,展示了如何基于 `poll`实现多路复用的TCP回声服务器的基本框架。在实际应用中,你可能需要对其进行扩展或修改,以满足具体的需求。
96 0
|
7月前
|
Unix
poll 函数 I/O 多路复用的技术
【4月更文挑战第14天】poll 是另一种在各种 UNIX 系统上被广泛支持的 I/O 多路复用技术,虽然名声没有 select 那么响,能力一点不比 select 差,而且因为可以突破 select 文件描述符的个数限制,在高并发的场景下尤其占优势。
|
7月前
|
消息中间件 Unix Linux
【ZMQ polling机制】ZMQ异步接收机制以及与epoll/select的对比分析
【ZMQ polling机制】ZMQ异步接收机制以及与epoll/select的对比分析
507 0
|
消息中间件 负载均衡 网络协议
ZMQ/ZeroMQ的三种消息模式
ZMQ/ZeroMQ的三种消息模式
ZMQ/ZeroMQ的三种消息模式
|
7月前
|
Unix Linux API
高性能网络编程 - select、 poll 、epoll 、libevent
高性能网络编程 - select、 poll 、epoll 、libevent
96 0
ZMQ之处理多个套接字(zmq_poll函数)
ZMQ之处理多个套接字(zmq_poll函数)