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

完善 rocketmq-produce-example 项目

• • 1.添加一个配置文件
• 2.添加一个启动类
• 3.添加 MQSource
• 4.添加发送消息的类
• 5.添加配置类
• 6.事务消息往往需要我们监听回查
• 7.构建一个简单的模型
• 8.测试消息的发送
• 9.启动类

1.添加一个配置文件

• 配置信息如下：

logging.level.com.alibaba.cloud.stream.binder.rocketmq=DEBUG

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

spring.cloud.stream.bindings.output1.destination=test-topic
spring.cloud.stream.bindings.output1.content-type=application/json
spring.cloud.stream.rocketmq.bindings.output1.producer.group=binder-group
spring.cloud.stream.rocketmq.bindings.output1.producer.sync=true

spring.cloud.stream.bindings.output2.destination=TransactionTopic
spring.cloud.stream.bindings.output2.content-type=application/json
spring.cloud.stream.rocketmq.bindings.output2.producer.transactional=true
spring.cloud.stream.rocketmq.bindings.output2.producer.group=myTxProducerGroup

spring.cloud.stream.bindings.output3.destination=pull-topic
spring.cloud.stream.bindings.output3.content-type=text/plain
spring.cloud.stream.rocketmq.bindings.output3.producer.group=pull-binder-group

spring.application.name=rocketmq-produce-example

server.port=28081

management.endpoints.web.exposure.include=*
management.endpoint.health.show-details=always

2.添加一个启动类

@SpringBootApplication 
public class RocketMQProduceApplication {
   
   
      
	public static void main(String[] args) {
   
   
      
		SpringApplication.run(RocketMQProduce