RocketMQ是一个统一消息引擎，轻量级的数据处理平台。通俗的讲，当你需要一个消息处理框架，可以考虑选它。
ActiveMQ 支持同步、异步两种发送的模式将消息发送到 Broker，模式的选择对发送延时有巨大的影响。producer 能达到怎样的产出率(产出率=发送数据总量/时间)主要受发送延时的影响，使用异步发送可以显著的提高发送的性能。ActiveMQ 默认使用异步发送通的模式：除非明确指定使用同步发送的方式或者在未使用事务的前提下发送持久化的消息，这两种情况都是同步发送的。 如果没有使用事务且发送的是持久化的消息，每一次发送都是同步发送的且会阻塞 producer 直到 Broker 返回一个确认，表示消息己经被安全的持久化到磁盘。确认机制提供了消息安全的保障，但同时会阻塞客户端带来了很大的延时。很多高性能的应用，允许在失败的情况下有少量的数据丢失。如果你的应用满足这个特点，你可以使用异步发送来提高生产率，即使发送的是持久化的消息。 异步投递可以最大化 produer 端的发送效率。通常在发送消息量比较密集的情况下使用异步发送，它可以很大的提升 producer 性能；不过这也带来了额外的问题，就是需要消耗较多的 Client 端内存同时也会导致 Broker 端性能消耗增加；此外它不能有效的确保消息的发送成功。
昨天试了半天为啥监听不到死信队列的消息，原因是打开方式不对，还有死信队列就一条消息，没意思。
应该是处理此条消息的时候，实体类未序列化？然后我重试下，将实体类序列化去掉，这在运行时会直接异常的，目前原因不详。
官方的解决方案是主从集群（备份）方案 zookeeper集群 Replicated（瑞pk得） levelDB就是之前在讲消息持久化kahaDB的另一种消息持久化方案，这种方案的性能会比较好 activemq集群
死信队列监听一开始的逻辑是正确的，但关于监听的内容以及动态判断有了新的思路，不断发现不断改善。
Rabbit是基于AMQP协议并使用Erlang开发的开源消息队列中间件，它支持多种语言的客户端，也是目前市面上使用比较广泛的一种消息队列，因此学习并掌握它是非常有必要的。本文主要基于Java客户端进行讲解，不涉及环境搭建部分。
比如有一个订单系统，还要一个库存系统，用户下订单后要调用库存系统来处理，直接调用话，库存系统出现问题咋办呢？
点对点模型是基于队列的，生产者发消息到队列，消费者从队列接收消息，队列的存在使得消息的异步传输成为可能。
MQ是现在大型系统架构中必不可少的一个重要中间件，之前有偏文章《MQ(消息队列)常见的应用场景解析》介绍过MQ的应用场景，现在流行的几个MQ是rabbitmq,rocketma,kafka,这几个MQ比较最容易找到相关的文章，而也有些系统使用的是activemq，因activemq是相对比较传统的MQ，在使用过程中还是会遇到很多坑，这里简单列举几个大家可能会遇到的问题，把自己使用acitvemq的经验和大家分享一下。
有两种方法可以接收消息，一种是使用同步阻塞的MessageConsumer#receive方法。另一种是使用消息监听器MessageListener。这里需要注意的是，在同一个session下，这两者不能同时工作，也就是说不能针对不同消息采用不同的接收方式。否则会抛出异常。
网易云音乐自2013年上线后，业务保持了高速增长。云音乐除了提供好听的音乐外，还留下了我们在乐和人上的美好回忆。本文整理自网易云音乐消息队列负责人林德智在近期 Apache Flink&RocketMQ Meetup 上海站的分享，通过该文，您将了解到：
我们来想一下，要在项目中使用一个新技术，是不是应该先了解市面上都有哪些常用的框架，所以应该从技术调研开始，选择合适的框架应用于我们的项目。
担任路由消息的提供者。生产者或消费者能够通过NameServer查找各Topic相应的Broker IP列表分别进行发送消息和消费消息。nameServer由多个无状态的节点构成，节点之间无任何信息同步。 broker会定期向NameServer以发送心跳包的方式，轮询向所有NameServer注册以下元数据信息：
.markdown-body{word-break:break-word;line-height:1.75;font-weight:400;font-size:15px;overflow-x:hidden;color:#333}.markdown-body h1,.markdown-body h2,.markdown-body h3,.markdown-body h4,.markdown-body h5,.markdown-body h6{line-height:1.5;margin-top:35px;margin-bottom:10px;padding-bottom:5px}.markdown-body h1{font-size:30px;margin-bottom:5px}.markdown-body h2{padding-bottom:12px;font-size:24px;border-bottom:1px solid #ececec}.markdown-body h3{font-size:18px;padding-bottom:0}.markdown-body h4{font-size:16px}.markdown-body h5{font-size:15px}.markdown-body h6{margin-top:5px}.markdown-body p{line-height:inherit;margin-top:22px;margin-bottom:22px}.markdown-body img{max-width:100%}.markdown-body hr{border:none;border-top:1px solid #ddd;margin-top:32px;margin-bottom:32px}.markdown-body code{word-break:break-word;border-radius:2px;overflow-x:auto;background-color:#fff5f5;color:#ff502c;font-size:.87em;padding:.065em .4em}.markdown-body code,.markdown-body pre{font-family:Menlo,Monaco,Consolas,Courier New,monospace}.markdown-body pre{overflow:auto;position:relative;line-height:1.75}.markdown-body pre>code{font-size:12px;padding:15px 12px;margin:0;word-break:normal;display:block;overflow-x:auto;color:#333;background:#f8f8f8}.markdown-body a{text-decoration:none;color:#0269c8;border-bottom:1px solid #d1e9ff}.markdown-body a:active,.markdown-body a:hover{color:#275b8c}.markdown-body table{display:inline-block!important;font-size:12px;width:auto;max-width:100%;overflow:auto;border:1px solid #f6f6f6}.markdown-body thead{background:#f6f6f6;color:#000;text-align:left}.markdown-body tr:nth-child(2n){background-color:#fcfcfc}.markdown-body td,.markdown-body th{padding:12px 7px;line-height:24px}.markdown-body td{min-width:120px}.markdown-body blockquote{color:#666;padding:1px 23px;margin:22px 0;border-left:4px solid #cbcbcb;background-color:#f8f8f8}.markdown-body blockquote:after{display:block;content:""}.markdown-body blockquote>p{margin:10px 0}.markdown-body ol,.markdown-body ul{padding-left:28px}.markdown-body ol li,.markdown-body
RabbitMQ转载原文【推荐】:https://www.jianshu.com/p/78847c203b76
消息队列在现今数据量超大，并发量超高的系统中是十分常用的。本文将会对现时最常用到的几款消息队列框架 ActiveMQ、RabbitMQ、Kafka 进行分析对比。
ActiveMQ默认的使用的协议是openWire，端口号：61616 一条消息从producer端发出之后，一旦被broker正确保存，那么它将会被consumer消费，然后ACK，broker端才会删除；不过当消息过期或者存储设备溢出时，也会终结它
在一个事务正在进行的同时，发出消息给其他的业务，如果消息发送失败，或者消息的执行失败，则回滚消息，重复执行，反复执行失败后，记录失败信息，后期补充性的处理；在消息系统中开启事务，消息的事务是指，保证消息被正常消费，否则回滚的一种机制
本篇文章聊聊消息队列相关的东西，内容局限于我们为什么要用消息队列，消息队列究竟解决了什么问题，消息队列的选型。
2020年处于移动互联网的下半场，各种技术层出不穷，虽然数据也在爆发式增长，但是高并发、高吞吐已经不再是首要的痛点，稳定、可靠才是王道。 本文作为一篇消息队列入门级介绍，帮助大家对消息队列有一个大致的了解，并对对时下流行的消息队列组件进行了简单的比较，供大家做技术选型的参考。 1 什么是消息队列 消息队列（Message Queue），从广义上讲是一种消息队列服务中间件，提供一套完整的信息生产、传递、消费的软件系统。 消息队列所涵盖的功能远不止于队列（Queue），其本质是两个进程传递信息的一种方法。两
从八月份开始，断断续续连载了不少 RabbitMQ 教程，最近抽空整理了一下，未来可能会有一个视频教程，小伙伴们敬请期待。
activeMQ 是一种开源的，实现了 JMS1.1 规范的，面向消息(MOM)的中间件，为应用程序提供高效的、可扩展的、稳定的和安全的企业级消息通信
消息队列和事件流是事件驱动架构的关键组成部分，但它们究竟有何异同？在什么情况下应选择它们的哪一个？
大家想一想在你们平时开发的系统里面有没有这种情况，就是你们系统会调用到第三方接口服务，而且这个接口服务是在你流程里面进行同步调用的，这个时候你们的系统性能是直接和第三方接口服务挂钩的，也就是第三方接口服务性能的好坏直接影响到你自己的系统。
在消息队列选型时，我们调研了市场上比较常用ActiveMQ，RabbitMQ，RocketMQ，Kafka。
各种mq activemq，kafka使用zookeeper做管理 rocketmq自己实现nameserver broke管理 AMQP核心概念 高级消息队列协议 publisher application->Server->Virtual host->Exchange->Message Queue->Consumer application Server:又称Broker，接收客户端的连接，实现AMQP实体服务 Connection：连接，应用程序与Broker的网络连接 Channel：网络信道，几乎
大家好，我是小❤，一个漂泊江湖多年的 985 非科班程序员，曾混迹于国企、互联网大厂和创业公司的后台开发攻城狮。
某一天，系统B的负责人告诉系统A的负责人，现在系统B的SystemBNeed2do(String userId)这个接口不再使用了，让系统A别去调它了。 于是，系统A的负责人说"好的，那我就不调用你了。"，于是就把调用系统B接口的代码给删掉了。代码变成这样了：
场景说明：用户注册，需要执行三个业务逻辑，分别为写入用户表，发注册邮件以及注册短信。
什么是消息中间件？随着业务的急速增长以及分布式架构的逐渐兴起，首先要考虑的就是如何高效的在各节点之间传递消息，其次要考虑的是流量洪峰时如何削减系统的压力以及跨平台消息的传输等问题，消息中间件就可以帮我们解决以上问题。而消息队列产品众多，我们该如何选择呢？本系列文章主要针对目前使用最多的ActiveMQ、Kafka、RabbitMQ进行讲解说明。
MQ(message queue)，从字面意思上看，本质是个队列，FIFO 先入先出，只不过队列中存放的内容是message 而已，还是一种跨进程的通信机制，用于上下游传递消息。在互联网架构中，MQ 是一种非常常见的上下游“逻辑解耦+物理解耦”的消息通信服务。使用了 MQ 之后，消息发送上游只需要依赖 MQ，不用依赖其他服务。
Pin，关注 RPC、Service Mesh、Serverless 等云原生技术。
来源：https://www.jianshu.com/p/8f7ebbcbeee5
消息队列中间件（简称消息中间件）是指利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型，它可以在分布式环境下提供应用解耦、弹性伸缩、冗余存储、流量削峰、异步通信、数据同步等等功能，其作为分布式系统架构中的一个重要组件，有着举足轻重的地位。
导语 消息队列 RocketMQ 版（TDMQ for RocketMQ，简称 TDMQ RocketMQ 版）在今日正式公测！TDMQ RocketMQ 是TDMQ系列产品中的一款分布式高可用的消息队列服务，兼容 Apache RocketMQ 的各个组件与概念，RocketMQ 4.6及以上版本的客户端几乎零改造接入。欢迎大家扫描文末二维码使用体验！ TDMQ RocketMQ 版的背景 RocketMQ作为典型的业务处理消息队列，主要用于处理订单，支付，积分等业务类型，对信息交换的准确性有极高的要求
生产者把消息发送到消息队列中以后，并不期望被立即消费，而是等待指定时间后才可以被消费者消费，这类消息通常被称为延迟消息。延迟消息的应用场景其实是非常的广泛，比如以下的场景：
MQ(message queue)，从字面意思上看，本质是个队列，FIFO 先入先出，只不过队列中存放的内容是 message 而已，还是一种跨进程的通信机制，用于上下游传递消息。在互联网架构中，MQ 是一种非常常见的上下游“逻辑解耦+物理解耦”的消息通信服务。使用了 MQ 之后，消息发送上游只需要依赖 MQ，不用依赖其他服务。
RabbitMQ支持给队列内的消息设置过期时间和给消息单独过期时间，那么结合死信队列我们就可以做到消息的延迟发送了； 大概是以下步骤 1.创建延迟队列并设置消息的过期时间,绑定一个死信队列 2.不创建该队列的消费者，让其内部消息根据过期时间自动过期 3.创建死信队列的消费者，使其每次消费死亡的消息；
我们在做消息队列的技术选型时，往往会结合业务场景进行考虑。今天来聊一聊消息队列可能会用到的 7 种消息场景。
1、削峰：在某个模块接收到超过最大承受的并发量时，可以通过 MQ 排队来使这些削减同一时刻处理的消息量。减小并发量。
选择中间件的可以从这些维度来考虑：可靠性，性能，功能，可运维行，可拓展性，社区活跃度。目前常用的几个中间件，ActiveMQ作为“老古董”，市面上用的已经不多，其它几种：
RabbitMQ 是一款开源的，Erlang 编写的，基于 AMQP 协议的，消息中间件；
并且，索性咱就直接把这个坑填得满满的，直接盘点RocketMQ支持的11种消息类型以及背后的实现原理
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
对象存储
云直播
