由于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...

在发送和接收消息重要的类有：ConnectionFactory，Connection，Channel和QueueingConsumer。ConntectionFactory类是方便创建与AMQP代理相关联的Connection；下面来看看ConntectionFactory是如何创建一个Contention.首先通过n...

http://blog.csdn.net/zhu_tianwei/article/details/40887885在一般使用RabbitMQ做RPC很容易。客户端发送一个请求消息然后服务器回复一个响应消息。为了收到一个响应，我们需要发送一个'回调'的请求的队列地址。我们可以使用默认队列（在Java客户端除外）。AMQP...

http://blog.csdn.net/zhu_tianwei/article/details/53563311在实际的业务中我们会遇见生产者产生的消息，不立即消费，而是延时一段时间在消费。RabbitMQ本身没有直接支持延迟队列功能，但是我们可以根据其特性Per-QueueMessageTTL和 Dead...

http://blog.csdn.net/zhu_tianwei/article/details/53971296下面主要从队列、消息发送、消息接收方面了解消息传递过的一些可靠性处理。 1、队列 消费者是无法订阅或者获取不存在的MessageQueue中信息。消息被Exchange接受以后，如果没有...

http://blog.csdn.net/zhu_tianwei/article/details/53969674前面介绍了几类exchange的作用，这个总结一下： direct：消息会被推送至绑定键（bindingkey）和消息发布附带的选择键（routingkey）完全匹配的队列。默认有”A...