024 RabbitTemplate组件

Posted 2021-01-12 trekxu

一 .概述

　　在前面,我们完成了一个交换机,队列,绑定,RabbitAdmin组件的声明,我们发现这些比我们直接使用客户端完成要简单的多,本次我们使用RabbitTemplate来完成操作.

---

 

二 .RabbitTemplate

　　我们使用这个对象完成我们对Rabbitmq的消息的发送和接收.

@Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connctionFactory) {

        RabbitTemplate template = new RabbitTemplate();

        template.setConnectionFactory(connctionFactory);
        
        return template;
    }

在上面,我们创建了一个最简单的RabbitTemplate模板,在后面我们会丰富这个对象的内容.

　　下面,我们就使用这个对象完成一个消息的发送.

    @Test
    public void send() {
        template.send("admin_exchange", "admin", new Message("trek".getBytes(),new MessageProperties()));
    }

我们简单的就发送了一条消息,说明我们的RabbitTemplate的使用是比较简单的.

---