44、SpringCloudAlibaba实战：消息队列：完善rocketmq-consumer-example项目

本文详细讲解如何完善RocketMQ消费者示例项目，包括添加配置文件、创建Sink、配置消息监听器、主动拉取消息以及模型类、配置类和启动类的完整实现步骤，适用于Spring Cloud Stream与RocketMQ集成开发。

完善 rocketmq-consumer-example 项目

- 1.添加配置文件
2.添加一个 Sink
6.3创建消息的监听器
4.主动去 mq 服务器拉起消息
5.模型类
6.配置类
7.启动类

1.添加配置文件

内容如下：

spring.cloud.stream.rocketmq.binder.name-server=127.0.0.1:9876

spring.cloud.stream.bindings.input1.destination=test-topic
spring.cloud.stream.bindings.input1.content-type=text/plain
spring.cloud.stream.bindings.input1.group=test-group1
spring.cloud.stream.rocketmq.bindings.input1.consumer.orderly=true

spring.cloud.stream.bindings.input2.destination=test-topic
spring.cloud.stream.bindings.input2.content-type=text/plain
spring.cloud.stream.bindings.input2.group=test-group2
spring.cloud.stream.rocketmq.bindings.input2.consumer.orderly=false
spring.cloud.stream.rocketmq.bindings.input2.consumer.tags=tagStr
spring.cloud