RabbitTemplate和AmqpAdmin对象

￡神魔★判官ぃ 2021-06-24 16:12 450阅读 0赞

在SpringBoot整合RabbitMQ时，我们可以通过RabbitTemplate和AmqpAdmin对象对消息队列进行一系列的操作。当然，前提是在启动类里面添加了@EnableRabbit注解开启了基于注解的RabbitMQ模式。

# RabbitTemplate #

发送消息队列。

//Mwssage需要自己构造一个-定义消息体的内容和消息头
    //rabbitTemplate.send(exchange,routeKey,message);
    
    //object默认当成消息体，只需要传入要发送的对象，自动序列化发送给rabbitmq 
    //rabbitTemplate.convertAndSend(exchange,routeKey,object);
    
    Map<String,Object> map=new HashMap<>();
    map.put("msg","这是第一个消息");
    map.put("data", Arrays.asList("helloworld",123,true));     
    rabbitTemplate.convertAndSend("exchange.direct","atwunian.news",map);

也可以直接发送一个对象为消息体。

//对象被默认序列化以后发送出去
    rabbitTemplate.convertAndSend("exchange.direct","atwunian.news",new Book("西游记","吴承恩"));

如果需要将发送的数据对象自动序列化为JSON数据，则需要自定义序列化器。

@Configuration
    public class MyAMQPConfig {
    
        //自定义JSON消息序列化器
        @Bean
        public MessageConverter messageConverter(){
            return new Jackson2JsonMessageConverter();
        }
    }

接收发送的消息队列数据。

Object o=rabbitTemplate.receiveAndConvert("atwunian.news");
    System.out.println(o.getClass());
    System.out.println(o);

也可以在方法上添加@RabbitListener注解监听消息队列来接收数据。

@RabbitListener(queues="atwunian")
    public void receive02(Message message){
      System.out.println(message.getBody());
      System.out.println(message.getMessageProperties());
    }
    
    @RabbitListener(queues="atwunian.news")
    public void receive(Book book){
      System.out.println("收到消息"+book);
    }

# AmqpAdmin #

创建一个交换器。

amqpAdmin.declareExchange(new DirectExchange("amqpadmin.exchange"));

创建一个消息队列。

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

创建交换器和消息队列的绑定关系。

amqpAdmin.declareBinding(new Binding("amqpadmin.queue",Binding.DestinationType.QUEUE,"amqpadmin.exchange","amqp.abc",null));