博客

概述

屏蔽底层消息中间件的差异，降低切换成本，统一消息的编程模型。

目前仅支持rebbitmq和kafka

Stream常用注解简介

@Input：标识输入通道，通过该输入通道接收到的消息进入应用程序

@Output：标识输出通道，发布的小童将通过该通道离开应用程序

@StreaListener:监听队列，用于消费者的队列的消息接收

@EnableBinding：channel和exchange绑定在一起

消息生产者（rabbitmq为例）

新增消息驱动maven依赖

 <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
        </dependency>

配置文件

server:
  port: 8801
spring:
  application:
    name: cloud-stream-provider
  cloud:
    stream:
      binders: #在此处配置要绑定的rabbitmq的服务信息
        defaultRabbit: #表示定义的名称，用于binding整合
          type: rabbit #消息组件类型
          environment: #设置rabbitmq相关的环境配置
            spring: