消息队列 RabbitMQ 与 Spring 整合使用的实例代码

一、什么是 RabbitMQ

RabbitMQ 是实现 AMQP（高级消息队列协议）的消息中间件的一种，最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。

RabbitMQ 是由 Erlang 语言开发，安装 RabbitMQ 服务需要先安装 Erlang 语言包。

二、如何与 Spring 集成

1. 我们都需要哪些 Jar 包？

抛开单独使用 Spring 的包不说，引入 RabbitMQ 我们还需要两个：

<!-- RabbitMQ -->
<dependency>
 <groupId>com.rabbitmq</groupId>
 <artifactId>amqp-client</artifactId>
 <version>3.5.1</version>
</dependency>
<dependency>
 <groupId>org.springframework.amqp</groupId>
 <artifactId>spring-rabbit</artifactId>
 <version>1.4.5.RELEASE</version>
</dependency>

2. 使用外部参数文件 application.properties：

mq.host=127.0.0.1
mq.username=queue
mq.password=1234
mq.port=8001
# 统一XML配置中易变部分的命名
mq.queue=test_mq

易变指的是在实际项目中，如果测试与生产环境使用的同一个 RabbitMQ 服务器。那我们在部署时直接修改 properties 文件的参数即可，防止测试与生产环境混淆。

 修改 applicationContext.xml 文件，引入我们创建的 properties 文件

<context:property-placeholder location="classpath:application.properties"/>
<util:properties id="appConfig" location="classpath:application.properties"></util:properties>

3. 连接 RabbitMQ 服务器

<!-- 连接配置 -->
<rabbit:connection-factory id="connectionFactory" host="${mq.host}" username="${mq.username}"
  password="${mq.password}" port="${mq.port}" />
  
<rabbit:admin connection-factory="connectionFactory"/>

4. 声明一个 RabbitMQ Template

复制代码 代码如下:
<rabbit:template id="amqpTemplate" exchange="${mq.queue}_exchange" connection-factory="connectionFactory"  />

5. 在 applicationContext.xml 中声明一个交换机，name 属性需配置到 RabbitMQ 服务器。

<rabbit:topic-exchange name="${mq.queue}_exchange" durable="true" auto-delete="false">
 <rabbit:bindings>
  <rabbit:binding queue="test_queue" pattern="${mq.queue}_patt"/>
 </rabbit:bindings>
</rabbit:topic-exchange>

交换机的四种模式：

• direct：转发消息到 routigKey 指定的队列。
• topic：按规则转发消息（最灵活）。
• headers：（这个还没有接触到）
• fanout：转发消息到所有绑定队列

交换器的属性：

• 持久性：如果启用，交换器将会在server重启前都有效。
• 自动删除：如果启用，那么交换器将会在其绑定的队列都被删除掉之后自动删除掉自身。
• 惰性：如果没有声明交换器，那么在执行到使用的时候会导致异常，并不会主动声明。

如果没有队列绑定在交换机上，则发送到该交换机上的消息会丢失。

一个交换机可以绑定多个队列，一个队列可以被多个交换机绑定。

topic 类型交换器通过模式匹配分析消息的 routing-key 属性。它将 routing-key 和 binding-key 的字符串切分成单词。这些单词之间用点隔开。它同样也会识别两个通配符：#匹配0个或者多个单词，*匹配一个单词。例如，binding key：*.stock.#匹配 routing key：usd.stcok 和 eur.stock.db，但是不匹配 stock.nana。

因为交换器是命名实体，声明一个已经存在的交换器，但是试图赋予不同类型是会导致错误。客户端需要删除这个已经存在的交换器，然后重新声明并且赋予新的类型。

6. 在 applicationContext.xml 中声明一个队列，name 属性是需要配置到 RabbitMQ 服务器的。

复制代码 代码如下:
<rabbit:queue id="test_queue" name="${mq.queue}_testQueue" durable="true" auto-delete="false" exclusive="false" />

• durable：是否持久化
• exclusive：仅创建者可以使用的私有队列，断开后自动删除
• auto-delete：当所有消费端连接断开后，是否自动删除队列

7. 创建生产者端

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * @Description: 消息队列发送者
 * @Author: 
 * @CreateTime: 
 */
@Service
public class Producer {

 @Autowired
 private AmqpTemplate amqpTemplate;
 
 public void sendQueue(String exchange_key, String queue_key, Object object) {
  // convertAndSend 将Java对象转换为消息发送至匹配key的交换机中Exchange
  amqpTemplate.convertAndSend(exchange_key, queue_key, object);
 }
}

8. 在 applicationContext.xml 中配置监听及消费者端 

<!-- 消费者 -->
<bean name="rabbitmqService" class="com.enh.mq.RabbitmqService"></bean>
 
<!-- 配置监听 -->
<rabbit:listener-container connection-factory="connectionFactory" acknowledge="auto">
　　<!-- 
　　　　queues 监听队列，多个用逗号分隔 
　　　　ref 监听器
　　-->
　　<rabbit:listener queues="test_queue" ref="rabbitmqService"/>
</rabbit:listener-container>

消费者 Java 代码：

import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;

public class RabbitmqService implements MessageListener {
 public void onMessage(Message message) {
  System.out.println("消息消费者 = " + message.toString());
 }
}

至此，我们的所有配置文件就写完了，最终如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xmlns:context="http://www.springframework.org/schema/context"
  xmlns:util="http://www.springframework.org/schema/util"
  xmlns:aop="http://www.springframework.org/schema/aop"
  xmlns:tx="http://www.springframework.org/schema/tx"
  xmlns:rabbit="http://www.springframework.org/schema/rabbit"
  xmlns:p="http://www.springframework.org/schema/p"
  xsi:schemaLocation="
  http://www.springframework.org/schema/context
  http://www.springframework.org/schema/context/spring-context-3.0.xsd
  http://www.springframework.org/schema/beans
  http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
  http://www.springframework.org/schema/util
  http://www.springframework.org/schema/util/spring-util-3.0.xsd
  http://www.springframework.org/schema/aop
  http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
  http://www.springframework.org/schema/tx
  http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
  http://www.springframework.org/schema/rabbit
  http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd">
  
  
  
 <!-- RabbitMQ start -->
 
 <!-- 连接配置 -->
 <rabbit:connection-factory id="connectionFactory" host="${mq.host}" username="${mq.username}"
  password="${mq.password}" port="${mq.port}" />
  
 <rabbit:admin connection-factory="connectionFactory"/>
 
 <!-- 消息队列客户端 -->
 <rabbit:template id="amqpTemplate" exchange="${mq.queue}_exchange" connection-factory="connectionFactory" />
 
 <!-- queue 队列声明 -->
 <!-- 
  durable 是否持久化 
  exclusive 仅创建者可以使用的私有队列，断开后自动删除 
  auto-delete 当所有消费端连接断开后，是否自动删除队列 -->
 <rabbit:queue id="test_queue" name="${mq.queue}_testQueue" durable="true" auto-delete="false" exclusive="false" />
 
 <!-- 交换机定义 -->
 <!-- 
  交换机：一个交换机可以绑定多个队列，一个队列也可以绑定到多个交换机上。
  如果没有队列绑定到交换机上，则发送到该交换机上的信息则会丢失。
  
  direct模式:消息与一个特定的路由器完全匹配，才会转发
  topic模式:按规则转发消息，最灵活
  -->
 <rabbit:topic-exchange name="${mq.queue}_exchange" durable="true" auto-delete="false">
  <rabbit:bindings>
   <!-- 设置消息Queue匹配的pattern (direct模式为key) -->
   <rabbit:binding queue="test_queue" pattern="${mq.queue}_patt"/>
  </rabbit:bindings>
 </rabbit:topic-exchange>
 
 <bean name="rabbitmqService" class="com.enh.mq.RabbitmqService"></bean>
 
 <!-- 配置监听 消费者 -->
 <rabbit:listener-container connection-factory="connectionFactory" acknowledge="auto">
  <!-- 
   queues 监听队列，多个用逗号分隔 
   ref 监听器 -->
  <rabbit:listener queues="test_queue" ref="rabbitmqService"/>
 </rabbit:listener-container>
</beans>

9. 如何使用 RabbitMQ 发送一个消息

　　@Autowired
 private Producer producer;
 @Value("#{appConfig['mq.queue']}")
 private String queueId;
 
 /**
  * @Description: 消息队列
  * @Author: 
  * @CreateTime: 
  */
 @ResponseBody
 @RequestMapping("/sendQueue")
 public String testQueue() {
  try {
   Map<String, Object> map = new HashMap<String, Object>();
   map.put("data", "hello rabbitmq");
   producer.sendQueue(queueId + "_exchange", queueId + "_patt", map);
  } catch (Exception e) {
   e.printStackTrace();
  }
  return "发送完毕";
 }

嗯。这个测试是 SpringMVC 框架。

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

# RabbitMQ整合Spring  # spring整合rabbitmq  # Spring  # 消息队列  # SpringBoot使用RabbitMQ延时队列(小白必备)  # SpringBoot集成RabbitMQ的方法(死信队列)  # springboot实现rabbitmq的队列初始化和绑定  # Spring Boot与RabbitMQ结合实现延迟队列的示例  # rabbitmq结合spring实现消息队列优先级的方法  # Spring学习笔记3之消息队列(rabbitmq)发送邮件功能  # Spring项目集成RabbitMQ及自动创建队列  # 多个  # 绑定  # 交换器  # 机上  # 如果没有  # 会在  # 可以使用  # 到该  # 客户端  # 删除掉  # 还没有  # 切分  # 也会  # 是由  # 才会  # 等方面  # 可用性  # 还需要  # 四种  # 重启 

相关文章： h5在线制作网站电脑版下载,h5网页制作软件？  如何选购建站域名与空间？自助平台全解析  如何获取上海专业网站定制建站电话？  如何选择高效响应式自助建站源码系统？  建站主机空间推荐 高性价比配置与快速部署方案解析  购物网站制作公司有哪些,哪个购物网站比较好？  建站之星如何取消后台验证码生成？  如何优化Golang Web性能_Golang HTTP服务器性能提升方法  建站之星3.0如何解决常见操作问题？  网站制作中优化长尾关键字挖掘的技巧,建一个视频网站需要多少钱？  红河网站制作公司,红河事业单位身份证如何上传？  建站主机如何选？性能与价格怎样平衡？  如何通过服务器快速搭建网站？完整步骤解析  内部网站制作流程,如何建立公司内部网站？  TestNG的testng.xml配置文件怎么写  建站之星官网登录失败？如何快速解决？  如何快速生成橙子建站落地页链接？  上海网站制作网页,上海本地的生活网站有哪些？最好包括生活的各个方面的？  高性能网站服务器配置指南：安全稳定与高效建站核心方案  制作门户网站的参考文献在哪,小说网站怎么建立？  定制建站如何定义？其核心优势是什么？  如何在Windows服务器上快速搭建网站？  定制建站是什么？如何实现个性化需求？  视频网站app制作软件,有什么好的视频聊天网站或者软件？  宝塔新建站点报错如何解决？  如何在阿里云服务器自主搭建网站？  大连网站设计制作招聘信息,大连投诉网站有哪些？  建站之星后台密码遗忘或太弱？如何重置与强化？  网页设计网站制作软件,microsoft office哪个可以创建网页？  建站主机服务器选购指南：轻量应用与VPS配置解析  宿州网站制作公司兴策,安徽省低保查询网站？  如何在宝塔面板中创建新站点？  教育培训网站制作流程,请问edu教育网站的域名怎么申请？  公司网站制作价格怎么算,公司办个官网需要多少钱？  浅谈Javascript中的Label语句  Swift中循环语句中的转移语句 break 和 continue  存储型VPS适合搭建中小型网站吗？  大连 网站制作,大连天途有线官网？  如何快速搭建高效简练网站？  如何在万网ECS上快速搭建专属网站？  ,南京靠谱的征婚网站？  小型网站制作HTML,*游戏网站怎么搭建？  建站之星免费版是否永久可用？  如何用腾讯建站主机快速创建免费网站？  如何通过多用户协作模板快速搭建高效企业网站？  电商网站制作公司有哪些,1688网是什么意思？  香港服务器建站指南：外贸独立站搭建与跨境电商配置流程  外贸公司网站制作,外贸网站建设一般有哪些步骤？  如何在IIS7中新建站点？详细步骤解析  小程序网站制作需要准备什么资料,如何制作小程序？