如何编写Springweb集成rabbitmq代码-创新互联

本篇文章为大家展示了如何编写Springweb集成rabbitmq代码，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。

创新互联-专业网站定制、快速模板网站建设、高性价比濠江网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式濠江网站制作公司更省心,省钱,快速模板网站建设找我们，业务覆盖濠江地区。费用合理售后完善，10年实体公司更值得信赖。

引入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代码-创新互联
标题URL：http://cdxtjz.cn/article/pscgp.html