Spring Cloud Stream 消息驱动 RabbitMQ 基础使用
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Spring Cloud Stream 消息驱动 RabbitMQ 基础使用相关的知识，希望对你有一定的参考价值。
参考技术A项目的快速搭建参照官方 Creating a Sample Application by Using Spring Initializr
RabbitMQ部署在DockerSwarm集群
加入依赖
再选择Kafka或RabbitMQ
修改启动类
Sink的源码
先启动项目，启动前配置一下rabbitmq连接
启动项目
启动日志中有rabbitmq的连接及注册通道的信息
查看Rabbitmq的queue
查看控制台，已接收到消息
举个例子，假如只有一个消息生产者和一个消费者，消息能正常处理，在微服中可能一个消费者会有多个实例，一个消息会被多个实例处理，这样就出现了消息重复的问题，给消费者分组之后，一个消费者的多个实例中只会有一个实例处理消息
项目改造
启动类
创建一个消息监听 SinkMsgRecvicer
写一个测试的TestController
需要增加web依赖
启动项目 访问 http://localhost:8080/send?name=liangwang
控制台会有输出
待续。。。
以上是关于Spring Cloud Stream 消息驱动 RabbitMQ 基础使用的主要内容，如果未能解决你的问题，请参考以下文章
spring cloud 2.x版本 Spring Cloud Stream消息驱动组件基础教程（kafaka篇）
SpringCloud - Spring Cloud 之 Stream构建消息驱动微服务框架；Spring Cloud Alibaba集成RocketMQ（二十四）