(转载)zeromq使用注意点滴

zeromq使用注意点滴

1.关于介绍zeromq的就不说了,可以自己去看官方guide很详细

2.主要说下在使用过程中需要注意的地方

  1)使用如果使用c++的接口的时候,在你自己的类中或者apache模块中需要将zmq::context_t 对象定义在zmq::socket_t对象的前面,这样可以保证销毁的顺序

  2)使用sub-pub时候,如果sub没有调用setsockopt设置过滤项(设置NULL则接受所有),那么将会接收不到任何的消息,默认会阻塞所有消息

  3)如果是后台服务集群使用且zmq需要bind端口的,那么最好在iptables中进行下过滤,不要让外部链接连接过来,否则会造成cpu空转;关于cpu空转将会在最后说

  4)客户端连接服务器时,每个客户端中的zmq,每个连接使用一个socket,虽然可以一个socket可以调用connect多次,也就是连接多个server。但是,记住,最好是一个socket只调用一次connect

  5)使用zmq的程序,运行一段时间后(可能几天),如果你碰到异常退出,并且你使用nohup运行的lognohup.out中显示zeromq connection timeout,那么你可以zeromq/src/tcp_socket.cpp文件中的203行看是write的时候出错。

 1 int zmq::tcp_socket_t::write (const void *data, int size)
 2 {
 3     ssize_t nbytes = send (s, data, size, 0);
 4
 5     //  Several errors are OK. When speculative write is being done we may not
 6     //  be able to write a single byte to the socket. Also, SIGSTOP issued
 7     //  by a debugging tool can result in EINTR error.
 8     if (nbytes == -1 && (errno == EAGAIN || errno == EWOULDBLOCK ||
 9           errno == EINTR))
10         return 0;
11
12     //  Signalise peer failure.
13     if (nbytes == -1 && (errno == ECONNRESET || errno == EPIPE))
14         return -1;
15
16     errno_assert (nbytes != -1);
17     return (size_t) nbytes;
18 } 

这是由于 errno_assert (nbytes != -1);造成的,但是,真正的原因是nbytes==-1时,errno==ETIMEDOUT ,在前面一行中没有去添加对这个timeout的判断,另外,可以参考该文件中对win上的处理。因此,这里如果你碰到了timeout错误,那么请将errno == ETIMEOUT加入到errno==EPIPE后面,然后重新编译

  6)关于cpu空转。首先你可以用top 程序名,去看你的程序的cpu使用率是否是100%,而且基本固定不变,那么这时候,你就需要怀疑是否你的程序的问题,然后通过lsof -p 程序的进程号,去查看是否有文件描述符有can‘t identify protocol,还要注意下,是否有外网的ip连接到你的zmq的监听的端口。然后,你可以在zeromq/src/epoll.cpp中的loop,rm_fd,add_fd函数中打log,看看在监听到EPOLLERR|EPOLLHUP 的文件描述符是不是lsof -p 查看到的can‘t identify protocol的文件描述符一致。其实,只要做到前面5点,那么cpu 空转基本是不会出现的。

ps:最后,希望碰到问题,大家能自己思考为什么会出现这样的问题,该如何解决,对自己的提升会有很大的帮助。

来源:http://www.linuxidc.com/Linux/2013-03/80273.htm

时间: 2024-08-26 00:48:37

(转载)zeromq使用注意点滴的相关文章

转载:消息队列软件产品大比拼(MSMQ、ActiveMQ、RabbitMQ、ZeroMQ)

转载:http://www.cnblogs.com/amityat/archive/2011/08/31/2160293.html

点滴积累【other】---Windows 7 IIS (HTTP Error 500.21 - Internal Server Error)解决方案(转载)

此文来自:http://blog626.blog.163.com/blog/static/105610732201051591450870/ 搭建IIS时出现如下错误: HTTP Error 500.21 - Internal Server Error Handler "WebServiceHandlerFactory-Integrated" has a bad module "ManagedPipelineHandler" in its module list.

rabbitMQ、activeMQ、zeroMQ、Kafka、Redis 比较

Kafka作为时下最流行的开源消息系统,被广泛地应用在数据缓冲.异步通信.汇集日志.系统解耦等方面.相比较于RocketMQ等其他常见消息系统,Kafka在保障了大部分功能特性的同时,还提供了超一流的读写性能. 针对Kafka性能方面进行简单分析,相关数据请参考:https://segmentfault.com/a/1190000003985468,下面介绍一下Kafka的架构和涉及到的名词: Topic:用于划分Message的逻辑概念,一个Topic可以分布在多个Broker上. Parti

Python著名的lib和开发框架(均为转载)

第一,https://github.com/vinta/awesome-python Awesome Python A curated list of awesome Python frameworks, libraries, software and resources. Inspired by awesome-php. Awesome Python Admin Panels Algorithms and Design Patterns Anti-spam Asset Management A

死亡的协议--- Pieter Hintjens (ZeroMQ作者)

过去几年中用zeromq写过几个系统系统.对ZeroMQ强大和灵活印象非常深刻.在阅读zeromq guide文档时候.发现作者整理各种通信模式非常经典和实用,可以作为分布式通信的教科书来看.第一次见到这么有价值的开源框架说明文档 .  Pieter Hintjens   2010诊断出胆管癌,并成功手术切除.最近 (2016年4月)发现癌症大面积扩散到肺部,已经无法治疗. 他写的最后一篇通信模式是关于死亡协议. 原文地址是 A Protocol for Dying http://hintjen

专题:点滴Javascript

JS#43: 使用ECMAScript 6 Symbols创建私有属性 JS#42: 使用ECMAScript 6 Sets JS#41: Javascript使用递归和迭代造成栈溢出问题 JS#40: 使用console.time测试Javascript性能 JS#39: Javascript中判断两个日期相等 JS#38: Javascript中检测数组和对象 JS#37: Javascript中计算Object的长度 JS#36: 使用ECMAScript 6 Maps JS#35: 使用

转载--C++的反思

转载自http://blog.csdn.net/yapian8/article/details/46983319 最近两年 C++又有很多人出来追捧,并且追捧者充满了各种优越感,似乎不写 C++你就一辈子是低端程序员了,面对这种现象,要不要出来适时的黑一下 C++呢?呵呵呵. 咱们要有点娱乐精神,关于 C++的笑话数都数不清: 笑话:C++是一门不吉祥的语言,据说波音公司之前用ADA为飞机硬件编程,一直用的好好的,后来招聘了一伙大学生,学生们说我靠还在用这么落后的语言,然后换成C++重构后飞机就

【转载】值得推荐的C/C++框架和库

原文:值得推荐的C/C++框架和库 值得学习的C语言开源项目 Libevent libev是一个开源的事件驱动库,基于epoll,kqueue等OS提供的基础设施.其以高效出名,它可以将IO事件,定时器,和信号统一起来,统一放在事件处理这一套框架下处理.基于Reactor模式,效率较高,并且代码精简(4.15版本8000多行),是学习事件驱动编程的很好的资源. 下载链接:https://github.com/libevent/libevent Memcached Memcached 是一个高性能

【转载】维度表和事实表的区别

免责声明:     本文转自网络文章,转载此文章仅为个人收藏,分享知识,如有侵权,请联系博主进行删除.     原文作者:知识点滴      原文地址: 维度表, 事实表, 数据仓库, BI...   以前一直对维度表, 事实表, 数据分析, BI等概念等有一些模糊. 这几天的学习终于让这些有了一些眉目了: 维度表示你要对数据进行分析时所用的一个量, 比如你要分析产品销售情况, 你可以选择按类别来进行分析,或按区域来分析. 这样的按..分析就构成一个维度.前面的示例就可以有两个维度:类型和区域.