导航菜单

Spring Cloud Stream 整合 RabbitMQ

专注,不要迷路;不断更新Java相关技术和信息!

简介

Spring Cloud Stream是一个用于构建消息驱动的微服务的框架。应用程序通过输入(相当于消费者)和输出(相当于生产者)与Spring Cloud Stream中的Binder交互,Binder负责与消息中间件交互;因此,我们只关注如何与Binder进行交互,而无需专注于与特定的消息中间件交互。

快速入门

1、添加依赖

Org.springframework.cloud spring-cloud-stream-binder-rabbit2.1.2.RELEASE

2、配置文件

提供商配置(使用动态路由密钥)

服务器:端口: 7071spring:云:流:绑定器: pro:类型: rabbit环境: spring: rabbitmq:地址: localhost端口: 5672用户名:测试密码:测试虚拟主机: testbindings: myOutPut:目标: myOutPut内容类型: application/json default-binder: test rabbit: bindings: myOutPut这里是文章图片 producer: exchangeType: topic routing-key-expression: headers.routeId

服务器:端口: 7072spring:云:流:兔子:绑定:输入:消费者: bindingRoutingKey: routeKey1确认模式:手动绑定器:抗议:类型: rabbit环境: spring: rabbitmq:地址: localhost端口: 5672用户名:测试密码:测试虚拟主机: testbindings:输入:目的地: myOutPut内容类型:应用程序/json default-binder:抗议组: group-cus1

3、自定义通道

公共接口MqMessageSource {//自定义通道字符串MY_OUT_PUT='myOutPut';

http://www.sugys.com/bds2u.html