开发者学堂课程【RocketMQ 知识精讲与项目实战（第三阶段）：消息消费初探】学习笔记，与课程紧密联系，让用户快速学习知识。
课程地址：https://developer.aliyun.com/learning/course/704/detail/12493
消息消费初探
消息消费初探
以消息推送的模式来去研究里面有哪些重要的方法，其实这里有一个顶层的一个类叫做MQC consumer，它下边有一个扩展的接口叫做 MQPushConsumer，它就是推模式的一个消费者，针对这个接口有一个实现叫做 Default MQPush consumer，重点来看其中有哪些方法。
第一个方法在这里边叫做 send message back，的意思是说发送消息的一个确认，就是消息消费完了之后通过这个方法可以发送它的一个确认。第二种sub scribemessage queens，它就是获取消费者对主题分配了哪些队列，这个返回来的就是一个队列的集合，然后这里有几个方法就是去注册并发事件的一个消息的监听器，那还有一个就是注册顺序消息的一个事件的监听器。另外还有两种方法就是订阅消息的，那这个是基于主题订阅消息的，然后支持过滤，那么一种过滤就是支持表达式，另外一种过滤就是基于类的模式去过滤。其他的还有去订阅消息，然后去指定消费的队列，unsubscribe 就是取消消息的订阅。
看这个类当中有哪些方法？它有很多重要的属性，有消费者祖、消息消费模式到底是集训模式还是广播模式，它默认的是集群模式。然后去指定消息消费开始偏移量，然后还有集群模式下的消息队列负载策略和订阅消息相关的一个集合信息，然后这里还有就是业务的一个监听器，拿到消息之后通过这个监听器将消息传递给客户端，让客户端去消费。其他的还有消息进度存储器、消费者最大线程数量、并发消息消费时处理队列的最大跨度、每1000次流控后打印流控日志、推模式下任务间隔时间、推模式下任务拉取的条数为32条、每次传入 MessageListener 中的消息数量、是否每次拉取消息都订阅消息、消息重试次数以及消息消费超时时间。这是一些基于推模式下的一些主要的一些类，还有方法和属性进行了说明。
