AMQP，即 AMQP，一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开发标准，为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端中间件不同产品，不同的开发语言等条件的限制，Erlang 中的实现有 Rab

‘queueName‘ => ‘test_cache_queue‘."_".$time,‘routeKey‘ => ‘test_cache_route‘."_".$time,‘host‘ => ‘1

那就表示一个工作队列，而工作队列的最大特征在于：若干个消费者一起完成工作。

因为消息的生产和消费都是异步的，而且只关心消息的发送和接收，没有业务逻辑的侵入,轻松的实现系统间解耦。别名为 `消息中间件` 通过利用高效可靠的消息传递机制进行平台无关的数据交流，并基于数据通信来进行分布式系统的集成。它是一个完全支持JMS规范的的消息中间

它是消费-生产者模型的一个典型的代表，producer往消息队列中不断写入消息，而另一端consumer则可以读取或者订阅队列中的消息。业务上，可以实现服务提供者和消费者之间的数据解耦，提供高可用性的消息传输机制，在实际生产中应用相当广泛。AMQP，即Ad

yum -y install make gcc gcc-c++ kernel-devel m4 ncurses-devel openssl-devel unixODBC-devel. 查看所有用户rabbitmqctl list_users添加一个用户ra

public static void main(String[] args) throws IOException {. public static void main(String[] args) throws IOException {. channe

消费端实现幂等性，就意味着，我们的消息永远不会被消费多次，即时收到多条一样的消息。幂等性，通俗点说，就一个数据，或者一个请求，给你重复来多次，你得确保对应的数据是不会改变的，不能出错。生产者进行接收应该，用来确定这条消息是否正常的发送到broker，这种方

rabbitmqctl set_permissions -p VHostPath User ConfP WriteP ReadP

　　消息队列是一种应用程序对应用程序的通信方法。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。队列的使用除去了接收和发送应用程序同时执行的要求。　　RabbitMQ是使用Erla

作为一个有丰富经验的微服务系统架构师，经常有人问我，应该选择 RabbitMQ 还是 Kafka?的确，在一些案例场景下选择 RabbitMQ 还是 Kafka 没什么差别，但是这两种技术在底层实现方面是有许多差异的。这篇文章会先介绍一下基本的异步消息模

先说一个实际的业务场景：Client端有一个请求需要进行耗时处理或者查询，这个处理在Server端做。Server 端处理完后通知给请求的Client端。这种场景可以称之为RPC. Client作为Producer发布消息，Server端作为Cosumer

broker发送了两个ack确认；如果收到nack信令，需要重新发送整个批次消息。broker回复ack数量和机制是什么？

下面是rabbitMQ和spring集成的配置,我配置了二种ExCahange: topicExchange和directExChange. --配置connection-factory，指定连接rabbit server参数 -->. --通过指

kafka 来说的话是高吞吐量，kafka 在每秒百万级别，完全分布式； 而 rabbitmq 比较简单，遵循 amqp 协议，一般应用可以使用；不适合物联网数据上报。上面的代码虽然能解决消息丢失的问题，但有一个弊端，就是当业务处理时间特别长的时候，rab

为什么要使用MQ？因此，系统可用性降低。因此，需要考虑的东西更多，系统复杂性增大。①自动确认模式，消费者挂掉，待ack的消息回归到队列中。针对这个问题，通过某种算法，将需要保持先后顺序的消息放到同一个消息队列中。同一个queue里的消息一定是顺序消息的。例

使用过rabbitmq的同学都知道，客户端在返回Nack时有一个requeue参数，标明是否需要重新排队，没错，的确是这样的。我当时也这么想，可后来进一步思考，到底是放入服务端队列，还是在本地队列呢？带着疑问，做了一个demo测试一下。返回Nack且req

--通过指定下面的admin信息，当前producer中的exchange和queue会在rabbitmq服务器上自动生成-->. -- 咨询订单支付成功 -->

所有队列中的消息都以append的方式写到一个文件中，当这个文件的大小超过指定的限制大小后，关闭这个文件再创建一个新的文件供消息的写入。文件名从0开始然后依次累加。当某个消息被删除时，并不立即从文件中删除相关信息，而是做一些记录，当垃圾数据达到一定比例时，

既然要做分布式系统，就不得不说分布式消息通信系统。分布式系统的基础是各个分布式单元能够以各种方式互相通信，分布式消息中间件比较有名的开源实现有rabbitMQ，zeroMQ（库），ActiveMQ等，本篇先考察一下著名的消息中间件rabbitmq. rab