好资源导航 » 文章资讯 » Spring web集成rabbitmq代码实例

Spring web集成rabbitmq代码实例

2023-08-02 17:19:04 83

这篇文章主要介绍了Springweb集成rabbitmq代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

引入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;

publicclassRabbitMqMessageConsumerimplementsMessageListener{

@Override
publicvoidonMessage(Messagemessage){
System.out.println("消费信息,"+DateUtil.getNow("yyyy-MM-ddHH:mm:ss")+"---->"+message);
}

}

RabbitMqMessageProducer：

packageclub.codeapes.web.core.rabbitmq;

importorg.springframework.amqp.core.AmqpTemplate;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.stereotype.Repository;


@Repository
publicclassRabbitMqMessageProducer{

@Autowired
privateAmqpTemplateamqpTemplate;

publicvoidsendMessage(Objectmessage){
System.out.println("tosendmessage:"+message);
amqpTemplate.convertAndSend("queueTestKey",message);
}

}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

返回顶部
514930285
czq8825@qq.com

Spring web集成rabbitmq代码实例

热门推荐

随机推荐