首页 / RABBITMQ / SpringCloud stream连接RabbitMQ收发信息

SpringCloud stream连接RabbitMQ收发信息

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了SpringCloud stream连接RabbitMQ收发信息，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3077字，纯文字阅读大概需要5分钟。

内容图文

 1、POM引入spring-cloud-starter-stream-rabbit

注意springboot 版本，用1.5.2.RELEASE 就报错 rabbitmqTemple not found

sb版本切换到1.5.14 就好了

技术分享图片 技术分享图片 
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.14.RELEASE</version>
        <relativePath /> <!-- lookup parent from repository -->
    </parent>

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

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Edgware.SR4</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
View Code

 

 

2、Bindings

            public
            interface
             OrderStream {

    
    @Output(ORDER_OUT)
    MessageChannel outOrder();

    @Input(ORDER_INPUT)
    SubscribableChannel inputOrder();
    
    
    @Output(ORDER_OUT_R)
    MessageChannel outOrderR();


    @Input(ORDER_INPUT_R)
    SubscribableChannel inputOrderR();
}

 

        ORDER_OUT 用用于发送消息，ORderOUT_R 用于接收消息回调
如果input 里面的名称 和 output 配置一样会报错

3、发送
指定bindings
    
@SuppressWarnings("SpringJavaAutowiringInspection")
@EnableBinding({OrderStream.class})
publicclass OrderMsgProceducer {


    privatestaticfinal Logger log = LoggerFactory.getLogger(OrderMsgProceducer.class);
    @Autowired
    @Qualifier(OrderStream.ORDER_OUT)
    private MessageChannel messageChannel;

    publicvoid send(Order timingEvent) {
        Message<Order> message = MessageBuilder.withPayload(timingEvent).build();
        messageChannel.send(message);
        log.info("send Mq:{}",message);
    }
}

 

4、接受 与回调

之所以能够接受到是因为

技术分享图片

接受的与发送的是一个

 

@SuppressWarnings("SpringJavaAutowiringInspection")
@EnableBinding({OrderStream.class})
publicclass OrderMsgConsumer {

    privatefinalstatic Logger log = LoggerFactory.getLogger(OrderMsgConsumer.class);

    @StreamListener(OrderStream.ORDER_OUT)
    @SendTo(OrderStream.ORDER_OUT_R)
    public String receiver(@Payload Order order) throws Exception {

        log.info("Receive Order To MQ:{}",order);
        log.debug("MQ END:{}",order);
        return "我收到了";
    }
    
    @StreamListener(OrderStream.ORDER_OUT_R)
    publicvoid receiverHuidiao(String msg) throws Exception {
        System.out.println("我接收回调......");
        System.out.println(msg);
    }
}

 

配置文件

spring.rabbitmq.host=1xxx
spring.rabbitmq.port=5673
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.cloud.stream.bindings.ORDER_SEND.content-type=application/json;charset=UTF-8
spring.cloud.stream.bindings.ORDER_SEND.producer.deliveryMode=PERSISTENT
spring.cloud.stream.bindings.ORDER_SEND.destination=ORDER_14
spring.cloud.stream.bindings.ORDER_SEND.group=becom
spring.cloud.stream.bindings.ORDER_SEND.consumer.maxAttempts=3
spring.cloud.stream.bindings.ORDER_SEND.consumer.backOffInitialInterval=1000
spring.cloud.stream.bindings.ORDER_SEND.consumer.concurrency=1
        group作用：如果我们启动两个服务，能够确保我们发送一个消息只被消费一次
    
         
测试
技术分享图片

 

        
            技术分享图片

技术分享图片

 

mq页面

技术分享图片

 

项目：

技术分享图片

 

原文：https://www.cnblogs.com/lyon91/p/10118383.html

内容总结

以上是互联网集市为您收集整理的SpringCloud stream连接RabbitMQ收发信息全部内容，希望文章能够帮你解决SpringCloud stream连接RabbitMQ收发信息所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1119128.html

来源：【匿名】