Java架构(十七)整合springcloud云架构消息驱动SpringCloudStream

在使用spring cloud云架构的时候&＃xff0c;我们不得不使用Spring cloud Stream&＃xff0c;因为消息中间件的使用在项目中无处不在&＃xff0c;我们公司后面做了娱乐方面的APP&＃xff0c;在使用spring cloud做架构的时候&＃xff0c;其中消息的异步通知&＃xff0c;业务的异步处理都需要使用消息中间件机制。spring cloud的官方给出的集成建议&＃xff08;使用rabbit mq和kafka&＃xff09;&＃xff0c;我看了一下源码和配置&＃xff0c;只要把rabbit mq集成&＃xff0c;kafka只是换了一个pom配置jar包而已&＃xff0c;闲话少说&＃xff0c;我们就直接进入配置实施&＃xff1a;

1. 简介&＃xff1a;

Spring cloud Stream 数据流操作开发包&＃xff0c;封装了与Redis,Rabbit、Kafka等发送接收消息。

2. 使用工具&＃xff1a;

rabbit&＃xff0c;具体的下载和安装细节我这里不做太多讲解&＃xff0c;网上的实例太多了

3. 创建commonservice-mq-producer消息的发送者项目&＃xff0c;在pom里面配置stream-rabbit的依赖

Java代码

4. 在yml文件里面配置rabbit mq

Java代码

5. 定义接口ProducerService

Java代码

6. 定义绑定

Java代码

7. 定义发送消息业务ProducerController

Java代码

8. 创建commonservice-mq-consumer1消息的消费者项目&＃xff0c;在pom里面配置stream-rabbit的依赖

Java代码

定义接口ConsumerService

Java代码

定义启动类和消息消费

Java代码

分别启动commonservice-mq-producer、commonservice-mq-consumer1
通过postman来验证消息的发送和接收

可以看到接收到了消息&＃xff0c;下一章我们介绍mq的集群方案。

欢迎大家和我一起学习spring cloud构建微服务云架构&＃xff0c;我这边会将近期研发的spring cloud微服务云架构的搭建过程和精髓记录下来&＃xff0c;帮助更多有兴趣研发spring cloud框架的朋友&＃xff0c;大家来一起探讨spring cloud架构的搭建过程及如何运用于企业项目。

我本人邀约各大BATJ架构大牛共创Spring Cloud构建微服务架构的交流社区。 &＃xff08;群号&＃xff1a;573988200&＃xff09;欢迎各路架构师、开发者&＃xff0c;学习与交流使用Spring Cloud诸多强大组件的实战经验。

为什么某些人会一直比你优秀&＃xff0c;是因为他本身就很优秀还一直在持续努力变得更优秀&＃xff0c;而你是不是还在满足于现状内心在窃喜!

合理利用自己每一分每一秒的时间来学习提升自己&＃xff0c;不要再用"没有时间“来掩饰自己思想上的懒惰&＃xff01;趁年轻&＃xff0c;使劲拼&＃xff0c;给未来的自己一个交代&＃xff01;

希望此文能帮到大家的同时&＃xff0c;也听听大家的观点。欢迎留言讨论&＃xff0c;加关注&＃xff0c;分享你的高见&＃xff01;持续更新&＃xff01;

To-陌霖Java架构

分享互联网最新文章关注互联网最新发展