开发者社区> 范大脚脚> 正文

ZeroMQ接口函数之 :zmq_msg_send – 从一个socket发送一个消息帧

简介:
+关注继续查看

Name

zmq_msg_send – 从一个socket发送一个消息帧

Synopsis

int zmq_msg_send (zmq_msg_t *msg, void *socket, int flags);

Description

zmq_msg_send函数和zmq_sendmsg(3)函数是完全相同的,只是zmq_sendmsg(3)在以后的版本中会被弃用。zmq_msg_send()函数在操作性方面和其他消息函数更有一致性。

zmq_msg_send()函数将会使用socket指定的socket,以队列方式(FIFO)将msg参数指定的消息添加到发送队列里面。flags参数由下列标志组合(|)而成:

  ZMQ_DONTWAIT

    指明本次操作使用非阻塞方式执行。如果这个消息不能被添加到哦消息队列里面,zmq_msg_send()函数会执行失败,并设置errno的值为EAGAIN.。

  ZMQ_SNDMORE

    指明正在被发送的消息是个多帧消息,并且后面还有更多的消息会进行发送。参见下面关于多帧消息的章节,以获取更详细的信息。

在调用zmq_msg_send()函数的时候,消息结构zmq_msg_t是失效的。如果想把消息发送给多个socket,需要调用复制函先数复制这个消息(比如zmq_msg_copy()函数)。

注意:调用zmq_msg_send()成功并不意味着消息已经成功得发送到网络上了,只能说明消息已经添加到消息队列,ZMQ会确保消息的发送。

多帧消息(Multi-part messages 具体怎么翻译我也不会。。。)

一个ZMQ消息是由1个或多个帧组成的。每个消息段都是一个对立的zmq_msg_t消息结构。ZMQ确保对消息进行原子交付:每个socket或者接收整个消息,或者一个消息帧也不接收。每个消息中的帧数是不受限制的,除非内存不够用了。

除了发送最后一帧消息,应用进程每次发送消息时必须使用ZMQ_SNDMORE标志以发送多帧消息。

Return value

如果zmq_msg_send()函数执行成功则返回消息中数据的长度。否则返回 -1,并且设置errno的值为下列值。

Errors

  EAGAIN

    在使用非阻塞模式发送消息的时候此消息不可用。

  ENOTSUP

    zmq_msg_send()函数不支持此socket的类型。

  EFSM

    当socket处在不正确的状态时,zmq_msg_send()操作无法执行。这中情况可能发生在一个socket在集中状态间切换的时候,比如ZMQ_REP。请查看zmq_socket(3) 函数的消息模式章节获得更多信息。

  ETERM

    和socket相联系的ZMQ context被终结了。

  ENOTSOCK

    参数提供的socket不可用。

  EINTR

    在消息发送之前,操作被系统信号中断了。

  EFAULT

    参数提供的消息不可用。

Example

  向一个消息对象写入内容并发送

复制代码
/* Create a new message, allocating 6 bytes for message content */
zmq_msg_t msg;
int rc = zmq_msg_init_size (&msg, 6);
assert (rc == 0);
/* Fill in message content with 'AAAAAA' */
memset (zmq_msg_data (&msg), 'A', 6);
/* Send the message to the socket */
rc = zmq_msg_send (&msg, socket, 0); assert (rc == 6);
复制代码

  发送一个多帧消息

复制代码
/* Send a multi-part message consisting of three parts to socket */
rc = zmq_msg_send (&part1, socket, ZMQ_SNDMORE);
rc = zmq_msg_send (&part2, socket, ZMQ_SNDMORE);
/* Final part; no more parts to follow */ rc = zmq_msg_send (&part3, socket, 0);
复制代码




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

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
基于commons-pool2实现KafkaProducer池来提升kafka发送消息性能
基于commons-pool2实现KafkaProducer池来提升kafka发送消息性能
1204 0
Ajax-17:使用fetch函数发送ajax请求
Ajax-17:使用fetch函数发送ajax请求
40 0
带你读《计算机组成与设计:硬件/软件接口(英文版原书第5版RISC-V版)》之一:Computer Abstractions and Technology
全书着眼于当前计算机设计中最基本的概念,展示了软硬件间的关系,并全面介绍当代计算机系统发展的主流技术和最新成就。书中逐条指令地列举了完整的MIPS指令集,并介绍了网络和多处理器结构的基本内容。将CPU性能和程序性能紧密地联系起来是本版的一个新增内容。另外,本版对软硬件的讨论更加深入,作者展示了软硬件部件如何影响程序的性能,并在光盘中为侧重硬件和侧重软件的读者分别提供了相关资料。
1287 0
开发函数计算的正确姿势——运行 Selenium Java
Selenium 是用于测试 Web 应用程序的可移植框架。本文介绍如何将 Selenium 框架运行在函数计算的 Java 运行时。
876 0
高通TrustZone接口QSEECOM Use-After-Free漏洞分析
#高通QSEECOM接口漏洞(CVE-2019-14040)分析 #阿里安全(侯客) ##背景:  上周五看到一篇国外的安全公司zimperium的研究人员写的一篇他们分析发现的高通的QSEECOM接口漏洞文章,[https://blog.zimperium.com/multiple-kernel-vulnerabilities-affecting-all-qualcomm-d
799 0
+关注
3656
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载