弹簧引导集成RabbitMQ的示例代码

  


  

  

RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统
  

  

MQ全称为消息队列,消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过队列来通信。队列的使用除去了接收和发送应用程序同时执行的要求。

  

AMQP就是一个协议,是一个高级抽象层消息通信协议。

  

虽然在同步消息通讯的世界里有很多公开标准(如COBAR的IIOP,或者是SOAP等),但是在异步消息处理中却不是这样,只有大企业有一些商业实现(如微软的MSMQ, IBM的Websphere MQ等),因此,在2006年的6月,思科,Redhat, iMatix等联合制定了AMQP的公开标准。也就是说AMQP是异步通讯的一个协议。

  


  

  

在项目中,将一些无需即时返回且耗时的操作提取出来,进行了异步处理,而这种异步处理的方式大大的节省了服务器的请求响应时间,从而提高了系统的吞吐量。不过大多数不仅仅是无需即时返回,甚至是执行是否成功都无所谓。如果需要即时返回则可以使用达博,弹簧引导与达博集成可以去看春天引导集成Dubbox

  


  

  

RabbitMQ并不是直接一个简单的jar包(jar包只是提供一个基本的与RabbitMQ本身通讯的一些功能),和达博相同,RabbitMQ也需要其他软件来运行,以下是RabbitMQ运行所需要的软件

  

<强> 1,Erlang
  

  

由于RabbitMQ软件本身是基于Erlang开发的,所以想要运行RabbitMQ必须要先按照Erlang

  

Erlang官网   

Erlang下载地址

  RabbitMQ

<强>
  

  

RabbitMQ才是实现消息队列的核心
  

  

RabbitMQ官网   

RabbitMQ下载   

<>强配置RabbitMQ
  

  

安装完成后,需要完成一些配置才能使用RabbitMQ,可以直接用cmd到RabbitMQ的安装目录下的sbin目录通过命令配置,也可以直接在开始菜单中直接找RabbitMQ到命令提示符(sbin dir)运行直接到达RabbitMQ的安装目录的sbin,为了方便,我们先启用管理插件,执行命令

        rabbitmq-plugins。蝙蝠使rabbitmq_management      

即可,<强>注意,这是在Windows下面,如果是Linux则没有蝙蝠后缀强然后我们添加一个用户,因为在外网环境没有用户的情况下是不能连接成功的,执行添加用户命令

        rabbitmqctl。蝙蝠add_user springboot密码      

springboot是用户名、密码是密码
  

  

然后为了方便演示,我们给springboot赋予管理员权限,方便登录管理页面

        rabbitmqctl。蝙蝠set_user_tags springboot管理员      

给账号赋予虚拟主机权限

        rabbitmqctl。蝙蝠set_permissions - p/springboot。*。*。*      

然后启动RabbitMQ服务访问RabbitMQ管理页面http://localhost: 15672年即可看见登录页面,如果没有创建用户则可以用客人,客人登录,如果有创建用户则用创建的用户登录

  

<>强创建Springboot项目
  

  

因为创建春引导项目在前面的文章已经说过很多次了,所以这里就不多说了

  

<强>添加RabbitMQ相关依赖
  

        & lt; !——rabbitmq祝辞   & lt; dependency>   & lt; groupId> org.springframework.boot   & lt; artifactId> spring-boot-starter-amqp   & lt;/dependency>      

没错,就是点配置,不过这样可能有点不理解,我还是把全部配置贴出来吧

        & lt;项目xmlns=" http://maven.apache.org/POM/4.0.0 " xmlns: xsi=" http://www.w3.org/2001/XMLSchema-instance "   xsi: schemaLocation=" http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd”比;   & lt; modelVersion> 4.0.0      & lt; groupId> wang.raye.rabbitmq   & lt; artifactId> demo1   & lt; version> 0.0.1-SNAPSHOT   & lt; packaging> jar      & lt; name> demo1   & lt; url> http://maven.apache.org</url>      & lt; properties>   & lt; project.build.sourceEncoding> UTF-8

弹簧引导集成RabbitMQ的示例代码