springboot2 整合 rabbitmq3.8

一时失言乱红尘 2023-07-25 12:42 1阅读 0赞

**一、简配版**

**导入Spring for RabbitMQ**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhdmVxaW5n_size_16_color_FFFFFF_t_70][]

**项目结构**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhdmVxaW5n_size_16_color_FFFFFF_t_70 1][]

**application.yml**

spring:
        rabbitmq:
            addresses: amqp://admin:admin@192.168.0.201:5672

address，以逗号分隔的客户端应连接到的地址列表。admin:admin是用户名密码。

整合rabbitmq还有哪些属性，请参阅 [RabbitProperties][]

**RabbiMQConfig.java**

package com.xin.xpfs.springbootrabbitmqsingle.config;
    
    import org.springframework.amqp.core.Queue;
    import org.springframework.amqp.rabbit.annotation.EnableRabbit;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    
    @Configuration
    //@EnableRabbit
    public class RabbiMQConfig {
    
        @Bean
        public Queue myQueue() {
            return new Queue("myQueue");
        }
    }

在Config类里创建了Queue，没有创建交换器，使用默认交换器

Exchange: (AMQP default) 默认交换隐式绑定到每个队列，路由密钥等于队列名称。无法显式绑定到默认exchange或从默认exchange解除绑定。也不能删除。

在消费者@RabbitListener注解里，也可以创建交换器、队列、绑定。

**RabbiMQConfig.java** 创建了交换器和绑定的

package com.xin.xpfs.springbootrabbitmqsingle.config;
    
    import org.springframework.amqp.core.Binding;
    import org.springframework.amqp.core.BindingBuilder;
    import org.springframework.amqp.core.DirectExchange;
    import org.springframework.amqp.core.Queue;
    import org.springframework.amqp.rabbit.annotation.EnableRabbit;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    
    @Configuration
    //@EnableRabbit
    public class RabbiMQConfig {
    
        @Bean
        public Queue myQueue() {
            return new Queue("myQueue", true);
        }
    
        @Bean
        public DirectExchange directExchange() {
            return new DirectExchange("myDirectExchange", true, false);
        }
    
        @Bean
        public Binding binding(Queue myQueue, DirectExchange directExchange) {
            return BindingBuilder.bind(myQueue).to(directExchange).with("myQueue");
        }
    
    }

**ProducerController.java**

package com.xin.xpfs.springbootrabbitmqsingle.controller;
    
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.util.UUID;
    
    @RestController
    public class ProducerController {
    
        @Autowired
        private RabbitTemplate rabbitTemplate;
    
        @RequestMapping("/send")
        public String send() {
            String content = UUID.randomUUID().toString();
            rabbitTemplate.convertAndSend("myQueue",content);
            return content;
        }
    }

**MyConsumer.java**

package com.xin.xpfs.springbootrabbitmqsingle.consumer;
    
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    @Component
    @Slf4j
    public class MyConsumer {
    
        @RabbitListener(queues = "myQueue")
        public void onMessage(String content) {
            log.info("收到消息：{}", content);
        }
    
    }

浏览器访问：[http://localhost:8080/send][http_localhost_8080_send]

控制台输出：收到消息：dd799baa-d805-42dd-a7a3-fa854240a0be

**RabbitMQ配置属性表**

Spring Cloud中RabbitMQ配置属性表

[https://blog.csdn.net/en\_joker/article/details/80103519][https_blog.csdn.net_en_joker_article_details_80103519]

Spring Boot + RabbitMQ 配置参数解释

[https://www.cnblogs.com/qts-hope/p/11242559.html][https_www.cnblogs.com_qts-hope_p_11242559.html]

**参考：**

spring boot 2.x 系列 —— spring boot 整合 RabbitMQ

[https://blog.csdn.net/m0\_37809146/article/details/86680920][https_blog.csdn.net_m0_37809146_article_details_86680920]

**文档：**

AMQP中文文档

[https://docshome.gitbooks.io/springboot/content/pages/spring-boot-features.html\#boot-features-amqp][https_docshome.gitbooks.io_springboot_content_pages_spring-boot-features.html_boot-features-amqp]

AMQP英文文档

[https://docs.spring.io/spring-boot/docs/2.2.6.RELEASE/reference/htmlsingle/\#boot-features-amqp][https_docs.spring.io_spring-boot_docs_2.2.6.RELEASE_reference_htmlsingle_boot-features-amqp]

spring-amqp 英文

[https://docs.spring.io/spring-amqp/docs/2.2.5.RELEASE/reference/html/\#amqp][https_docs.spring.io_spring-amqp_docs_2.2.5.RELEASE_reference_html_amqp]

Spring AMQP 中文文档

[https://www.docs4dev.com/docs/zh/spring-amqp/2.1.2.RELEASE/reference][https_www.docs4dev.com_docs_zh_spring-amqp_2.1.2.RELEASE_reference]

**其他：**

[RabbitMQ 核心概念][RabbitMQ]  
[RabbitMQ 客户端开发][RabbitMQ 1]  
[基于 HAProxy + KeepAlived 搭建 RabbitMQ 高可用集群][HAProxy _ KeepAlived _ RabbitMQ]  
[spring cloud 系列第8篇 —— config+bus 分布式配置中心与配置热刷新 (F版本)][spring cloud _8_ _ config_bus _ _F]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhdmVxaW5n_size_16_color_FFFFFF_t_70]: /images/20230528/cb5fbdec5b1740c08da01d711ea20637.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hhdmVxaW5n_size_16_color_FFFFFF_t_70 1]: /images/20230528/80b60702488d4e7489f9e2928b51e082.png
[RabbitProperties]: https://github.com/spring-projects/spring-boot/tree/v2.1.1.RELEASE/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/amqp/RabbitProperties.java
[http_localhost_8080_send]: http://localhost:8080/send
[https_blog.csdn.net_en_joker_article_details_80103519]: https://blog.csdn.net/en_joker/article/details/80103519
[https_www.cnblogs.com_qts-hope_p_11242559.html]: https://www.cnblogs.com/qts-hope/p/11242559.html
[https_blog.csdn.net_m0_37809146_article_details_86680920]: https://blog.csdn.net/m0_37809146/article/details/86680920
[https_docshome.gitbooks.io_springboot_content_pages_spring-boot-features.html_boot-features-amqp]: https://docshome.gitbooks.io/springboot/content/pages/spring-boot-features.html#boot-features-amqp
[https_docs.spring.io_spring-boot_docs_2.2.6.RELEASE_reference_htmlsingle_boot-features-amqp]: https://docs.spring.io/spring-boot/docs/2.2.6.RELEASE/reference/htmlsingle/#boot-features-amqp
[https_docs.spring.io_spring-amqp_docs_2.2.5.RELEASE_reference_html_amqp]: https://docs.spring.io/spring-amqp/docs/2.2.5.RELEASE/reference/html/#amqp
[https_www.docs4dev.com_docs_zh_spring-amqp_2.1.2.RELEASE_reference]: https://www.docs4dev.com/docs/zh/spring-amqp/2.1.2.RELEASE/reference
[RabbitMQ]: https://blog.csdn.net/m0_37809146/article/details/104000543
[RabbitMQ 1]: https://blog.csdn.net/m0_37809146/article/details/104000658
[HAProxy _ KeepAlived _ RabbitMQ]: https://blog.csdn.net/m0_37809146/article/details/104000699
[spring cloud _8_ _ config_bus _ _F]: https://blog.csdn.net/m0_37809146/article/details/86677462