Spring集成RabbitMQ-使用RabbitMQ更方便

如果提到Spring，你脑海中对他的印象还停留在SSH三大框架之一，那或许你该好好重新认识这个家伙。

在IT技术日新月异的今天，他还能让你忘不了并与他朝夕相处，他，肯定有自己的绝活。如今他早已经不是孤军奋战，而是形成了一个大家族，或许你知道Spring Boot，Spring Cloud，Spring Datad等等。

Spring给我的感觉就是好用，易上手，尤其有了更加强大的注解使用之后，可以抛去繁琐的XML配置，我们有更多的精力集中在自己的业务上、代码上。而Spring AMQP就是这样的一个集成了RabbitMQ的好用的工具库，能够很好的实现收发消息。



从这篇开始我们将陆续介绍Spring如何集成RabbitMQ，又是如何在Spring下使用RabbitMQ的。

和原生的RabbitMQ区别在哪

在《RabbitMQ入门》系列中，我们只用到了amqp-client这个jar包，包括新建Connection、Channel以及Consumer等。

但是我们在Spring下集成，还需要引入新的jar包依赖。



这里用的是最新的spring-rabbit版本2.0.0.M5

最新的spring-rabbit要求Spring Framework的最低版本为5.0.x，amqp-client的最低版本为4.1.x（对于一些新特性要求这样的最低版本，对于大部分功能来说，较低的版本也能正常工作）

添加好这些依赖后，编译项目出现下面的错误



从错误信息可以看出是中央仓库中没有Bismuth-M3这个依赖，所以需要添加一个Repository能够提供这个依赖的。添加如下信息到pom.xml中，问题解决。

一个简单到爆的HelloWorld实例

有了上面的依赖，我们先抛开XML配置以及注解配置，直接就可以写一个Spring集成RabbitMQ的HelloWorld。



没错，就是这么几行代码，就可以实现发送消息和接收消息了。

新建了一个连接工厂，在其构造函数中指定了hostname。当然了CachingConnectFactory还提供了其他重载形式的构造函数，可以赋值hostname以及port等。

AmqpAdmin对象负责新建Exchange、Queue以及绑定等工作。

AmqpTemplate负责收发消息。

相比我们在《RabbitMQ入门》系列中，需要新建Connection，还要创建Channel以及Consumer，完成绑定等操作，这种方式更加简洁。

启动代码后，我们可以看到一个名为myqueue的队列已经存在了。



​

XML配置版本和注解配置版本

XML配置

如果非要使用你熟悉的XML模式，也不是不行。新建rabbit-context.xml文件



这时候在实现类中这样写就ok了



基于注解的配置

使用注解我们不用看让人眼花缭乱的xml配置了。我们需要声明一个配置类，如下



请点击此处输入图片描述

这时候在java实现类中这样写



以上两种方式都是等效的，具体看个人偏好了。

如果您觉得阅读本文对您有帮助，请点一下“推荐”按钮，您的“推荐”将是我最大的写作动力！如果您想持续关注我的文章，请扫描二维码，关注JackieZheng的微信公众号，我会将我的文章推送给您，并和您一起分享我日常阅读过的优质文章。