Spring Cloud Stream与RabbitMQ整合时Producer与Consumer的相关配置

生产者属性

下面的属性都必须添加前缀：

spring.cloud.stream.<rabbitName>.bindings.<channelName>.producer.

如果Spring Cloud创建了一个rabbit实例，则上述配置中的rabbitName的名称一般为"rabbit"，不需要做变更；如果创建了多个rabbit实例,则rabbitName需要修改为其创建的实例名称,channelName表示管道名称。

routingKeyExpression：使用一个SpEL表达式，指定发布的消息使用哪个路由key。如果是固定的key，在properties 文件中配置routingKeyExpression='my.routingKey'；在yaml文件中则是routingKeyExpression: '''my.routingKey'''，其配置示例如下：

spring:cloud:stream:rabbit:bindings:#管道名称test_output_channel:producer:#指定生产者消息投递的routing keyrouting-key-expression: '''key1'''

Spring Cloud Stream与RabbitMQ整合时Producer与Consumer的相关配置相关推荐

Spring Cloud Stream与RabbitMQ整合
Spring Cloud与RabbitMQ整合需要引入下述依赖 <dependency><groupId>org.springframework.cloud</group ...
Spring Cloud Stream与RabbitMQ 死信队列
RabbitMQ的TTL全称为Time-To-Live,表示的是消息的有效期.消息如果在队列中一直没有被消费并且存在时间超过了TTL,消息就会变成"死信" (Dead Messag ...
介绍Spring Cloud Stream与RabbitMQ集成
一. 首先安装rabbitmq-management 这里用的是rabbitmq的docker镜像,我们可以在Docker Hub中搜索rabbitmq, 找到最新的版本安装 sudo docker ...
Spring Cloud Stream多RabbitMQ实例配置时报错no default binder has been set
当前Spring Cloud Rabbit的版本为2.1.2 <dependency><groupId>org.springframework.cloud</groupI ...
Spring Cloud Sleuth与Zipkin整合时遇到的问题记录(大湿胸文章集锦)
Spring Cloud Sleuth与Zipkin整合时遇到的问题记录将spring cloud sleuth的跟踪信息通过消息中间件收集发送到zipkin这一部分,在之前你已经按照第一种方式(h ...
【本人秃顶程序员】使用Spring Cloud Stream和RabbitMQ实现事件驱动的微服务
←←←←←←←←←←←← 快!点关注让我们展示如何使用Spring Cloud Stream来设计事件驱动的微服务.首先,Spring Cloud Stream首先有什么好处?因为Spring AM ...
Spring Cloud Stream 与 Kafka 整合
重要注意事项: 1. 尽管 Spring Cloud Stream Binder 中存在 Kafka 的整合,然而Spring Kafka 和 Spring Cloud Stream Kafka 在处 ...
使用Spring Cloud Stream与RabbitMQ集成
在我以前的文章中,我写了两个系统之间非常简单的集成场景-一个生成一个工作单元,另一个处理该工作单元,以及Spring Integration如何使这种集成非常容易. 在这里,我将演示如何使用Sprin ...
Spring Cloud Stream与RabbitMQ 生产者和消费者位于同一个应用服务
第一种模型:交换机类型为topic,路由key为"#",这是简单的使用模型当前Spring Cloud Rabbit的版本为2.1.2 <dependency>< ...

Spring Cloud Stream与RabbitMQ整合时Producer与Consumer的相关配置

Spring Cloud Stream与RabbitMQ整合时Producer与Consumer的相关配置相关推荐

最新文章

热门文章