网站首页 > 技术文章 正文
背景
公司为了省钱,最近项目消息队列由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 注意,如果配置了虚拟机,需要账号添加访问虚拟机的权限
- 上一篇: RabbitMQ的死信与延迟队列,你真的会用吗?
- 下一篇: 每日技巧分享:如何给图片去雾?
猜你喜欢
- 2024-12-03 RabbitMQ的死信与延迟队列,你真的会用吗?
- 2024-12-03 RabbitMQ原理与架构
- 2024-12-03 使用mq实现分布式事务-补偿事务一致性
- 2024-12-03 Linux安装及卸载RabbitMQ教程
- 2024-12-03 RabbitMQ 如何确保发布/订阅模式中的消息不丢失?
- 2024-12-03 SpringBoot+RabbitMQ 死神队列
你 发表评论:
欢迎- 最近发表
- 标签列表
-
- oraclesql优化 (66)
- 类的加载机制 (75)
- feignclient (62)
- 一致性hash算法 (71)
- dockfile (66)
- 锁机制 (57)
- javaresponse (60)
- 查看hive版本 (59)
- phpworkerman (57)
- spark算子 (58)
- vue双向绑定的原理 (68)
- springbootget请求 (58)
- docker网络三种模式 (67)
- spring控制反转 (71)
- data:image/jpeg (69)
- base64 (69)
- java分页 (64)
- kibanadocker (60)
- qabstracttablemodel (62)
- java生成pdf文件 (69)
- deletelater (62)
- com.aspose.words (58)
- android.mk (62)
- qopengl (73)
- epoch_millis (61)
本文暂时没有评论,来添加一个吧(●'◡'●)