认识达内从这里开始

认真做教育专心促就业

Spring Cloud构建微服务架构（1）

发布：济南达内培训
来源：济南达内培训
时间：2019-01-09 16:17

在该文中，我们通过简单的配置和注解就能实现向RabbitMQ中生产和消费消息。实际上我们使用的对RabbitMQ的starter就是通过Spring Cloud Stream中对RabbitMQ的支持来实现的。下面我们就通过本文来了解一下Spring Cloud Stream.-济南达内培训负责整理
    Spring Cloud Stream是一个用来为微服务应用构建消息驱动能力的框架。它可以基于Spring Boot来创建独立的、可用于生产的Spring应用程序。它通过使用Spring Integration来连接消息代理中间件以实现消息事件驱动的微服务应用。Spring Cloud Stream为一些供应商的消息中间件产品提供了个性化的自动化配置实现，并且引入了发布-订阅、消费组以及消息分区这三个核心概念。简单的说，Spring Cloud Stream本质上就是整合了Spring Boot和Spring Integration,实现了一套轻量级的消息驱动的微服务框架。通过使用Spring Cloud Stream,可以有效地简化开发人员对消息中间件的使用复杂度，让系统开发人员可以有更多的精力关注于核心业务逻辑的处理。由于Spring Cloud Stream基于Spring Boot实现，所以它秉承了Spring Boot的优点，实现了自动化配置的功能帮忙我们可以快速的上手使用，但是目前为止Spring Cloud Stream只支持下面两个着名的消息中间件的自动化配置：
    RabbitMQ
    Kafka
    快速入门
    下面我们通过构建一个简单的示例来对Spring Cloud Stream有一个初步认识。该示例主要目标是构建一个基于Spring Boot的微服务应用，这个微服务应用将通过使用消息中间件RabbitMQ来接收消息并将消息打印到日志中。所以，在进行下面步骤之前请先确认已经在本地安装了RabbitMQ,具体安装步骤请参考此文。
    构建一个Spring Cloud Stream消费者
    创建一个基础的Spring Boot工程，命名为：stream-hello
    编辑pom.xml中的依赖关系，引入Spring Cloud Stream对RabbitMQ的支持，具体如下：
    <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.9.RELEASE</version>
    <relativePath/> 
    </parent>
    <dependencies>
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
    </dependency>
    <dependency>
    <groupId>org.springframework.cloud</groupId>

<artifactId>spring-cloud-starter-stream-rabbit</artifactId>

济南达内培训

    </dependency>
    </dependencies>
    <dependencyManagement>
    <dependencies>
    <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-dependencies</artifactId>
    <version>Dalston.SR4</version>
    <type>pom</type>
    <scope>import</scope>
    </dependency>
    </dependencies>
    </dependencyManagement>
    创建用于接收来自RabbitMQ消息的消费者SinkReceiver,具体如下：
    @EnableBinding（Sink.class）
    public class SinkReceiver {
    private static Logger logger = LoggerFactory.getLogger（SinkReceiver.class）；
    @StreamListener（Sink.INPUT）
    public void receive（Object payload） {
    #（“Received: ” + payload）；
    }
    }
    创建应用主类，这里同其他Spring Boot一样，没有什么特别之处，具体如下：
    @SpringBootApplication
    public class SinkApplication {
    public static void main（String[] args） {
    SpringApplication.run（SinkApplication.class, args）；
    }
    }
    以上就是济南达内培训给大家做的内容详解，更多关于IT的学习，请继续关注济南达内培训

< 上一篇：Spring Boot中使用RabbitMQ（4）

下一篇：Spring Cloud构建微服务架构（2） >