文章目录1、什么是 RabbitMQ?为什么使用 RabbitMQ?2、RabbitMQ 有什么优缺点?3.rabbitmq 的使用场景4.RabbitMQ基本概念5.RabbitMQ 中的 broker 是指什么?cluster 又是指什么?6、RabbitMQ 概念里的 channel、exchange 和 queue 是逻辑概念,还是对应着进程实体?分 ......
139
0
0
2024-02-24
一、资料文档二、开发语言三、支持的协议四、消息存储五、消息事务六、 负载均衡 七、集群方式八、管理界面九、可用性十、消息重复十一、吞吐量TPS十二、订阅形式和消息分发十三、顺序消息十四、消息确认十五、消息回溯十六、消息重试十七、并发度本文将从,Kafka、 rabbitmq 、ZeroMQ、RocketMQ、ActiveMQ 17 个方面综合对比作为消息队列 ......
223
0
0
2023-08-29
对于消息中间件RabbitMQ,想必各位小伙伴并不陌生,其广泛应用程度不言而喻,此前我们也在许多课程以及诸多专栏文章中介绍了它的应用,其应用场景也是相当广泛的,像什么消息异步通信、服务模块解耦、高并发流量削峰、订单超时未支付自动失效等等都是实际项目中最为常见的场景。本文我们将重点介绍并实现Rabbit mq 的死信与延时队列,并将两者做一个简单的对比!内容对 ......
186
0
0
2023-06-18
一、初识 MQ MQ,中文意思是消息队列(MessageQueue),字面来看就是存放消息的队列,也就是 事件驱动架构 中的Broker。 1.1常见的几种MQ ActiveMQ rabbitMq RocketMQ Kafka 1.2几种MQ的对比 1.3MQ的基本结构 publisher :消息的提供者 exchange ......
200
0
0
2023-06-17
Dubbo远程调用的性能问题Dubbo调用在微服务项目中普遍存在 这些Dubbo调用都是同步的 “同步”指:A(消费者)调用B(生产者)的服务A在发起调用后,在B返回之前只能等待 直到B返回结果后A才能运行 订单减库Dubbo消费者发送调用后进入阻塞状态,这个状态表示改线程仍占用内存资源,但是什么动作都不做 如果生产者运行耗时较久,消费者就一直等待,如果消 ......
270
0
0
2023-06-13
一、简单的发送与接收消息 HelloWorld1. 发送消息 发送消息首先要获取与rabbitmq-server的连接,然后从渠道(chann)中指定的queue发送消息 , 不能定义两个queue名字相同,但属性不同示例: package com.zf.rabbitmq; import Java .io.IOException; import co ......
187
0
0
2023-06-09
目录前言循环场景解决方案一次消费消息不重入队列限定重试次数消息头设定次数存储重试次数队列使用Quorum类型队列消息过期参考资料前言当消费者端接收消息处理业务时,如果出现异常或是拒收消息将消息又变更为等待投递再次推送给消费者,这样一来,则形成循环的条件。循环场景生产者发送100条消息到RabbitMQ中,消费者设定读取到第50条消息时,设置拒收,同时设定是否 ......
269
0
0
2023-06-08
SpringBoot整合rabbitMq一、介绍消息队列(Message Queue)简称mq,本文将介绍SpringBoot整合rabbitmq的功能使用队列是一种数据结构,就像排队一样,遵循先进先出的原则。而消息队列是一种消息中间件,在项目中我们可以将消息打包放入队列,再由消费者监听进行处理数据,再进行业务的处理那么使用队列可以带来哪些好处呢解耦异步流量 ......
207
0
0
2023-03-27
前言一直没机会做spring生态圈的框架,公司选择的是一些小众的微服务,鉴于此考虑,丰富自己的技术栈,花了两天时间从网上各网站上学习了springboot一些基础知识。 本章只介绍springboot微服务集成RabbitMQ,用于通过消息中间件给其他微服务发送消息。环境准备IntelliJ IDEA前一章中搭建的微服务框架开始集成pom.xml中增加依赖包 ......
295
0
0
2023-03-03
目录需求步骤环境搭建canal.propertiesinstance.properties修改canal配置文件整合SpringBoot Canal实现客户端Canal整合RabbitMQSpringBoot整合RabbitMQ需求我想要在SpringBoot中采用一种与业务代码解耦合的方式,来实现数据的变更记录,记录的内容是新数据,如果是更新操作还得有旧数 ......
290
0
0
2023-02-05
目录前言RabbitMq的投递及消费流程提供者如何确保消息的成功投递单条消息的同步确认多条消息的同步确认异步消息确认消息的返回机制前言现在的一些互联网项目或者是高并发的项目中很少有没有引入消息队列的。 引入消息队列可以给这个项目带来很多的好处:比如削峰这个就很好的理解,在系统中的请求量是固定的,但是有的时候会多出很多的突发流量,比如在有秒杀活动的时候,这种瞬 ......
262
0
0
2023-02-05
RabbitMQ 是一个消息中间件,它接收消息并且转发,是“消费-生产者模型”的一个典型的代表,一端往消息队列中不断的写入消息,而另一端则可以读取或者订阅队列中的消息。 RabbitMQ 于 2007 年发布,由 erlang 语言进行开源实现,基于 AMQP(Advanced Message Queue 高级消息队列协议)基础上完成的。RabbitMQ 是 ......
278
0
0
2023-01-13
本文将从,Kafka、RabbitMQ、ZeroMQ、RocketMQ、ActiveMQ 17 个方面综合对比作为消息队列使用时的差异。一、资料文档Kafka:中。有kafka作者自己写的书,网上资料也有一些。rabbitmq:多。有一些不错的书,网上资料多。zeromq:少。没有专门写zeromq的书,网上的资料多是一些代码的实现和简单介绍。rocketm ......
300
0
0
2022-12-12
一、分布式事务实现方式1.1、两阶段提交(2PC) 需要数据库厂商的支持,java组件有atomikos等两阶段提交(Two-phase Commit,2PC),通过引入协调者(Coordinator)来协调参与者的行为,并最终决定这些参与者是否要真正执行事务准备阶段协调者询问参与者事务是否执行成功,参与者发回事务执行结果提交阶段如果事务在每个参与者上都执行 ......
479
0
0
2022-11-15
引入依赖 <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter& ......
380
0
0
2022-11-14