一 .概述
在前面,我們完成了一個交換機,隊列,綁定,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的使用是比較簡單的.