消息消费要注意的细节|学习笔记

简介: 快速学习消息消费要注意的细节

开发者学堂课程【全面讲解 Spring Cloud Alibaba 技术栈(知识精讲+项目实战)第四阶段消息消费要注意的细节】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址https://developer.aliyun.com/learning/course/686/detail/11912


消息消费要注意的细节


1、代码

@RocketMQMessageListener(

I consumerGroup ="shop",//消费者分组

topic="order-topic",//要消费的主题

consumeMode=ConsumeMode.CONCURRENTLY//消费模式:无序和有序

messageMode]=MessageMode1.CLUSTERING,//消息模式:广播和集群,默认是集群

)

public class SmsService implements

RocketMQListener<Order> {}

消费的细节是围绕着 RocketMQ Listener, RocketMQ 的消息监听路径展开:

packagecom.itheima.service;

import com.itheima.domain.order;

import lombok.extern.slf4i.Slf4i;

import

org.apache.rocketmg.spring.annotation.RocketMOMes

sageListener:

import

orq.apache.rocketmg.spring.core.RocketMolistener;

import orq.springframework.stereotype.Service;

@S1f4j

@Service

//consumerGroup-消费者组名topic-要消费的主题

@RocketMOMessageListener(

consumerGroup="shop-user",//消费者组名

topic="order-topic",//消费主题

consumeMode =ConsumeMode.CONCURRENTLY/消费模式,

指定是否顺序消费CONCURRENTLY(同步默认) ORDERLY()

messaqeModel =MessaqeMode1.CLUSTERING//消息模式

BROADCASTING(广播) CLUSTERING(集群,默认)

//点进 messaqeModel 可以看到默认的为集群模式

image.png

2、RocketMQ 支持两种消息模式

广播消费:每个消费者实例都会收到消息,也就是一条消息可以被每个消费者实例处理:

集群消费:一条消息只能被一个消费者实例消费

image.png

比如有两个消息消费者生产者向里面投一个消息,如果是集群意味着一个消息消费者消费,另一个没法再消费。如果是广播意味着个消息会消费一次,另一个也消费一次

相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
8月前
|
消息中间件 Java API
RocketMQ事务消息, 图文、源码学习探究~
介绍 RocketMQ是阿里巴巴开源的分布式消息中间件,它是一个高性能、低延迟、可靠的消息队列系统,用于在分布式系统中进行异步通信。 从4.3.0版本开始正式支持分布式事务消息~ RocketMq事务消息支持最终一致性:在普通消息基础上,支持二阶段的提交能力。将二阶段提交和本地事务绑定,实现全局提交结果的一致性。 原理、流程 本质上RocketMq的事务能力是基于二阶段提交来实现的 在消息发送上,将二阶段提交与本地事务绑定 本地事务执行成功,则事务消息成功,可以交由Consumer消费 本地事务执行失败,则事务消息失败,Consumer无法消费 但是,RocketMq只能保证本地事务
|
负载均衡 网络性能优化
EMQ如何保证消息不重复消费?
EMQ(Erlang MQTT Broker)通过以下机制来保证消息不重复消费
800 2
|
消息中间件 Java uml
5张图带你理解 RocketMQ 顺序消息实现机制
5张图带你理解 RocketMQ 顺序消息实现机制
727 1
5张图带你理解 RocketMQ 顺序消息实现机制
|
消息中间件 缓存 数据库
4 张图,9 个维度告诉你怎么做能确保 RocketMQ 不丢失消息
4 张图,9 个维度告诉你怎么做能确保 RocketMQ 不丢失消息
436 0
4 张图,9 个维度告诉你怎么做能确保 RocketMQ 不丢失消息
|
消息中间件 RocketMQ 开发者
消息消费方准备工作|学习笔记
快速学习消息消费方准备工作
消息消费方准备工作|学习笔记
|
消息中间件 运维 监控
多类型业务消息专题-普通消息 | 学习笔记(一)
快速学习多类型业务消息专题-普通消息
173 0
 多类型业务消息专题-普通消息 | 学习笔记(一)
|
消息中间件 存储 运维
多类型业务消息专题-普通消息 | 学习笔记(二)
快速学习多类型业务消息专题-普通消息
136 0
多类型业务消息专题-普通消息 | 学习笔记(二)
|
存储 消息中间件 Linux
多类型业务消息专题-顺序消息 | 学习笔记
快速学习多类型业务消息专题-顺序消息
多类型业务消息专题-顺序消息 | 学习笔记
|
消息中间件 NoSQL Kafka
|
消息中间件 RocketMQ 开发者
消息消费概述|学习笔记
快速学习消息消费概述