认识达内从这里开始

认真做教育专心促就业

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

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

    济南达内培训的老师说，它通过@Input注解绑定了一个名为input的通道。除了Sink之外，Spring Cloud Stream还默认实现了绑定output通道的Source接口，还有结合了Sink和Source的Processor接口，实际使用时我们也可以自己通过@Input和@Output注解来定义绑定消息通道的接口。当我们需要为@EnableBinding指定多个接口来绑定消息通道的时候，可以这样定义：@EnableBinding（value = {Sink.class, Source.class}）。
    @StreamListener:该注解主要定义在方法上，作用是将被修饰的方法注册为消息中间件上数据流的事件监听器，注解中的属性值对应了监听的消息通道名。在上面的例子中，我们通过@StreamListener（Sink.INPUT）注解将receive方法注册为对input消息通道的监听处理器，所以当我们在RabbitMQ的控制页面中发布消息的时候，receive方法会做出对应的响应动作。
    编写消费消息的单元测试用例
    上面我们通过RabbitMQ的控制台完成了发送消息来验证了消息消费程序的功能，虽然这种方法比较low,但是通过上面的步骤，相信大家对RabbitMQ和Spring Cloud Stream的消息消费已经有了一些基础的认识。下面我们通过编写生产消息的单元测试用例来完善我们的入门内容。
    在上面创建的工程中创建单元测试类：
    @RunWith（SpringRunner.class）
    @EnableBinding（value = {SinkApplicationTests.SinkSender.class}）
    public class SinkApplicationTests {
    @Autowired
    private SinkSender sinkSender;
    @Test
    public void sinkSenderTester（） {

sinkSender.output（）。send（MessageBuilder.withPayload（“produce a message :#”）。build（））；

济南达内培训

    }
    public interface SinkSender {
    String OUTPUT = “input”;
    @Output（SinkSender.OUTPUT）
    MessageChannel output（）；
    }
    }
    在应用了上面的消息消费者程序之后，运行这里定义的单元测试程序，我们马上就能在消息消费者的控制台中收到下面的内容：
    INFO 50947 --- [L2W-c2AcChb2Q-1] com.didispace.stream.SinkReceiver : Received: produce a message :#
    在上面的单元测试中，我们通过@Output（SinkSender.OUTPUT）定义了一个输出通过，而该输出通道的名称为input,与前文中的Sink中定义的消费通道同名，所以这里的单元测试与前文的消费者程序组成了一对生产者与消费者。到这里，本文的内容就次结束，如果您能够独立的完成上面的例子，那么对于Spring Cloud Stream的基础使用算是入门了。但是，Spring Cloud Stream的使用远不止于此，在近期的博文中，我讲继续更新这部分内容，帮助他们来理解和用好Spring Cloud Stream来构建消息驱动的微服务！
    本文完整实例：
    https://github.com/dyc87112/SpringCloud-Learning/tree/master/2-Dalston%E7%89%88%E6%95%99%E7%A8%8B%E7%A4%BA%E4%BE%8B/stream-hello
    以上就是济南达内培训给大家做的内容详解，更多关于IT的学习，请继续关注济南达内培训

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

下一篇：Java 2018大事回顾（1） >