认识达内从这里开始

认真做教育专心促就业

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

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

    到这里，我们快速入门示例的编码任务就已经完成了。下面济南达内培训的我们分别启动RabbitMQ以及该Spring Boot应用，然后做下面的试验，看看它们是如何运作的。
    手工测试验证
    我们先来看一下Spring Boot应用的启动日志。
    …
    INFO 16272 --- [main] o.s.c.s.b.r.RabbitMessageChannelBinder : declaring queue for inbound: input.anonymous.Y8VsFILmSC27eS5StsXp6A, bound to: input
    INFO 16272 --- [main] o.s.a.r.c.CachingConnectionFactory : Created new connection: SimpleConnection@3c78e551 [delegate=amqp://guest@127.0.0.1:5672/]
    INFO 16272 --- [main] o.s.integration.channel.DirectChannel : Channel 'input.anonymous.Y8VsFILmSC27eS5StsXp6A.bridge' has 1 subscriber（s）。
    INFO 16272 --- [main] o.s.i.a.i.AmqpInboundChannelAdapter : started inbound.input.anonymous.Y8VsFILmSC27eS5StsXp6A
    …
    从上面的日志内容中，我们可以获得以下信息：
    使用guest用户创建了一个指向127.0.0.1:5672位置的RabbitMQ连接，在RabbitMQ的控制台中我们也可以发现它。
    声明了一个名为input.anonymous.Y8VsFILmSC27eS5StsXp6A的队列，并通过RabbitMessageChannelBinder将自己绑定为它的消费者。这些信息我们也能在RabbitMQ的控制台中发现它们。

我们可以发现在应用控制台中输出的内容就是SinkReceiver中receive方法定义的，而输出的具体内容则是来自消息队列中获取的对象。这里由于我们没有对消息进行序列化，所以输出的只是该对象的引用，在后面的小节中我们会详细介绍接收消息后的处理。

济南达内培训

    在顺利完成上面快速入门的示例后，我们简单解释一下上面的步骤是如何将我们的Spring Boot应用连接上RabbitMQ来消费消息以实现消息驱动业务逻辑的。
    首先，我们对Spring Boot应用做的就是引入spring-cloud-starter-stream-rabbit依赖，该依赖包是Spring Cloud Stream对RabbitMQ支持的封装，其中包含了对RabbitMQ的自动化配置等内容。从下面它定义的依赖关系中，我们还可以知道它等价于spring-cloud-stream-binder-rabbit依赖。
    <dependencies>
    <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
    </dependency>
    </dependencies>
    接着，我们再来看看这里用到的几个Spring Cloud Stream的核心注解，它们都被定义在SinkReceiver中：
    @EnableBinding,该注解用来指定一个或多个定义了@Input或@Output注解的接口，以此实现对消息通道（Channel）的绑定。在上面的例子中，我们通过@EnableBinding（Sink.class）绑定了Sink接口，该接口是Spring Cloud Stream中默认实现的对输入消息通道绑定的定义，它的源码如下：
    public interface Sink {
    String INPUT = “input”;
    @Input（Sink.INPUT）
    SubscribableChannel input（）；
    }
    以上就是济南达内培训给大家做的内容详解，更多关于IT的学习，请继续关注济南达内培训

< 上一篇：Spring Cloud构建微服务架构（1）

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