• rocketsmq-06-message trace 消息轨迹
  消息轨迹 1. 消息轨迹数据关键属性 Producer端 Consumer端 Broker端 生产实例信息 消费实例信息  消息的Topic 发送消息时间 投递时间,投递轮次  消息存储位置 ...
  2018-09-20 01:35:26 | MQ
• rocketsmq-05-最佳实践
  最佳实践 1 生产者 1.1 发送消息注意事项 1 Tags的使用 一个应用尽可能用一个Topic，而消息子类型则可以用tags来标识。tags可以由应用自由设置，只有生产者在发送消息设置了tags，消费方在订阅消息时才可以利用tags通过broker做消息过滤：message.setTags(“TagA”)。 2 Keys的使用 每个消息在业务层面的唯一标识码要设置到ke...
  2018-09-20 01:35:26 | MQ
• rocketsmq-04-入门例子
  1 基本样例 在基本样例中我们提供如下的功能场景： 使用RocketMQ发送三种类型的消息：同步消息、异步消息和单向消息。其中前两种消息是可靠的，因为会有发送是否成功的应答。 使用RocketMQ来消费接收到的消息。 1.1 加入依赖： maven: <dependency> <groupId>org.apa...
  2018-09-20 01:35:26 | MQ
• rocketsmq-03-Architecture&Design 架构与设计
  架构设计 1 技术架构 RocketMQ架构上主要分为四部分，如上图所示: Producer：消息发布的角色，支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集群队列进行消息投递，投递的过程支持快速失败并且低延迟。 Consumer：消息消费的角色，支持分布式集群方式部署。支持以push推，pull拉两种模式对...
  2018-09-20 01:35:26 | MQ
• rocketsmq-02-concept&features 基本概念与特性
  基本概念 1 消息模型（Message Model） RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。Broker 在实际部署过程中对应一台服务器，每个 Broker 可以存储多个Topic的消息，每个Topic的消息也可以分片存储于不同的 Broker。...
  2018-09-20 01:35:26 | MQ
• MQ Learn-01-Overview
  MQ 的优势 1.通过持久性冗余 冗余是消息队列最明显的优势之一。应用程序崩溃，超时，代码中的错误以及其他问题只是常态的一部分。在每月处理数百万或数十亿交易的应用程序中尤其如此。 队列通过使读取消息的进程确认它已完成事务并且可以安全地删除它来帮助实现冗余。如果出现任何问题，最糟糕的情况是，该消息会持久保存到某处，并且不会丢失。它可以在以后重新处理。 2.交通高峰期 您并不总是确切知...
  2018-09-20 01:35:26 | MQ
• Spring Kafka
  Spring Kafka Apache Kafka的Spring (Spring - Kafka)项目将核心Spring概念应用到基于Kafka的消息解决方案的开发中。 它提供了一个“模板”作为发送消息的高级抽象。 它还提供了对带有 @KafkaListener 注解和“侦听器容器”的消息驱动pojo的支持。 这些库促进了依赖注入和声明性的使用。 在所有这些情况下，您将看到与Spr...
  2018-09-19 07:44:59 | MQ
• QMQ-03-顺序消费
  顺序消费消息的必要性 在MQ里，顺序消息的意思是消费消息的顺序和消息发送时(单机发送)的顺序保持一致。 比如ProducerA按照顺序发送msga, msgb, msgc三条消息，那么consumer消费的时候也应该按照msga, msgb, msgc来消费。 对于顺序消息，在我们实际使用中发现，大部分业务系统并不需要或者并不依赖MQ提供的顺序机制，这些业务本身往往就能处理无序的消息，...
  2018-09-19 07:44:59 | MQ