Spring Cloud-22-Spring Cloud Stream整合RabbitMQ(上)

述

Spring Cloud Stream是一个构建消息驱动的微服务框架.它构建在Spring Boot之上,用以创建工业级的应用程序,并且通过Spring Integration提供了和消息代理的连接.

Spring Cloud Stream为一些供应商的消息中间件产品提供了个性化的自动化配置实现(目前仅支持RabbitMQ和Kafka),同时引入了发布订阅,消费组和分区的语义概念.

下面来通过一个简单的消息收发,看一下Spring Cloud Stream的基本用法.

整合RabbitMQ

新建工程

新建一个工程,名称是stream-rabbitmq

引入依赖

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

spring-cloud-starter-stream-rabbit是Spring Cloud Stream对RabbitMQ的封装,这里包含了对RabbitMQ的默认配置,比如连接的ip默认是localhost,默认端口是5672,默认用户是guest,如果我们需要修改的话,还是和上文一样,在配置文件中配置就可以了

修改配置

如果是用的默认配置的话,就不用修改,否则,就改成自己的配置, 直接把上篇文章中的配置复制过来就好,具体如下:

spring:
  application:
    name: stream-rabbitmq
  rabbitmq:
    host: 172.16.12.3
    port: 5672
    username: admin
    password: admin
server:
  port: 2010

创建消息消费者

创建一个消费者用来接收消息,代码如下:

/**
 * @author 周泽
 * @date Create in 16:34 2019/4/8
 * @Description 消息消费者
 */
@EnableBinding(Sink.class)
@Slf4j
public class SinkReceiver {

    @StreamListener(Sink.INPUT)
    public void receive(Object playload) {
        log.info("收到消息:{}", playload);
    }
}