摘要：與協議詳解可以看看這個下面是和集成的配置我配置了二種和公共配置配置，指定連接參數通過指定下面的信息，當前中的和會在服務器上自動生成定義說明是否持久化僅創建者可以使用的私有隊列，斷開后自動刪除當所
RabbitMQ與AMQP協議詳解可以看看這個 http://www.cnblogs.com/franky...
下面是rabbitMQ和spring集成的配置,我配置了二種ExCahange: topicExchange和directExChange
Spring公共配置
生成者demo例子 :
@Controller
@RequestMapping("/amqpTest")
public class AmqpTestController {
@Autowired
private AmqpTemplate amqpTemplate;
@RequestMapping("/sendMsg")
@ResponseBody
public String sendAmqbMsg(Model model,@RequestParam(value="msg",defaultValue="hello world!!!")String msg){
if(model!=null&&!"".equals(msg)){
amqpTemplate.convertAndSend("mq.asdfExChange", "mq.asdf.send", msg);
}else{
amqpTemplate.convertAndSend("mq.asdfExChange", "mq.asdf.send", "hello world");
}
return "success";
}
@RequestMapping("/sendMsg2")
@ResponseBody
public String sendAmqbMsg2(Model model,@RequestParam(value="msg",defaultValue="hello world!!!")String msg){
if(model!=null&&!"".equals(msg)){
amqpTemplate.convertAndSend("mq.asdfExChange", "mq.asdf2.send", "這個世界很奇妙!!!");
}else{
amqpTemplate.convertAndSend("mq.asdfExChange", "mq.asdf2.send", "這個世界很奇妙");
}
return "success";
}
@RequestMapping("/sendMsg3")
@ResponseBody
public String sendAmqbMsg3(Model model,@RequestParam(value="msg",defaultValue="hello world!!!")String msg){
if(model!=null&&!"".equals(msg)){
amqpTemplate.convertAndSend("mq.qwerExChange", "mq.qwer.send", "神奇的世界!!!");
}else{
amqpTemplate.convertAndSend("mq.qwerExChange", "mq.qwer.send", "神奇的世界");
}
return "success";
}
}
消費者:
這里我按照配置列出來一個Demo
消費者
路徑匹配上就沒有什么問題.public class AsdfConsumer implements MessageListener{
static{
System.out.println("已經依賴成功 ");
}
public void onMessage(Message message) {
MessageProperties m=message.getMessageProperties();
// System.out.println(m);
String msg= new String (message.getBody());
System.out.println("消費掉了:"+msg+"------->>>>>");
}
}
文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。
轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/75859.html
