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

2023-09-26 15:44:06 50

一、什么是RabbitMQ

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

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

二、如何与Spring集成

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

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



com.rabbitmq
amqp-client
3.5.1


org.springframework.amqp
spring-rabbit
1.4.5.RELEASE

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文件

3.连接RabbitMQ服务器

4.声明一个RabbitMQTemplate

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

交换机的四种模式：

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

交换器的属性：

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

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

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

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

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

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

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

7.创建生产者端

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

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

@Autowired
privateAmqpTemplateamqpTemplate;

publicvoidsendQueue(Stringexchange_key,Stringqueue_key,Objectobject){
//convertAndSend将Java对象转换为消息发送至匹配key的交换机中Exchange
amqpTemplate.convertAndSend(exchange_key,queue_key,object);
}
}

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

消费者Java代码：

importorg.springframework.amqp.core.Message;
importorg.springframework.amqp.core.MessageListener;

publicclassRabbitmqServiceimplementsMessageListener{
publicvoidonMessage(Messagemessage){
System.out.println("消息消费者="+message.toString());
}
}

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

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

@Autowired
privateProducerproducer;
@Value("#{appConfig['mq.queue']}")
privateStringqueueId;

/**
*@Description:消息队列
*@Author:
*@CreateTime:
*/
@ResponseBody
@RequestMapping("/sendQueue")
publicStringtestQueue(){
try{
Mapmap=newHashMap();
map.put("data","hellorabbitmq");
producer.sendQueue(queueId+"_exchange",queueId+"_patt",map);
}catch(Exceptione){
e.printStackTrace();
}
return"发送完毕";
}

嗯。这个测试是SpringMVC框架。

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

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

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

热门推荐

随机推荐