一、InstallationRocketMQ-4.9.2onCentOS7.9地址：https://rocketmq.apache.orghttps://github.com/apache/rocketmqhttps://archive.apache.org/dist/rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip 准备环境 二、下载RocketMQwgethttps://archive.apache.org/dist/rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip安装解压工具yuminst
一、InstallationRocketMQ-4.9.2onCentOS7.9地址：https://rocketmq.apache.orghttps://github.com/apache/rocketmqhttps://archive.apache.org/dist/rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip 准备环境 二、下载RocketMQwgethttps://archive.apache.org/dist/rocketmq/4.9.2/rocketmq-all-4.9.2-bin-release.zip安装解压工具yuminst
在众多关于MQ的面试八股文中有这么一道题，“如何保证MQ消息消费的幂等性”。为什么需要保证幂等性呢？是因为消息会重复消费。为什么消息会重复消费？明明已经消费了，为什么消息会被再次被消费呢？不同的MQ产生的原因可能不一样本文就以RocketMQ为例，来扒一扒RocketMQ中会导致消息重复消息的原因，最终你会发现，其实消息重复消费算是RocketMQ无奈的“bug”。 消息发送异常时重复发送首先，我们来瞅瞅RocketMQ发送消息和消费消息的基本原理。如图，简单说一下上图中的概念：Broker，就是RocketMQ的服务端，如上图就有两个服务实例Topic就是一类消息集合的名字Queue就是To
在众多关于MQ的面试八股文中有这么一道题，“如何保证MQ消息消费的幂等性”。为什么需要保证幂等性呢？是因为消息会重复消费。为什么消息会重复消费？明明已经消费了，为什么消息会被再次被消费呢？不同的MQ产生的原因可能不一样本文就以RocketMQ为例，来扒一扒RocketMQ中会导致消息重复消息的原因，最终你会发现，其实消息重复消费算是RocketMQ无奈的“bug”。 消息发送异常时重复发送首先，我们来瞅瞅RocketMQ发送消息和消费消息的基本原理。如图，简单说一下上图中的概念：Broker，就是RocketMQ的服务端，如上图就有两个服务实例Topic就是一类消息集合的名字Queue就是To
延迟任务在我们日常生活中比较常见，比如订单支付超时取消订单功能，又比如自动确定收货的功能等等。所以本篇文章就来从实现到原理来盘点延迟任务的11种实现方式，这些方式并没有绝对的好坏之分，只是适用场景的不大相同。DelayQueueDelayQueue是JDK提供的api，是一个延迟队列DelayQueue泛型参数得实现Delayed接口，Delayed继承了Comparable接口。getDelay方法返回这个任务还剩多久时间可以执行，小于0的时候说明可以这个延迟任务到了执行的时间了。compareTo这个是对任务排序的，保证最先到延迟时间的任务排到队列的头。来个demo@Getterpubli
延迟任务在我们日常生活中比较常见，比如订单支付超时取消订单功能，又比如自动确定收货的功能等等。所以本篇文章就来从实现到原理来盘点延迟任务的11种实现方式，这些方式并没有绝对的好坏之分，只是适用场景的不大相同。DelayQueueDelayQueue是JDK提供的api，是一个延迟队列DelayQueue泛型参数得实现Delayed接口，Delayed继承了Comparable接口。getDelay方法返回这个任务还剩多久时间可以执行，小于0的时候说明可以这个延迟任务到了执行的时间了。compareTo这个是对任务排序的，保证最先到延迟时间的任务排到队列的头。来个demo@Getterpubli
SpringBoot是一个基于Spring框架的快速开发框架，而RabbitMQ和RocketMQ则是常用的消息队列中间件。下面是它们常用的一些用法和场景。1、订单处理在电商等系统中，下单后需要进行一系列的处理，包括库存扣减、支付通知等。可以将订单相关的消息发送到消息队列中，由消费者异步地进行处理，从而提高系统的处理能力和可靠性。使用RabbitMQ实现订单处理的示例代码：//发送订单消息rabbitTemplate.convertAndSend("order-exchange","order-routing-key",order);//消费订单消息@RabbitListener(queues
SpringBoot是一个基于Spring框架的快速开发框架，而RabbitMQ和RocketMQ则是常用的消息队列中间件。下面是它们常用的一些用法和场景。1、订单处理在电商等系统中，下单后需要进行一系列的处理，包括库存扣减、支付通知等。可以将订单相关的消息发送到消息队列中，由消费者异步地进行处理，从而提高系统的处理能力和可靠性。使用RabbitMQ实现订单处理的示例代码：//发送订单消息rabbitTemplate.convertAndSend("order-exchange","order-routing-key",order);//消费订单消息@RabbitListener(queues
SpringBoot是一个快速开发框架，可以帮助开发人员快速构建和部署基于Java的Web应用程序。同时，它还提供了对多种消息队列系统的支持，包括RocketMQ、Kafka、RabbitMQ、ActiveMQ和ZeroMQ。这些消息队列系统都有各自的优点和缺点，下面我们来分别介绍一下。1、RocketMQRocketMQ是阿里巴巴开源的分布式消息队列系统，具有高可用、高可靠、高性能等特点。它适合大规模分布式系统中的消息传递、异步处理、解耦等场景。在SpringBoot中使用RocketMQ，需要添加如下依赖：dependency>groupId>com.alibaba.cloudgroupI
SpringBoot是一个快速开发框架，可以帮助开发人员快速构建和部署基于Java的Web应用程序。同时，它还提供了对多种消息队列系统的支持，包括RocketMQ、Kafka、RabbitMQ、ActiveMQ和ZeroMQ。这些消息队列系统都有各自的优点和缺点，下面我们来分别介绍一下。1、RocketMQRocketMQ是阿里巴巴开源的分布式消息队列系统，具有高可用、高可靠、高性能等特点。它适合大规模分布式系统中的消息传递、异步处理、解耦等场景。在SpringBoot中使用RocketMQ，需要添加如下依赖：dependency>groupId>com.alibaba.cloudgroupI
