摘要：与协议详解可以看看这个下面是和集成的配置我配置了二种和公共配置配置，指定连接参数通过指定下面的信息，当前中的和会在服务器上自动生成定义说明是否持久化仅创建者可以使用的私有队列，断开后自动删除当所
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+"------->>>>>");
}
}
文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。
转载请注明本文地址：https://www.ucloud.cn/yun/75859.html
