上一篇文章介绍了《springcloud stream kafka实践》提到spring cloud 封装了消息中间件,只需要简单修改配置就可以切换消息中间件。在kafka的基础上,切换到rabbitmq。
一、 配置依赖
1 <dependency> 2 <groupId>org.springframework.cloud</groupId> 3 <artifactId>spring-cloud-stream-binder-rabbit</artifactId> 4 </dependency>
二、 修改配置文件
1 # 生成者配置 2 spring: 3 cloud: 4 stream: 5 bindings: 6 output: 7 destination: ${rabbit.queue} 8 input: 9 destination: ${rabbit.queue} 10 rabbitmq: 11 host: 192.168.3.100 12 port: 5672 13 username: xxxx 14 password: xxxx 15 rabbit: 16 queue: cloud-stream-queue
至此,由kafka切换到rabbitMQ完成改造
三、测试结果
控制台输出
标签:stream,spring,RabbitMQ,kafka,queue,rabbit,cloud From: https://www.cnblogs.com/lfhappy/p/17566477.html