关键词：

各种消息队列如何选择？为何选择rocketmq来保证消息不丢失，及应该采用rocketmq哪种通信模式？

前言消息队列本质上来说，是一个符合先进先出原则的单向队列：一方发送消息并存入消息队列尾部(生产者投递消息)，一方从消息队列的头部取出消息(消费者消费消息)。 但对于一个成熟可靠的消息队列来说，所需要解决... 查看详情

滴滴出行基于rocketmq构建企业级消息队列服务的实践

本文整理自滴滴出行消息队列负责人江海挺在ApacheRocketMQ开发者沙龙北京站的分享。通过本文，您将了解到滴滴出行：在消息队列技术选型方面的思考；为什么选择RocketMQ作为出行业务的消息队列解决方案；如何构建自己的消息... 查看详情

rocketmq-如何实现顺序消息

...新增消息、修改消息。如何发送和消费顺序消息我们使用RocketMQ顺序消息来模拟一下订单的场景，顺序消息分为两部分：顺序发送、顺序消费。1.顺序发消息上面代码模拟了按顺序依次发送创建、支付、退款消息到TopicTest中。在ap... 查看详情

rocketmq工作原理

1.消息的生产过程消息生产过程，经历如下过程：1.向NameServer发出获取消息Topic的路由信息的请求2.nameServer返回该Topic的路由表以及Broker列表3.Producer根据代码中指定的Queue选择策略，从Queue中选择一个队列，用于存储消息4.Producer对... 查看详情

面试连环炮系列（二十?四）：为什么选择rocketmq

为什么选择RocketMQ，而不是其他MQ性能：阿里支撑，经受住淘宝，天猫双11重重考验；性能高；可靠性好；可用性高；易扩展。功能：功能完善，我们需要的功能基本都够满足，如：事务消息，消息重试，死信队列，定时消息等。... 查看详情

rocketmq使用顺序消息(代码片段)

目录说明生产端消费端总结说明RocketMQ与其它消息队列一样，一个Topic利用多个队列来存储数据，单个队列内的数据是顺序存储的，但队列间的数据无法保证顺序性。RocketMQ目前支持保证某类数据或部分数据的顺序性。... 查看详情

rocketmq源码之selectonemessagequeue选择队列

参考技术ARocketMQ是通过MQFaultStrategy的selectOneMessageQueue方法来选择发送队列的我们先来看下MQFaultStrategy中重要的属性我们来看开启了延迟容错的逻辑：selectOneMessageQueue选择队列的基本逻辑我们已经了解了，现在来具体看下LatencyFault... 查看详情

rocketmq使用顺序消息(代码片段)

目录说明生产端消费端总结说明RocketMQ与其它消息队列一样，一个Topic利用多个队列来存储数据，单个队列内的数据是顺序存储的，但队列间的数据无法保证顺序性。RocketMQ目前支持保证某类数据或部分数据的顺序性。... 查看详情

golang快速接入rocketmq实现消息队列业务(代码片段)

...使用redis中的list数据类型，在大规模业务中我们可以引入rocketmq等，尤其在业务重构时需要将原有的redis消息队列实现改成rocketmq，为了保证既有业务不受影响，不引入新的BUG，是一件非常苦恼的事情；今天就介绍一个包，可以方... 查看详情

rocketmq：死信队列和消息幂等

参考技术A上一篇《RocketMQ：消息重试》中我们提到当一条消息消费失败时，RocketMQ会进行一定次数的重试。重试的结果也很简单，无非就是在第N次重试时，被成功消费。或者就是经过M次重试后，仍然没有被消息。这通常是由于... 查看详情

消息队列rocketmq如何存储消息

Rocket的消息是有consumequeue和commitlog组成。ConsumeQueueConsumequeue是消息的逻辑队列，相当于字典目录，用来指定消息在物理文件（commitlog）上的位置，我们可以在配置中指定consumequeue和commitlog存储的目录。每一个topic下的每个queue都... 查看详情

springboot实战项目整合阿里云rocketmq消息队列实现发送普通消息，延时消息(代码片段)

原文地址：Springboot实战项目整合阿里云RocketMQ消息队列实现发送普通消息，延时消息--附代码-学不会丶-博客园一.为什么选择RocketMQ消息队列？（可跳过看三的整合代码实例）首先RocketMQ是阿里巴巴自研出来的&#... 查看详情

kafka还是rabbitmq？

...靠传输。市面上的消息队列也有很多，比如阿里云的oss，RocketMQ，ZeroMQ，RabbitMQ，Kafka等，甚至Java中的List也可以称为一个简单的消息队列，种类如此繁多，我们该如何选择呢？现在主流的消息队列可以分为两类，一类以kafka为代... 查看详情

rocketmq顺序消费

参考技术A对于所有的MQ来说，必问的一道面试题就是RocketMQ顺序消息怎样做？原理是什么？首先我们要明确什么顺序消费，顺序消费的定义是什么？我所理解的顺序消费，指的针对某一类消息，比如都是订单A的消息来说，它的消... 查看详情

如何有选择地从 AMQP（RabbitMQ）队列中删除消息？

】如何有选择地从AMQP（RabbitMQ）队列中删除消息？【英文标题】：HowtoselectivelydeletemessagesfromanAMQP(RabbitMQ)queue?【发布时间】：2011-03-2623:21:39【问题描述】：我想有选择地从AMQP队列中删除消息，甚至不读取它们。场景如下：发送方... 查看详情

kafka消息队列

...市面上比较常见的消息队列主要有Kafka、ActiveMQ、RabbitMQ、RocketMQ等。但是这么多的消息队列我们如何进行选择呢？在大数据的场景中我们主要采用Kafka作为消息队列。我们在JavaEE的开发当中主要采用ActiveMQ、RabbitMQ、RocketMQ。 ... 查看详情

mq——如何选择消息队列

一个好的消息队列需满足以下几点：1、首先，必须是开源的产品，这个非常重要。开源意味着，如果有一天你使用的消息队列遇到了一个影响你系统业务的Bug，你至少还有机会通过修改源代码来迅速修复或规避这个Bug，解决你... 查看详情

rocketmq源码合集

消息队列中间件RocketMQ源码分析——Message发送与接收消息队列中间件RocketMQ源码分析——Message存储分布式消息队列RocketMQ源码分析——Message拉取与消费（上）分布式消息队列RocketMQ源码分析——Message拉取与消费（下&#x... 查看详情