RabbitMQ与spring集成以及配置完整的生产者和消费者

这篇文章给大家介绍RabbitMQ与spring集成以及配置完整的生产者和消费者，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。

RabbitMQ与AMQP协议详解可以看看这个 http://www.cnblogs.com/frankyou/p/5283539.html

下面是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+"------->>>>>");                }    }

关于RabbitMQ与spring集成以及配置完整的生产者和消费者就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。