一 .概述
在前面,我们完成了一个交换机,队列,绑定,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的使用是比较简单的.