当RabbitMQ发布消息速度快于消费速度或者系统资源不足时，RabbitMQ将降低或阻断发布消息速度，以免服务器资源饱满而宕机，可以通过rabbitmqctl和web管理页面查看连接的状态为flow，当服务器资源不足时，连接会被blocked。连接被流控后和正常使用没有什么区别，体现可网络带宽不足情况一样。这个流控不...

对于RabbitMQ的监控，除了服务器基本信息（硬盘、CPU、内存、IO等）以及MQ的进程和端口，我们也可以通过请求url访问管理API监控其集群和队列的情况。在Java api3.6.0以后，channel接口为我们提供了如下接口：/***Returnsthenumberofmessagesinaqueue...

之前介绍过关于消息发送和接收的可靠性：RabbitMQ学习之消息可靠性及特性 下面主要介绍一下集群环境下，rabbitmq实例宕机的情况下，消息的可靠性。验证rabbitmq版本【3.4.1】。 集群环境要求： 1.集群中至少有一台硬盘节点 2.加入集群中有一台内存节点，一台硬盘...

1.增加负载均衡器关于负载均衡器，商业的比如F5的BIG-IP，Radware的AppDirector，是硬件架构的产品，可以实现很高的处理能力。但这些产品昂贵的价格会让人止步，所以我们还有软件负载均衡方案。互联网公司常用的软件LB一般有LVS、HAProxy、Nginx等。LVS是一个内核层的产品，主要在第四层负责数...

http://blog.csdn.net/zhu_tianwei/article/details/40931971我们先搭建一个普通集群模式，在这个模式基础上再配置镜像模式实现高可用，Rabbit集群前增加一个反向代理，生产者、消费者通过反向代理访问RabbitMQ集群。架构图如下：设计架构可以如下：在一个集群里，有4...

由于RabbitMQ是用erlang开发的，RabbitMQ完全依赖Erlang的Cluster，因为erlang天生就是一门分布式语言,集群非常方便，但其本身并不支持负载均衡。Erlang的集群中各节点是经由过程一个magiccookie来实现的，这个cookie存放在$home/.erlang.cookie中(像我...

下面我们通过一个实例看一下rabbit的使用。1.实现一个消息监听器ReceiveMessageListener.Java [java] viewplain copy  print?package org.springframework.amqp.core;&...

RabbitMQ已经实现了Jackson的消息转换（Jackson2JsonMessageConverter），由于考虑到效率，如下使用Gson实现消息转换。如下消息的转换类的接口MessageConverter，Jackson2JsonMessageConverter的父类AbstractJsonMessageCon...

http://blog.csdn.net/zhu_tianwei/article/details/40920985spring-rabbitmq中实现远程接口调用，主要在com.rabbitmq.spring.remoting下几个类：发布服务端(Server)：RabbitInvokerServiceExporter...

spring-rabbitmq的源码到http://github.com/momania/spring-rabbitmq下载，并可以下载实例代码。由于我使用的rabbitmq版本是3.0.4，部分代码做了调整。具体实例如下（创建自动删除非持久队列）：1.资源配置application.properties [...

http://blog.csdn.net/zhu_tianwei/article/details/40919249实现使用Exchange类型为DirectExchange.routingkey的名称默认为Queue的名称。注解实现异步发送消息。1.生产者配置ProducerConfiguration.Java&nbs...

http://blog.csdn.net/zhu_tianwei/article/details/40919031实现使用Exchange类型为DirectExchange.routingkey的名称默认为Queue的名称。异步发送消息。1.配置文件 [plain] viewplain c...

http://blog.csdn.net/zhu_tianwei/article/details/40918477上一篇文章通过xml配置rabbitmq的rabbitTemplate，本节将使用注解的形式实现同步消息的发送。1.注解配置AnnotationConfiguration.Java [java]&...

http://blog.csdn.net/zhu_tianwei/article/details/40890543以下实现使用Exchange类型为DirectExchange.routingkey的名称默认为Queue的名称。1.所需jar包依赖 [html] viewplain cop...

对于大多数应用来说都做了与spring整合，对于rabbitmq来说。也有与spring的整合。可能通过spring的官网找到spring-amqp项目下载。spring-amqp项目包括三个子项目：spring-amqp、spring-erlang、spring-rabbit.  下面来认识一下s...