如何编写Springweb集成rabbitmq代码
本篇文章为大家展示了如何编写Springweb集成rabbitmq代码,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。
成都创新互联公司从2013年开始,先为康乐等服务建站,康乐等地企业,进行企业商务咨询服务。为康乐企业网站制作PC+手机+微官网三网同步一站式服务解决您的所有建站问题。
引入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
package club.codeapes.web.core.rabbitmq;import club.codeapes.common.date.DateUtil;import com.alibaba.fastjson.JSON;import org.springframework.amqp.core.Message;import org.springframework.amqp.core.MessageListener;public class RabbitMqMessageConsumer implements MessageListener { @Override public void onMessage(Message message) { System.out.println("消费信息," + DateUtil.getNow("yyyy-MM-dd HH:mm:ss") + "---->" + message); }}
RabbitMqMessageProducer:
package club.codeapes.web.core.rabbitmq;import org.springframework.amqp.core.AmqpTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Repository;@Repositorypublic class RabbitMqMessageProducer{ @Autowired private AmqpTemplate amqpTemplate; public void sendMessage(Object message) { System.out.println("to send message:" + message); amqpTemplate.convertAndSend("queueTestKey", message); }}
上述内容就是如何编写Springweb集成rabbitmq代码,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注创新互联行业资讯频道。
本文题目:如何编写Springweb集成rabbitmq代码
文章网址:http://ybzwz.com/article/jcccsj.html