springboot整合rabbitmq的应用（全）

灰太狼 2022-11-15 03:47 67阅读 0赞

# 可视化操作rabbitmq #

## 1、docker容器拉取 ##

docker pull rabbitmq:3.8.14-management

## 2、生成rabbitmq的docker容器 ##

docker run -d -p 5672:5672 -p 15672:15672 --name myrabbitmq 6d11713e4e3d
    -d:后台运行
    -p: 暴露端口，前边映射主机端口，后边映射虚拟机端口，这是主机与虚拟器通信的接口
      第二个是rabbitmq管理界面的web端口映射

## 3、物理机访问rabbitmq的web管理器：账户和密码都是guest ##

![2021033021213931.png][]

## 4、创建交换器，创建队列，绑定交换器和对类 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA_size_16_color_FFFFFF_t_70][]

默认是持久化的，就是下次重启交换器还在。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA_size_16_color_FFFFFF_t_70 1][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA_size_16_color_FFFFFF_t_70 2][]

## 4、进入交换器发送消息，进入队列获取消息 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA_size_16_color_FFFFFF_t_70 3][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA_size_16_color_FFFFFF_t_70 4][]

# springboot整合rabbitmq #

## 1、pom.xml ##

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.4.4</version>
            <relativePath/> 
        </parent>
        <groupId>com.pshdhx</groupId>
        <artifactId>springboot-amqp-rabbitmq</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>springboot-amqp-rabbitmq</name>
        <description>Demo project for Spring Boot</description>
        <properties>
            <java.version>1.8</java.version>
        </properties>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-amqp</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.amqp</groupId>
                <artifactId>spring-rabbit-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

## 2、配置rabbitmq ##

spring.rabbitmq.host=192.168.44.128
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest

## 3、测试类测试rabbitmq：发送消息和接受消息 ##

package com.pshdhx.rabbitmq;
    
    import com.pshdhx.rabbitmq.bean.Book;
    import org.junit.jupiter.api.Test;
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    
    import java.util.Arrays;
    import java.util.HashMap;
    import java.util.Map;
    
    @SpringBootTest
    class SpringbootAmqpRabbitmqApplicationTests {
    
        @Autowired
        RabbitTemplate rabbitTemplate;
    
        @Test
        void contextLoads() {
    //        message需要自己定义一个，定义消息体和消息头，不好使，序列化成bytep[]
    //        rabbitTemplate.send(exchange,routekey,message);
            Map<String,Object> map = new HashMap<>();
            map.put("msg","这是第一个消息");
            map.put("data", Arrays.asList("helloword",123,true));
            rabbitTemplate.convertAndSend("exchange.direct","pshdhx.news",map);
        }
        @Test
        public void receive(){
            Object o = rabbitTemplate.receiveAndConvert("pshdhx.news");
            System.out.println(o.getClass());
            System.out.println(o);
        }
    
        @Test
        public void sendAll(){
            rabbitTemplate.convertAndSend("exchange.fanout","pshdhx.news",new Book("pshdhx","psd"));
        }
    
    }

## 4、配置类配置rabbitmq：消息队列序列化 ##

package com.pshdhx.rabbitmq.config;
    
    import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
    import org.springframework.amqp.support.converter.MessageConverter;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    /**
     * @Authtor pshdhx
     * @Date 2021/3/3020:54
     * @Version 1.0
     */
    @Configuration
    public class MyRabbitMqConfig {
    
        @Bean
        public MessageConverter messageConverter(){
            return  new Jackson2JsonMessageConverter();
        }
    }

## 5、两个服务之间监听rabbitmq（订单系统发送消息，存储系统随时监听并接受消息） ##

package com.pshdhx.rabbitmq.bean;
    
    /**
     * @Authtor pshdhx
     * @Date 2021/3/3021:03
     * @Version 1.0
     */
    public class Book {
        private String bookName;
        private String author;
    
        public Book() {
        }
    
        public Book(String bookName, String author) {
            this.bookName = bookName;
            this.author = author;
        }
    
        public String getBookName() {
            return bookName;
        }
    
        public void setBookName(String bookName) {
            this.bookName = bookName;
        }
    
        public String getAuthor() {
            return author;
        }
    
        public void setAuthor(String author) {
            this.author = author;
        }
    }
    
    
    
    
    package com.pshdhx.rabbitmq.service;
    
    import com.pshdhx.rabbitmq.bean.Book;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Service;
    
    /**
     * @Authtor pshdhx
     * @Date 2021/3/3021:06
     * @Version 1.0
     */
    @Service
    public class BookService {
        @RabbitListener(queues = "pshdhx.news")
        public void listener(Book book){
            System.out.println("收到消息"+book);
        }
    }
    
    
    
    
    
    package com.pshdhx.rabbitmq;
    
    import org.springframework.amqp.rabbit.annotation.EnableRabbit;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    /**
     *
     */
    @EnableRabbit
    @SpringBootApplication
    public class SpringbootAmqpRabbitmqApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(SpringbootAmqpRabbitmqApplication.class, args);
        }
    
    }

全文完：感谢阅读！

[2021033021213931.png]: /images/20221022/5883260b6ea8456d8fa717674e6c0784.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20210330212235336.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20210330212251859.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20210330212304660.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20210330212415535.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20210330212429918.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3BzaGRoeA==,size_16,color_FFFFFF,t_70