pom 文件

1   
      
        2     
       
         3       
        
         com.rabbitmq
         4       
        
         amqp-client
         5       
        
         4.0.2
         6     
        7     
       
         8       
        
         org.slf4j
         9       
        
         slf4j-api
        10       
        
         1.7.10
        11     
       12     
       
        13       
        
         org.slf4j
        14       
        
         slf4j-log4j12
        15       
        
         1.7.5
        16     
       17     
       
        18       
        
         log4j
        19       
        
         log4j
        20       
        
         1.2.17
        21     
       22     
       
        23       
        
         junit
        24       
        
         junit
        25       
        
         4.11
        26     
       27     
       
        28       
        
         org.springframework.amqp
        29       
        
         spring-rabbit
        30       
        
         1.7.5.RELEASE
        31     
       32 33   
      

spring 集成rabbitmq 的核心配置

1 
     
       7      8     
       9     
      12         13     14     
      15     
      16     17     
      18     
      19 20     
      21     
      22     23     
      24     
      
       25         
       
        26             
        27         
       28     
      29     30     31     
      32     
      
       33         
       34     
      35 36     
      37     
      38 39 
     

业务方法的类 和方法

1 public class MyConsumer {2 3     4        //具体执行业务的方法5     public void listen(String foo) {6         System.out.println("消费者： " + foo);7     }8     9 }

执行rabbitmq

1 import org.springframework.amqp.rabbit.core.RabbitTemplate; 2 import org.springframework.beans.factory.annotation.Autowired; 3 import org.springframework.context.support.AbstractApplicationContext; 4 import org.springframework.context.support.ClassPathXmlApplicationContext; 5  6 public class SpringMain { 7      8     public static void main(final String... args) throws Exception { 9         AbstractApplicationContext ctx = new ClassPathXmlApplicationContext("classpath:context.xml");10         //RabbitMQ模板11         RabbitTemplate template = ctx.getBean(RabbitTemplate.class);12         //发送消息13         template.convertAndSend("Hello, world!");14         Thread.sleep(1000);// 休眠1秒15         ctx.destroy(); //容器销毁16     }17 18 }