本文主要介绍RocketMQ中Topic Tag GroupName的概念 设计初衷以及使用方法。 一.Topic 首先看看官方的定义： Topic是生产者在发送消息和消费者在拉取消息的类别。Topic与生产者和消费者之间的关系非常松散。 具体来说，一个Topic可能有 个，一个或多个生产者向它发送消息 相反，一个生产者可以发送不同类型Topic的消息。 类似的，消费者组可以订阅一个或多个主题，只 ...
2020-03-31 08:50 0 3505 推荐指数：
多个服务器的情况下： 相同 topic 、consumerGroup tag 默认 均衡消费消息 相同 topic 、consumerGroup 当存在不同Tag的时候，会导致消费混乱，比如TagA的消息被TagB的消费者消费了。 相同topic 不同consumerGroup 默认 ...
最近做的项目的一个版本需求中，需要用到MQ,对数据记录进行异步落库，这样可以减轻数据库的压力,同时可以抗住大量的数据落库。这里需要说明一下本人用到的MQ是公司自己在阿里的RokectMQ的基础上进行封装的，然后加上自己的东西，形成个性化的开发，且安全性高。这里就不多透露相关公司的信息啦，我就叫 ...
待续 ...
新增topic是需要客户端直接通知broker完成的： 通过createAndUpdateTopicConfig方法 发送给broker以后，在AdminBrokerProcessor里面负责处理这个类型消息： private synchronized ...
tag 的使用场景：不同的消费组，订阅同一 topic 不同的 tag，拉取不同的消息并消费。在 topic 内部对消息进行隔离。 producer 发送消息，指定 tag consumer 订阅 topic，指定 tag broker 存储 consumer ...
项目绩效评估和奖励体系 如何评估项目的绩效，如何评估团队成员的绩效，如何根据评估结果进行薪酬奖励激励。1.我们为什么要做这件事情？ 对我们要做的事情有充分的认识，以确保我们在用正确的方式做正确的事情， ...
项目中使用了RocketMQ，没有显式的创建和Topic和MessageQueue，在消息发送时，就创建了Topic和 4个 MessageQueue 此时想要修改MessageQueue的数量方式如下： 通过producer.createTopic方法创建； 通过控制台方式 ...
