本文主要介绍RocketMQ中Topic、Tag、GroupName的概念、设计初衷以及使用方法。
一.Topic
首先看看官方的定义:
Topic是生产者在发送消息和消费者在拉取消息的类别。Topic与生产者和消费者之间的关系非常松散。
具体来说,一个Topic可能有0个,一个或多个生产者向它发送消息;相反,一个生产者可以发送不同类型Topic的消息。
类似的,消费者组可以订阅一个或多个主题,只要该组的实例保持其订阅一致即可。
Topic在Google翻译中解释为话题。我们可以理解为第一级消息类型,类比于书的标题。在应用系统中,一个Topic标识为一类消息类型,比如交易信息。
在Producer中使用Topic:
1 Message msg = new Message("TopicTest" /* Topic */, 2 "TagA",("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET));