背景由于mac电脑，M1芯片下面安装的linux版本和大多数的linux有些许区别，所以在下载rocketmq镜像时候会报错。WARNING:Therequestedimage'splatform(linux/amd64)doesnotmatch所以需要下载支持arm64v8版本，但是在dockerhub上面没有，查询了很多的资料，最后终于找到了M1芯片下面能使用的rocketmq镜像参考文章https://blog.csdn.net/xiaolixi199311/article/details/131612079下载rocketmq镜像gitclonehttps://github.com/a
微服务之间实现关联的策略（但并不破坏微服务之间的解耦性）:OpenFeign调用和消息队列（ActiveMQ、RabbitMQ、Kafka、RocketMQ等）内部API调用（OpenFeign）消息队列（ActiveMQ、RabbitMQ、Kafka、RocketMQ）服务组合“内部API调用”和“消息队列”这两种方式的优缺点及对应的适用场景内部API调用优点缺点适用场景消息队列优点缺点适用场景可考虑“内部API调用”和“消息队列”结合使用在实际业务中，不同的微服务之间可能存在一定的关联性，比如在微服务OrderService中需要获取微服务UserService中的用户信息。这种情况下，可
前言在构建分布式系统时，选择适合的消息中间件是至关重要的决策。RabbitMQ、Kafka、ActiveMQ和RocketMQ是当前流行的消息中间件之一，它们各自具有独特的特点和适用场景。本文将对这四种消息中间件进行综合比较，帮助您在项目中作出明智的选择。1.RabbitMQ特点：消息模型：RabbitMQ采用AMQP（高级消息队列协议）标准，支持多种消息模型，包括点对点和发布/订阅。可靠性：提供丰富的可靠性机制，支持持久化、事务和消息确认等。灵活性：可以轻松地与多种编程语言和框架集成，提供强大的插件系统。优势：易用性：简单易用，适合初学者，有着良好的文档和社区支持。高可用性：提供集群和镜像队
目录前言1、常见消息队列1.ActiveMQ2.RabbitMQ3.RocketMQ4.Kafka2、区别1.消息传递模型2.消息持久化3.消息顺序性4.可靠性5.生态系统和社区支持6.表格对比前言消息队列可以实现应用程序之间的异步通信，能够实现异步消息的发送和接收，提高系统的可伸缩性和可靠性。常见消息队列：ActiveMQ、RabbitMQ、RocketMQ、Kafka等。1、常见消息队列1.ActiveMQActiveMQ是基于JavaMessageService(JMS)规范的开源消息队列软件，它使用了传统的基于队列（Queue）和发布-订阅（Topic）模式。ActiveMQ支持多种通
帮你梳理RocketMQ或Kafka的选择理由以及二者PK前提背景架构对比RocketMQ的架构Kafka的架构Broker对比主从架构模型差异:维度不同刷盘机制消息查询消费失败重试与延迟消费数据读写速度随机和顺序读写的对比连续I/O比随机I/O效率高的原因是随机和顺序速度比较服务治理Producer差异发送方式发送响应Consumer差异消息过滤有序消息消费确认消费并行度事务消息Topic和Tag的区别？Tag和Topic的选用Tag怎么实现消息过滤Tag过滤方式MessageBody过滤方式数据消息的堆积能力消息数据回溯性能对比数据一致性和实时性消息投递实时性消费失败重试消息顺序（题外话）
前言官方定义消息体默认大小为4MB，普通顺序消息类型。事务、定时、延时类消息默认大小为64KB。如果超过限制则会抛出异常！但实际工作中，需要使用到MQ进行异步解耦，传输的业务消息偶尔会遇到超过4MB，尤其在业务复杂的系统中，那么我们应该如何处理呢？在我工作实际应用中，有以下几种解决方案。解决方案方案一：消息压缩通常我们都是传递json消息数据，然后底层使用字节流进行传输。如果此时json数据超过4MB，则可以考虑进行消息压缩。原理其实很好理解，比如我们经常使用的压缩包，可以把大文件进行压缩，依次减小文件大小。那么我们这里需要使用到的就是字符压缩，把json字符串进行压缩，然后进行传输，原理图如
今天我们将解决使用RocketMQ事务消息时可能遇到的一个常见问题：如何让其支持多事务消息？1.问题背景在实际开发中，我们常常会面临多事务消息的场景，例如在DailyMart的订单模块中，用户支付后需要调用库存服务进行库存扣减，而在订单确认收货后需要调用用户服务实现积分赠送。这两个业务逻辑都需要通过事务消息来保证分布式事务。为了处理这种情况，我们可能会考虑在订单模块中创建两个事务消息监听器，分别用于处理库存扣减和积分赠送的事务处理和事务回查。@Component@Slf4j//处理订单支付的事务监听器publicclassOrderPaidTransactionListenerimplemen
一、背景RocketMQ无论采用Master/Slave的主从模式，还是采用Dledger的多副本模式，均能保证RocketMQ集群的高可用性，但在一些极端场景下，例如机房断电、机房火灾、地震等不可抗拒因素使得该IDC可用区的RocketMQ集群无法正常对外提供消息服务能力。因此，为了增强抗风险能力，消息队列RocketMQ集群多活异地容灾极为重要。二、物理部署异地容灾方案图2-1物理部署异地容灾方案图移动云部署的RocketMQ采用的Master/Slave的主从模式，其中物理部署异地容灾的方案包括以下几部分：(1)NameServer组件作为轻量级注册中心，无状态，负责更新和发现Broke
RocketMQ简单入门本文若有不当之处欢迎提出pr/issue主要内容：初识MQRocketMQ简介RocketMQ安装RocketMQ快速入门SpringBoot集成RocketMQ最后1.初识MQ1.1.同步和异步通讯微服务间通讯有同步和异步两种方式：同步通讯：就像打电话，需要实时响应。异步通讯：就像发邮件，不需要马上回复。两种方式各有优劣，打电话可以立即得到响应，但是你却不能跟多个人同时通话。发送邮件可以同时与多个人收发邮件，但是往往响应会有延迟。1.1.1.同步通讯Feign调用就属于同步方式，虽然调用可以实时得到结果，但存在下面的问题：总结：同步调用的优点：时效性较强，可以立即得到
SpringBoot集成RocketMQ全部种类消息实现+生产者和消费者配置信息介绍内含5.x新增可自定义时间的定时/延时消息前言添加POM依赖添加application.yml配置信息创建公共示例对象（只看demo可忽略）消费者相关介绍ACK机制介绍@RocketMQMessageListener介绍参数介绍RocketMQListener接口介绍泛型问题使用MessageExt（可获取完整消息对象：消息体、消息ID、topic、queueId等）使用UserDTO（不需要完整消息对象直接使用消息体类型）发送单向消息生产者消费者发送同步消息（响应值为void）生产者消费者发送同步消息（响应值
