SpringBoot专题学习Part27：SpringBoot整合RabbitMQ(发送接收消息、序列化、监听消息、AmqpAdmin的使用)

短命女 2023-07-20 12:02 1阅读 0赞

# 一、介绍 #

**RabbitMQ**是一套开源的**消息队列服务**软件 是由LShift提供的一个AMQP的开源实现  
由以高性能 健壮以及可伸缩性出名的Erlang写成  
具有很高的稳定性和可靠性

# 二、使用 #

## 1、准备和配置 ##

首先是引入RabbitMQ的依赖  
若使用Spring Initializer创建项目 可在创建的时候带上RabbitMQ模块  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70]  
或者直接手动引入依赖：

<dependency>
    	<groupId>org.springframework.boot</groupId>
    	<artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>

然后 在配置文件中配置RabbitMQ的连接信息：

# ip地址 默认为localhost
    spring.rabbitmq.host=111.111.111.111
    # 用户名 默认为guest
    spring.rabbitmq.username=guest
    # 密码 默认为guest
    spring.rabbitmq.password=guest
    # 端口号 默认为5672
    spring.rabbitmq.port=5672
    # 虚拟主机地址 默认为/
    spring.rabbitmq.virtual-host=/

RabbitMQ的自动配置类是**RabbitAutoConfiguration**  
里面配置了连接工厂(ConnectionFactory)  
**RabbitProperties**类里封装了RabbitMQ的所有配置属性

在自动配置类中还配置了**RabbitTemplate**  
该Template用于**给RabbitMQ发送和接收消息** 类似于JDBC的JdbcTemplate

在自动配置类中还配置了**AmqpAdmin**  
是RabbitMQ的**系统管理功能组件** 用于给RabbitMQ声明队列 创建交换器等

--------------------

## 2、RabbitTemplate发送接收消息 ##

首先在类里注入RabbitTemplate  
因为SpringBoot就是靠着RabbitTemplate来发送接收消息的：

@Autowired
    RabbitTemplate rabbitTemplate;

#### ①、发送消息 ： ####

**单播模式 点对点发送**  
首先要选择用于发送的交换器和该交换器绑定的路由键  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 2]

// 传入要发送的对象 自动序列化并发送给RabbitMQ
    // rabbitTemplate.convertAndSend(exchange,routeKey,object)
    Map<String,Object> map=new HashMap<>();
    map.put("msg","HelloWorld");
    map.put("data", Arrays.asList(true,123,"abc"));
    // 对象被默认序列化之后发送
    rabbitTemplate.convertAndSend("exchange.direct","zjitc.emps",map);

#### ②、接收消息： ####

// 指定队列名来获取 接收的时候会自动转换
    Object o = rabbitTemplate.receiveAndConvert("zjitc.emps");
    // 收到的结果的类型
    System.out.println(o.getClass());// class java.util.HashMap
    System.out.println(o);// {msg=HelloWorld, data=[true, 123, abc]}

接收之后 队列中的该条消息就没有了 因为已经被"阅读"了

#### ③、序列化： ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 3]  
序列化时默认使用Java方式编码 因此显示的会是一堆符号

可将数据自动转换为JSON格式发送

RabbitTemplate里内置有一个**MessageConverter**(消息转换器) 默认使用的是SimpleMessageConverter  
该SimpleMessageConverter底层是使用SerializationUtils转换的 因此导致了显示乱码结果

MessageConverter有很多实现 可以更换一个 换成**Jackson2JsonMessageConverter**：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 4]  
注：MessageConverter是`org.springframework.amqp.support.converter.MessageConverter` 不要导错包了

@Configuration
    public class MyAMQPConfig {
        
    
        @Bean
        public MessageConverter messageConverter()
        {
        
            // 换成Jackson2JsonMessageConverter
            return new Jackson2JsonMessageConverter();
        }
    }

加上之后 自动配置会立即生效 RabbitAutoConfiguration会识别自定义的MessageConverter并且一并添加  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 5]  
此时显示的就是JSON格式的数据了

#### 还能发送接收自定义的类： ####

###### 发送： ######

rabbitTemplate.convertAndSend("exchange.direct","zjitc.emps",new Student(1,"Mike"));

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 6]

###### 同样 也可正常序列化接收： ######

// 指定队列名来获取 接收的时候会自动转换
    Object o = rabbitTemplate.receiveAndConvert("zjitc.emps");
    // 收到的结果的类型
    System.out.println(o.getClass());// class net.zjitc.amqp.bean.Student

#### 不仅只能点对点发送 也可广播发送消息： ####

广播的时候是发送给所有的queue 因此无需指定消息队列的key **留空**即可 但不能不填 否则会接收不到消息

rabbitTemplate.convertAndSend("exchange.fanout","",new Student(2,"Pico"));

![在这里插入图片描述][20200401140649790.png]  
这样 就都接收到消息了

--------------------

## 3、监听消息队列的内容 ##

使用`@RabbitListener`和`@EnableRabbit`注解实现

首先 须**开启基于注解的Rabbit模式**  
将`@EnableRabbit`注解加在启动类上：

@SpringBootApplication
    @EnableRabbit // 开启基于注解的RabbitMQ模式
    public class SpringbootAmqpApplication {
        
    
        public static void main(String[] args) {
        
            SpringApplication.run(SpringbootAmqpApplication.class, args);
        }
    }

然后用`@RabbitListener`注解加在方法上来监听消息队列 并**指定要监听的消息队列的key** key传入的是数组形式 因而可监听多个消息队列  
方法的入参的要接收的类的类型

@Service
    public class StudentService {
        
    
        // 只要指定的队列有消息进入 该方法即会被调用 接收之后 队列中的该条数据就没有了
        @RabbitListener(queues = "zjitc.emps")
        public void receive(Student student)
        {
        
            System.out.println("叮咚！您刚刚收到一个新学生 信息为："+student);
        }
    }

![在这里插入图片描述][20200401140954309.png]  
消息发送后 立刻收到了

##### 还可接收消息头和消息体： #####

用`org.springframework.amqp.core.Message`对象来接收

@RabbitListener(queues = "zjitc.news")
    public void receiveWithHeader(Message message)
    {
        
        System.out.println(message.getMessageProperties());
        System.out.println(message.getBody());
    }

![在这里插入图片描述][2020040114105172.png]

--------------------

## 4、AmqpAdmin的使用 ##

AmqpAdmin的功能是**可在程序中对交换器**(Exchange)**和消息队列**(Queen)**和绑定规则进行操作**(创建 删除 绑定 等等)

首先 要在类里注入AmqpAdmin：

@Autowired
    AmqpAdmin amqpAdmin;

#### 创建 ####

创建的时候 使用以**declare**开头的方法  
**declare**就是**声明**的意思(多学了一个单词

###### 创建交换器： ######

使用declareExchange()方法创建一个交换器：

// 创建交换器 可指定交换器的名字
    amqpAdmin.declareExchange(new DirectExchange("amqpadmin.exchange.direct"));

有多种交换器 可自行选择  
![在这里插入图片描述][20200401141449392.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 7]  
创建成功

--------------------

###### 创建队列： ######

// 当传入的是两个参数时 第一个参数代表队列的key 第二个参数代表是否可持久化
    amqpAdmin.declareQueue(new Queue("amqpadmin.queue",true));

有多种构造方法 可自行选择  
![在这里插入图片描述][20200401141551420.png]  
创建成功

--------------------

###### 创建绑定规则： ######

// Binding(目的地,目的地的类型(消息队列还是交换器),交换器名字,路由键,参数头信息(若没有则填null))
    amqpAdmin.declareBinding(new Binding("amqpadmin.queue", Binding.DestinationType.QUEUE,"amqpadmin.exchange.direct","amqp.abc",null));

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 8]  
创建成功

--------------------

创建的方法是declare 删除的方法是delete 其余都是一样的 这里就不多加赘述了(其实是懒

--------------------

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70]: /images/20230528/9bba5c6403344274a105f85404db198d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 1]: /images/20230528/10a40434679b4544ac7b042056ad76ad.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 2]: /images/20230528/0a310936f25740f5986318c6b6210c33.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 3]: /images/20230528/60908675d5034cd68bcb3a67fdc4bba6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 4]: /images/20230528/7cc14d36cfe54acfb6ffab1cc4c91ce5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 5]: /images/20230528/b1a5b352d58a417d918d7455bd720047.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 6]: /images/20230528/29f0bbe3d24f4635afa940665fb49ef2.png
[20200401140649790.png]: /images/20230528/bb92fd9202af4385ac93728b626802fb.png
[20200401140954309.png]: /images/20230528/c5d42a81fda54b59a2867efabef6444e.png
[2020040114105172.png]: /images/20230528/79fbe825fdc04304a72ca188ae31a4b9.png
[20200401141449392.png]: /images/20230528/eacb385f2d0f4dbe81ae51ada2fa5030.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 7]: /images/20230528/5b20206c78d640129b7bbc7d63c3089e.png
[20200401141551420.png]: /images/20230528/9b8eb715acec4e74931c5f51db5c6141.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 8]: /images/20230528/f8c86b8dd01f474c8f02aa90c4002688.png