消息队列的优先级 消息队列规范中描述的优先级是指在一个消息队列中，每条消息都有不同的优先级，一般用整数来描述，优先级高的消息先投递，如果消息完全在一个内存队列中，那么在投递前可以按照优先级排序，令优先级高的先投递。 对于优先级问题，可以归纳为2类： 只要达到优先级目的即可，不是严格意义上的优先级，通常将优先级划分为高、中、低，或者再多几个级别。每个优先级可以用不同的topic表示，发消息时，指定不同的topic来表示优先级，这种方式可以解决绝大部分的优先级问题，但是对业务的优先级精确性做了妥协。 严格的优先级，优先级用整数表示，例如065535，这种优先级问题一般使用不同topic解决就非...

消息认证码和认证加密 消息认证码   消息认证码(MessageAuthenticationCode)是一种确认完整性并进行认证的技术。但是消息认证码并不能保证消息的机密性。   A将生成消息认证码的对称密钥，以安全的方式发送给B。(就当做是面对面交流转手给B)  A将明文消息和对称密钥一起哈希算一遍，最后得到消息认证码。  A把明文消息和消息认证码一起发给B。     B把明文消息和 对称密钥 用同样的哈希算法算一遍，然后把计算的消息认证码和A发过来的消息认证码两者进行对比，如果一样则认为是没有被篡改过的。      如果不一致则认为此次发送的消息不正确，不是假冒就...

任何先进的技术均与魔法无异 追本溯源 ​​经历了6个月的失踪，我将带着干货终究归来！【RocketMQ入门到精通】​​ 订阅与发布 消息的发布是指某个生产者向某个topic发送消息，消息的订阅是指某个消费者关注了某个topic中带有某些tag的消息，进而从该topic消费数据。 对于一个指定的Topic，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。在ApacheRocketMQ中支持分区顺序消息，如下图所示。我们可以按照某一个标准对消息进行分区（比如图中的ShardingKey），同一个ShardingKey的消息会被分配到同一个队...

RocketMQ中有很多概念，其中包括一些术语和角色。 理清楚基本的概念能有效的帮助理解RocketMQ的原理以及排查问题。 Producer 生产者。发送消息的客户端角色。发送消息的时候需要指定Topic。 Consumer 消费者。消费消息的客户端角色。通常是后台处理异步消费的系统。RocketMQ中Consumer有两种实现：PushConsumer和PullConsumer。 PushConsumer 推送模式（虽然RocketMQ使用的是长轮询）的消费者。消息的能及时被消费。使用非常简单，内部已处理如线程池消费、流控、负载均衡、异常处理等等的各种场景。 PullConsumer 拉...

任何先进的技术均与魔法无异 追本溯源 ​​经历了6个月的失踪，我将带着干货终究归来！【RocketMQ入门到精通】​​ 回溯基础知识 服务注册与发现设计模式-定时拉取模式 RocketMQTopic路由的注册、发现采用的就是拉取模式，如下图所示。 ​BrokerA和BrokerB全都想所有的NameServer进行注册相关的服务配置信息以及相关的Topic基本信息、Topic的读写队列数、操作权限等。 Broker默认每30s向NameServer发送心跳包，心跳包中包含主题的路由信息（Topic的读写队列数、操作权限等） NameServer会通过HashMap更新Topi...