spring boot使用mq

超、凢脫俗 2021-11-29 08:08 275阅读 0赞

1.引入mq依赖

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

2.配置配置mq，不然启用的是默认的mq配置

spring:  
      rabbitmq:
        host: localhost
        port: 5672
        username: guest
        password: guest

3.指定接受方和接受的exchange,和queue

//1.@RabbitListener(queues = "myQueue")
        //2@RabbitListener(queuesToDeclare = @Queue("myQueue"))
        @RabbitListener(bindings = @QueueBinding(
            value = @Queue("myQueue"),
                exchange = @Exchange("myExchange")
                ))
        public void Process(String message){
    
    
            log.info("message:{}",message);
    
        }

4.发送注入发送模板

@Autowired
        private AmqpTemplate amqpTemplate;
    
    @Test
        public void sends(){
    
            amqpTemplate.convertAndSend("myOrder","computer","now"+new Date());
    
        }

注意一点，商品发送过去的字符串信息，在转json时，必须去掉json字符串格式外的引号“”，

TypeReference<xx>() \{\});ObjectMapper.解决

发表评论取消回复

表情：

评论列表（有 0 条评论，275人围观）

还没有评论，来说两句吧...

相关阅读

相关 Spring Boot：使用Rabbit MQ消息队列

综合概述消息队列消息队列就是一个消息的链表，可以把消息看作一个记录，具有特定的格式以及特定的优先级。对消息队列有写权限的进程可以向消息队列中按照一定的规则添...

野性酷女/ 2024年04月18日 07:34/ 0 赞/ 31 阅读

相关为什么使用MQ

1.不使用消息队列的场景模拟一个原始的系统模型系统A需要调用系统B,C,D三个系统 ![watermark_type_ZmFuZ3poZW5naGVpdGk

阳光穿透心脏的1/2处/ 2022年12月25日 13:54/ 0 赞/ 159 阅读

相关 MQ原理、使用场景、IBM WebSphere MQ介绍及spring集成配置

一、MQ简介及特点 MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过写和检索出入列队的针对应用

本是古典何须时尚/ 2022年07月15日 02:13/ 0 赞/ 329 阅读

相关什么是MQ？什么时候使用MQ？为什么要使用MQ？

只是代码的搬运工~~~~~ 问题1：什么是MQ？什么时候使用MQ？为什么要使用MQ？ MQ，是一种跨进程的通信机制，用于上下游传递消息。在互联网架构中，MQ是一种非常常

向右看齐/ 2022年05月27日 13:54/ 0 赞/ 287 阅读

相关 Spring Boot | 3.4 Spring Boot日志使用

Spring Boot目录汇总地址： [https://blog.csdn.net/mengmengdastyle/article/details/80357203][ht

青旅半醒/ 2022年05月24日 13:47/ 0 赞/ 100 阅读

相关 MQ的使用和什么时候该使用MQ

原文地址：http://mp.weixin.qq.com/s/Brd-j3IcljcY7BV01r712Q 一、缘起一切脱离业务的架构设计与新技术引入都是耍流氓。

r囧r小猫/ 2022年05月18日 09:15/ 0 赞/ 224 阅读

相关 [MQ]使用MQ要解决的问题

1.如何实现高可用虽然消息队列可以带来异步解耦限流等优点,但同时也使得系统更加依赖MQ,稳定变差,一旦MQ挂掉,带来的问题十分严重. 2.如何保证消息的消费的幂等性

水深无声/ 2022年04月06日 15:18/ 0 赞/ 242 阅读

相关 spring boot使用mq

1.引入mq依赖 <dependency> <groupId>org.springframework.cloud</groupId>

超、凢脫俗/ 2021年11月29日 08:08/ 0 赞/ 276 阅读

相关自定义消息队列组件 mq-spring-boot-starter

目录为什么要自定义准备工作架构构思消息对象抽取消息订阅和发布者抽取如何使用

╰+哭是因爲堅強的太久メ/ 2021年09月24日 12:12/ 0 赞/ 285 阅读

相关【Spring Boot 5】Spring Boot Jpa 的使用

一、Spring Boot Jpa简介 Jpa（Java Persistence API）是sun官方提出的java持久化规范。它为java开发人员提供了一种对象/关联映

爱被打了一巴掌/ 2021年08月24日 12:19/ 0 赞/ 317 阅读