当前位置: 首页 > news >正文

建设银行网站怎么修改手机号码吗注册网站名字

建设银行网站怎么修改手机号码吗,注册网站名字,怎么设置网站名称,Wordpress无法显示1 简介 了解过RabbitMQ后,可能我们会遇到不同的系统在用不同的队列。比如系统A用的Kafka,系统B用的RabbitMQ,但是没了解过Kafka,因此可以使用Spring Stream,它能够屏蔽地产,像JDBC一样,只关心SQ…

1 简介

了解过RabbitMQ后,可能我们会遇到不同的系统在用不同的队列。比如系统A用的Kafka,系统B用的RabbitMQ,但是没了解过Kafka,因此可以使用Spring Stream,它能够屏蔽地产,像JDBC一样,只关心SQL和业务本身,不关心数据库的具体实现。

在这里插入图片描述
创建一个新的项目测试
在这里插入图片描述
导入SpringCloud依赖

    <dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>2021.0.1</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

在这里插入图片描述
新建两个模块,一个生产者一个消费者
在这里插入图片描述
在这里插入图片描述
给两个模块导入依赖

<dependencies><!--  RabbitMQ的Stream实现  --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-stream-rabbit</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency>
</dependencies>

在这里插入图片描述
在这里插入图片描述

1.1 编写生产者

首先是配置文件
在这里插入图片描述

server:port: 8001
spring:cloud:stream:binders:   #此处配置要绑定的rabbitmq的服务信息local-server: #绑定名称,随便起一个就行type: rabbit #消息组件类型,这里使用的是RabbitMQ,就填写rabbitenvironment:  #服务器相关信息,按照下面的方式填写就行,爆红别管spring:rabbitmq:host: 8.130.172.119port: 5672username: adminpassword: passwordvirtual-host: /bindings:test-out-0:destination: test.exchange

在这里插入图片描述
在这里插入图片描述
然后编写controller,访问一次接口,就向消息队列发送一个数据:

@RestController
public class PublishController {@ResourceStreamBridge bridge;  //通过bridge来发送消息@RequestMapping("/publish")public String publish(){//第一个参数其实就是RabbitMQ的交换机名称(数据会发送给这个交换机,到达哪个消息队列,不由我们决定)//这个交换机的命名稍微有一些规则://输入:    <名称> + -in- + <index>//输出:    <名称> + -out- + <index>//这里我们使用输出的方式,来将数据发送到消息队列,注意这里的名称会和之后的消费者Bean名称进行对应bridge.send("test-out-0", "HelloWorld!");return "消息发送成功!"+new Date();}
}

在这里插入图片描述
在这里插入图片描述
这里生产者就完成了

1.2 消费者

编写配置文件

因为消费者是输入,默认名称为 方法名-in-index,这里我们将其指定为我们刚刚定义的交换机

在这里插入图片描述

消费者启动类
在这里插入图片描述
直接定义一个consumer类型的bean即可

@Component
public class ConsumerComponent {@Bean("test")   //注意这里需要填写我们前面交换机名称中"名称",这样生产者发送的数据才会正确到达public Consumer<String> consumer(){return System.out::println;}
}

在这里插入图片描述
此时消费者就编写完成

1.3 启动测试

启动两个服务
在这里插入图片描述
在这里插入图片描述

访问controller
在这里插入图片描述
消费者接收到消息
在这里插入图片描述
这样就通过SpringCloud Stream屏蔽掉底层RabbitMQ来直接进行消息的操作了

http://www.yayakq.cn/news/689033/

相关文章:

  • dw做购物网站中国网络购物市场研究报告
  • 网站开发费计入什么会计科目seo综合查询平台
  • 北京高端网站公司哪家好全国网站建设哪家好
  • 爱站网使用的是什么网站网站集约化建设管理
  • 西安网站建设中心代理加盟微信网站建设
  • wordpress搬站换空间微信上wordpress
  • 360建站的应用场景手机端网站建站手册
  • 湖州建设网站制作上海做网站优化哪家好
  • 织梦网站 防黑有没有免费的seo网站
  • 上传了网站源码怎么做过期网站查询
  • 响应式企业营销型网站多少钱济南历山北路网站建设
  • 网站建设來超速云建站网页设计代码动漫
  • 淄博微网站建设佛山建设银行网站
  • 绿色风格 网站宣传网站模板
  • 技术支持 祥云平台 英文网站谷歌浏览器官网
  • 社交网站建设网网页qq登录保护功能怎么关闭
  • 商务互联做网站怎么样小说网站建设费用
  • 用wordpress做网站页面显示404深圳网站建设 外包合作
  • 什么是网站源码公司做网站是com好还是cn好
  • 江门网站建设工作龙岩电商公司
  • 学术网站建设wordpress 段落背景颜色
  • 广州哪里可以做网站怎样建设一个网站赚钱
  • 西安做网站公司 玖佰网络wordpress 分词插件
  • 视觉设计类网站网页制作简明教程
  • 网站动态和静态的区别网站备案怎么办
  • dedecms免费网站模板山东省住房和城乡建设厅二级建造师
  • 怀化市网站建设个人网站 服务器
  • 锦州制作网站公司给企业做网站的公司西安
  • 织梦(dedecms)怎么修改后台网站默认"织梦内容管理系统"标题网络推广技巧与方法
  • 在线男人和女人做那件事网站服务器是干嘛的