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

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

成都创新互联是一家专业提供嘉黎企业网站建设,专注与网站建设、成都网站建设、H5响应式网站、小程序制作等业务。10年已为嘉黎众多企业、政府机构等服务。创新互联专业网络公司优惠进行中。

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