基本概念

<p class="shortdesc"></p> <table class="table" id="Concepts__table_mcf_n5w_cmb"><caption></caption><colgroup><col><col></colgroup><thead class="thead"> <tr class="row"> <th class="entry" id="Concepts__table_mcf_n5w_cmb__entry__1">名称</th> <th class="entry" id="Concepts__table_mcf_n5w_cmb__entry__2">含义</th> </tr> </thead><tbody class="tbody"> <tr class="row"> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__1 "><p class="p">Broker</p></td> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__2 "><p class="p">MQ服务器,消息队列 MQ 服务端集群包含一个或多个Broker。</p></td> </tr> <tr class="row"> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__1 "><p class="p">Topic</p></td> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__2 "><p class="p">消息主题,用于消息分类,每条发布到消息队列 MQ 集群的消息都有一个Topic。</p></td> </tr> <tr class="row"> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__1 "><p class="p">生产者(Producer)</p></td> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__2 "><p class="p">消息生产者,也称为消息发布者,负责生产并发送消息到Broker。</p></td> </tr> <tr class="row"> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__1 "><p class="p">ProducerId</p></td> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__2 "><p class="p">一类Producer的标示。</p></td> </tr> <tr class="row"> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__1 "><p class="p">消费者(Consumer)</p></td> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__2 "><p class="p">消息消费者,也称为消息订阅者,负责从Broker读取消息并进行消费。</p></td> </tr> <tr class="row"> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__1 "><p class="p">ConsumerId</p></td> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__2 "><p class="p">一类Consumer的标示。</p></td> </tr> <tr class="row"> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__1 "><p class="p">Tag</p></td> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__2 "><p class="p">消息标签,用于进一步区分某个Topic下的消息。</p></td> </tr> <tr class="row"> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__1 "><p class="p">Message Key</p></td> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__2 "><p class="p">消息的唯一标识,由系统自动生成,可唯一标识某条消息。</p></td> </tr> <tr class="row"> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__1 "><p class="p">Message Id</p></td> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__2 "><p class="p">消息的唯一标识,由系统自动生成。</p></td> </tr> <tr class="row"> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__1 "><p class="p">集群消费</p></td> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__2 "><p class="p">一个ConsumerId 所标识的所有 Consumer 平均分摊消费消息。例如某个 Topic 有 9 条消息,一个ConsumerId有 3 个 Consumer 实例,那么在集群消费模式下每个实例平均分摊,只消费其中的 3 条消息。</p></td> </tr> <tr class="row"> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__1 "><p class="p">广播消费</p></td> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__2 "><p class="p">一个ConsumerId 所标识的所有 Consumer 都会各自消费某条消息一次。例如某个 Topic 有 9 条消息,一个ConsumerId 有 3 个 Consumer 实例,那么在广播消费模式下每个实例都会各自消费 9 条消息。</p></td> </tr> <tr class="row"> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__1 "><p class="p">延时消息</p></td> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__2 "><p class="p">消息生产者将消息发送到Broker,但并不期望这条消息立马投递,而是延迟一定时间后才投递给消费者进行消费,该消息即延时消息。</p></td> </tr> <tr class="row"> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__1 "><p class="p">消息过滤</p></td> <td class="entry" headers="Concepts__table_mcf_n5w_cmb__entry__2 "><p class="p">消费者客户端进行消息消费时,可以根据消息标签(Tag)对消息进行过滤,确保最终只接收被过滤后的消息类型。</p></td> </tr> </tbody></table>
以上内容是否解决了您的问题?
请补全提交信息!
咨询·建议

电话咨询

400-151-8800

邮件咨询

cloud@pingan.com

在线客服

工单支持

解决云产品相关技术问题