依赖包

                 
      
       org.springframework.amqp
                  
      
       spring-rabbit
                  
      
       1.6.8.RELEASE
              
     

spring-xxx.xml 配置文件

profile.xml 中相关配置

mq.address=xxxxmq.exchange=xxxxxmq.routingKey=xxxmq.queue=xxxmq.port=5672mq.user=xxxxmq.pwd=xxxxmq.timeout=5000mq.vhost=lms

相关类文件

public class RmqProducer {    private static final Logger LOGGER = LoggerFactory.getLogger(RmqConsumer.class);    private RabbitTemplate rabbitTemplate;    /**     * 发送信息     */    public void sendMessage(RabbitMessage msg) {        try {            // 发送信息            rabbitTemplate.convertAndSend(msg);        } catch (Exception e) {            LOGGER.error("rmq消费者任务处理出现异常", e);        }    }    public void setRabbitTemplate(RabbitTemplate rabbitTemplate) {        this.rabbitTemplate = rabbitTemplate;    }}

public class RmqConsumer {    private static final Logger LOGGER = LoggerFactory.getLogger(RmqConsumer.class);    public void rmqConsumeMessage(Object obj) {        LOGGER.info("rmq 消费者任务:{}", JSON.toJSONString(obj));        // TODO 具体的消费策略    }}

使用

• • 使用时只需要注入相应的bean即可使用
  • 如果有多个队列，注意以下Bean的定义

1. rmqProducer
2. rmqConsumer
3. messageListenerAdapter
4. LisetenerContainer

备注

• 如果已经在rabbit的图形化界面bind相关的exchange 和 quene，橙色斜体加粗子部分可以省略；