首页 > 其他分享 >spring cloud stream RabbitMQ实践

spring cloud stream RabbitMQ实践

时间:2023-07-19 18:44:30浏览次数:49  
标签:stream spring RabbitMQ kafka queue rabbit cloud

上一篇文章介绍了《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

相关文章

  • springcloud stream kafka实践
    SpringCloudStream是SpringCloud提供的一个用于构建消息驱动的微服务的框架。它简化了消息系统(如Kafka,rabbitMQ)的使用和集成,使开发者可以更专注于业务逻辑的实现。项目结构如下 一、移入依赖创建一个springbootweb项目引入依赖1<properties>2<java.version>1......
  • springboot——yaml格式
    ......
  • spring事务
    Spring声明式事务让我们从复杂的事务处理中得到解脱。使得我们再也无需要去处理获得连接、关闭连接、事务提交和回滚等这些操作。再也无需要我们在与事务相关的方法中处理大量的try…catch…finally代码。我们在使用Spring声明式事务时,有一个非常重要的概念就是事务属性。事务属性......
  • struts与spring集成
    1.struts与spring集成Spring和struts整合的四种方式。1.使用Spring的ActionSupport2.使用Spring的DelegatingRequestProcessor类。3.全权委托。org.springframework.web.struts.DelegatingActionProxy4.使用org.springframework.web.struts.AutowiringRequestProcessor......
  • AAudioStream
    AAudioStream的实现流程1.概述在开始之前,我们需要了解AAudioStream是什么以及它的作用。AAudioStream是AndroidNDK中的一个类,用于实现低延迟音频数据的读取和写入。它提供了一种高效的方式来进行音频处理和音频录制。在本文中,我们将教会你如何使用AAudioStream这个类。2.实现......
  • springboot
    起步依赖这两个包的源码:第一个:<developers><developer><name>Pivotal</name><email>[email protected]</email><organization>PivotalSoftware,Inc.</organization><organizationUrl>https://www.sprin......
  • 转:springboot2.0 集成redis服务详解,以及 (Lettuce & Jedis)
    springboot2.0集成redis服务详解,以及(Lettuce&Jedis)   ......
  • springboot简介
    spring程序于springboot程序对比springboot程序必须联网  另外可以去spring的官网创建项目进入spring官网选择这个选择配置点击generate生成会生成zip压缩文件......
  • HTTP/2 stream 1 was not closed cleanly before end of the underlying stream解决
    通过gitclone文件时报错HTTP/2stream1wasnotclosedcleanlybeforeendoftheunderlyingstream解决:gitconfig--globalhttp.versioinHTTP/1.1重新gitclone就可以了。 了解HTTP/2与HTTP/1.1区别:https://www.cnblogs.com/flydean/p/15187719.html有问题......
  • spring boot 如何配置多个数据源,mysql和oracle
    在SpringBoot中配置多个数据源,例如MySQL和Oracle,可以通过以下步骤实现:添加依赖在pom.xml文件中添加MySQL和Oracle的依赖:<!--MySQL--><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><!......