本文转载自微信公众号「爱笑的架构师」，作者雷架。大型互联网公司一般都会要求消息传递最大限度的不丢失，比如用户服务给代金券服务发送一个消息，如果消息丢失会造成用户未收到应得的代金券，最终用户会投诉。为避免上面类似情况的发生，除了做好补偿措施，更应该在系设计的

Kafka 是一个优秀的分布式消息中间件，许多系统中都会使用到 Kafka 来做消息通信。对分布式消息系统的了解和使用几乎成为一个后台开发人员必备的技能。今天就从常见的 Kafka 面试题入手和大家聊聊 Kafka 的那些事儿。生产者负责创建消息，然后将其

　　在Kafka在0.8以前的版本中，是没有Replication的，一旦某一个Broker宕机，则其上所有的Partition数据都不可被消费，这与Kafka数据持久性及Delivery Guarantee的设计目标相悖。同时Producer都不能再将数

* @param durable true if we are declaring a durable exchange . * @param autoDelete true if the server should delete the exchange

#earliest 当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，从头开始消费

是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。目标是实现一种在全行业广泛使用的标准消息中间件技术，以便降低企业和系统集成的开销，并且向大众提供工业级的

之前有个打算在学习RabbitMQ之前，把AMQP详细阅读一次，挑出里面的重点内容。后来找了下RabbitMQ的官方文档，发现了有一篇文档专门介绍了RabbitMQ中实现的AMQP模型部分，于是直接基于此文档和个人理解写下这篇文章。AMQP目前已经推出协议

课程介绍:分布式大数据处理系统架构中，消息中间件是必不可少的组件，本课程主要讲解如何基于Python和常用消息中间件快速开发大数据处理平台，并且结合实际应用场景，从零开始搭建一套完整的分布式日志分析告警系统。

前言Kafka起初是由LinkedIn公司采用Scala语言开发的-一个多分区、多副本且基于ZooKeeper协调的分布式消息系统，现已被捐献给Apache基金会。目前Kafka已经定位为一个分布式流式处理平台，它以高吞吐、可持久化、可水平扩展、支持流数据

接上一篇的《业务方对消息中间件的需求》，在可用性和可靠性的基础上，讨论各种架构的优缺点，最后给出自己关于消息中间件的架构思考。Kafka首先还是来看Kafka的系统架构。Broker是真正的服务端，用于存储消息。从上面的架构可以看出Kafka只是依赖了Zo

所以目前业界有几种不同的设计方式来满足不同的需求。那么有没有一种更高效的方式呢？答案是肯定的，但那可能要进一步降低可靠性！目前我们的监控日志收集系统使用的是和②中类似的方案，消息系统使用的是3方案，后期可能会将可靠性要求高的向1方案过度，可靠性要求不高的向

此公众号会从消息中间件的一些概念出发，陆续介绍分布式消息中间件的应用领域，涉及的技术等，最后到自己设计和实现一个分布式消息中间件。第一次写公众号，文章的结构组织并不一定能足够清晰，文字表达不一定够准确，权当和大家的讨论交流。对于分布式消息中间件，首先要了解

消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自

滴滴出行消息服务团队近日开源了其内部广泛使用的分布式消息中间件产品 DDMQ，这是一款致力于提供低延迟、高并发、高可用、高可靠消息服务的企业级消息队列产品。完善的监控配套：提供模块的健康检查和消息堆积告警功能。DDMQ 已经在滴滴内部稳定运行了两年多时间，

RocketMQ 自阿里开源以来，在 Apache 下的孵化还不错，现在很多互联网公司都在生产环境下使用。当然也是各大技术厂商的面试要点。

现在网上很多面试题，主要是针对技术本身的提问，比如：你聊聊对Dubbo的理解？你说说分布式事务是什么？你们Dubbo服务的超时一般怎么设置的？类似这样的问题，都是在考察你对一个技术的实践经验，而这目前越来越成为了面试的重点。这是一个非常典型的生产环境的问题

前言在分布式系统中,我们广泛运用消息中间件进行系统间的数据交换,便于异步解耦。现在开源的消息中间件有很多,前段时间产品 RocketMQ 也顺利开源,得到大家的关注。概念MQ简介MQ,Message queue,消息队列，就是指保存消息的一个容器。MQ特

RabbitAdmin类可以很好的才注意RabbitMQ,在Spring中直接进行诸如即可。RabbitAdmin底层实现就是从Spring容器中获取Exchange、Bingding、RoutingKey以及Queue的@Bean声明。使用RabbitT

　Kafka是一种消息中间件，首先我们看看什么是消息中间件、消息中间件可以解决什么问题，然后我们对比不同的消息中间件，总结Kafka适用的场景。　中间件位于系统软件和应用软件之间的部分，起到连接系统各部分。消息中间件是用于接收消息，并且将消息传递给需要消息

消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自