引入java包：

本項目中僅引入了四個java包：amqp-client-5.7.3.jar，spring-rabbit-2.2.2.RELEASE.jar，spring-retry-1.2.4.RELEASE.jar，spring-amqp-2.2.2.RELEASE.jar

spring-rabbitmq.xml

spring中需要引入這個xml,? 主要在總spring.xml。或者web.xml中需要引入下。

RabbitMqMessageConsumer

packageclub.codeapes.web.core.rabbitmq;importclub.codeapes.common.date.DateUtil;importcom.alibaba.fastjson.JSON;importorg.springframework.amqp.core.Message;importorg.springframework.amqp.core.MessageListener;public class RabbitMqMessageConsumer implementsMessageListener {

@Overridepublic voidonMessage(Message message) {

System.out.println("消費信息," + DateUtil.getNow("yyyy-MM-dd HH:mm:ss") + "---->" +message);

}

}

RabbitMqMessageProducer：

packageclub.codeapes.web.core.rabbitmq;importorg.springframework.amqp.core.AmqpTemplate;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.stereotype.Repository;

@Repositorypublic classRabbitMqMessageProducer{

@AutowiredprivateAmqpTemplate amqpTemplate;public voidsendMessage(Object message) {

System.out.println("to send message:" +message);

amqpTemplate.convertAndSend("queueTestKey", message);

}

}

總結

以上是生活随笔為你收集整理的java web中整合mq_spring-web 集成 rabbitmq的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。