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

完善 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