计算机系统应用教程网站

网站首页 > 技术文章 正文

springboot 集成RabbitMq 消息队列,入门实战,看这一篇就够了

btikc 2024-12-03 10:41:04 技术文章 61 ℃ 0 评论

背景

公司为了省钱,最近项目消息队列由rocketmq 转向自己搭建的rabbitMq。

简单认识

1 可靠性: 支持持久化,发布确认,传输确认来保证。

2 灵活的分发消息策略

分发消息策略有:简单模式、工作队列模式、发布订阅模式、路由模式、通配符模式。

3 支持集群。多台RabbitMQ服务器可以组成一个集群,形成一个逻辑Broker。

4 多种协议。RabbitMQ支持多种消息队列协议,比如 STOMP、MQTT 等等。

5 支持多种语言的客户端。RabbitMQ几乎支持所有常用编程语言,包括 Java、.NET、Ruby 等等。提供可视化管理界面。

6 支持插件:提供很多插件(消息轨迹追踪等),也可以自定义插件。

AMQPAMQP模型

消息(message)被发布者(publisher)发送给交换机(exchange),然后交换机将收到的消息根据路由规则分发给绑定的队列(queue)。最后AMQP代理会将消息投递给订阅了此队列的消费者,或者消费者按照需求自行获取。

消息确认

从安全角度考虑,网络是不可靠的,消费消息的时候可能会失败。基于此原因,AMQP模块包含了一个消息确认(message acknowledgements)的概念:当消息从队列投递给消费者的时候,消费者服务器需要返回一个ack(确认信息),当broker收到了确认才会将该消息删除;消息确认可以是自动的,也可以是由消费端手动确认。此外也支持生产端向broker发送消息得到broker的ack,从而针对做出响应逻辑。

实战代码

1 配置


2 发送消息,消费消息

3 界面

4 注意,如果配置了虚拟机,需要账号添加访问虚拟机的权限

本文暂时没有评论,来添加一个吧(●'◡'●)

欢迎 发表评论:

最近发表
标签列表