28、springboot整合RabbitMQ（2）

今天药忘吃喽~ 2021-12-20 07:39 250阅读 0赞

## 1、监听 ##

**1.1、监听队列**

如订单系统和库存系统

订单系统下订单之后将消息存放在消息队列中

库存系统需要时刻进行监听消息队列的内容，有新的订单就需要进行库存相关的操作

此时模拟监听消息队列中的Book信息

监听类：

@RabbitListener监听相关的消息队列

@Service
    public class BookService {
        @RabbitListener(queues = "atguigu.news")
        public void receive(Book book){
            System.out.println("收到消息：" + book);
        }
    }

开启关于RabbitMq注解

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

后台的监听结果

![1488757-20190227110043140-293236336.png][]

**1.2、获取消息头、消息体相关的参数**

![1488757-20190227110118331-2135121214.png][]

import org.springframework.stereotype.Service;
    
    @Service
    public class BookService {
        @RabbitListener(queues = "atguigu.news")
        public void receive(Book book){
            System.out.println("收到消息：" + book);
        }
    
        //import org.springframework.amqp.core.Message;
        @RabbitListener(queues = "atguigu")
        public void receive02(Message message){
            System.out.println(message.getBody());
            System.out.println(message.getMessageProperties());
        }
    
    
    }

打印的数据

[B@2d4a67c8
    MessageProperties [headers={__TypeId__=com.cr.amqp.pojo.Book}, contentType=application/json, contentEncoding=UTF-8, contentLength=0, receivedDeliveryMode=PERSISTENT, priority=0, redelivered=true, receivedExchange=exchange.fanout, receivedRoutingKey=, deliveryTag=1, consumerTag=amq.ctag-193ojwCpIAgVmLfB52Prkg, consumerQueue=atguigu]
    收到消息：com.cr.amqp.pojo.Book@74095f6e

# #

## 2、创建 ##

假设有些信道活着队列不存在的情况

可以使用 **AmqpAdmin**进行创建交换器，转换规则、队列（Queue、Exchange、Binding）

![1488757-20190227110222568-104440551.png][]

@Autowired
    AmqpAdmin amqpAdmin;

//创建交换器
    @Autowired
    AmqpAdmin amqpAdmin;
    
    public void createExchange(){
    
        //package org.springframework.amqp.core;
        //public interface Exchange extends Declarable
        amqpAdmin.declareExchange(new DirectExchange("amqp.exchange"));
    }

结果：

![1488757-20190227110305886-11774460.png][]

交换器的类：

![1488757-20190227110317067-425044389.png][]

创建队列：

amqpAdmin.declareQueue(new Queue("amqpadmin.queue"));

![1488757-20190227110400586-920878466.png][]

绑定规则：

//绑定规则
    amqpAdmin.declareBinding(new Binding("amqpadmin.queue",Binding.DestinationType.QUEUE,"amqp.exchange","amqp.aa",null));

![1488757-20190227110425788-1085718554.png][]

转载于:https://www.cnblogs.com/Mrchengs/p/10442326.html

[1488757-20190227110043140-293236336.png]: /images/20211220/24dff245711d4d48816a289e2a2be2a1.png
[1488757-20190227110118331-2135121214.png]: /images/20211220/9c3fb2fd49f2461daaf67947e06ad4e1.png
[1488757-20190227110222568-104440551.png]: /images/20211220/4a38d90f38184dd3bf07335549e28e53.png
[1488757-20190227110305886-11774460.png]: /images/20211220/d319ad676d4f47c6a8c1821f050455e2.png
[1488757-20190227110317067-425044389.png]: /images/20211220/b0c12471b769423faf5d110c15cbd1bf.png
[1488757-20190227110400586-920878466.png]: /images/20211220/ddd4e1ded9594096b2b225137eff6ef0.png
[1488757-20190227110425788-1085718554.png]: /images/20211220/e7cb73eeb57e4a09908c0f414df2c7ce.png