码迷,mamicode.com
首页 > 编程语言 > 详细

spring cloud stream

时间:2018-01-15 18:52:28      阅读:204      评论:0      收藏:0      [点我收藏+]

标签:app   artifact   配置   控制   end   添加   http   ota   factor   

创建spring boot工程,添加pom依赖

技术分享图片
<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
        </dependency>
View Code

添加消息接收SinkReceiver

技术分享图片
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;

@EnableBinding(Sink.class)
public class SinkReceiver {
    private static Logger logger= LoggerFactory.getLogger(SinkReceiver.class);
    @StreamListener(Sink.INPUT)
    public void receive(Object payload){
        logger.info("Received: "+payload);
    }
}
View Code

配置

技术分享图片
spring.application.name=stream-hello

spring.rabbitmq.host=10.202.203.29
spring.rabbitmq.port=5672
spring.rabbitmq.username=springcloud
spring.rabbitmq.password=123456
View Code

运行程序,打开rabbitmq监控界面,可以看到

技术分享图片

技术分享图片

技术分享图片

技术分享图片

推送消息

技术分享图片

在控制台查看结果

技术分享图片

 

spring cloud stream

标签:app   artifact   配置   控制   end   添加   http   ota   factor   

原文地址:https://www.cnblogs.com/uptothesky/p/8288974.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!