摘要：與協(xié)議詳解可以看看這個(gè)下面是和集成的配置我配置了二種和公共配置配置，指定連接參數(shù)通過指定下面的信息，當(dāng)前中的和會(huì)在服務(wù)器上自動(dòng)生成定義說明是否持久化僅創(chuàng)建者可以使用的私有隊(duì)列，斷開后自動(dòng)刪除當(dāng)所
RabbitMQ與AMQP協(xié)議詳解可以看看這個(gè) 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", "這個(gè)世界很奇妙!!!");
}else{
amqpTemplate.convertAndSend("mq.asdfExChange", "mq.asdf2.send", "這個(gè)世界很奇妙");
}
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";
}
}
消費(fèi)者:
這里我按照配置列出來一個(gè)Demo
消費(fèi)者
路徑匹配上就沒有什么問題.public class AsdfConsumer implements MessageListener{
static{
System.out.println("已經(jīng)依賴成功 ");
}
public void onMessage(Message message) {
MessageProperties m=message.getMessageProperties();
// System.out.println(m);
String msg= new String (message.getBody());
System.out.println("消費(fèi)掉了:"+msg+"------->>>>>");
}
}
文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/75859.html
