使用红迅Jpass进行二开的时候,登录提示MQClientException: The producer service state not OK 使用红迅Jpass进行二开代码的时候,前端用户登录的时候出现报错,提示: Caused by: org.apache.rocketmq.client.exception.MQClientException: The ... 帅平微服务2025-08-21421 阅读1 评论
Kafka、RabbitMQ、RocketMQ、Pulsar选型有什么建议? 业务中准备使用消息队列,熟悉的有:Kafka、RabbitMQ、RocketMQ、Pulsar。请问在选型上有什么建议?... 帅平消息队列2024-07-28928 阅读6 评论
Rocket MQ的顺序消息消费,如果有一条消息消费不成功,造成了它后边消息的消息堆积,这种情况下应该怎么办 Rocket MQ的顺序消息消费,如果有一条消息消费不成功,造成了它后边消息的消息堆积,这种情况下应该怎么办?处理措施如何保证消息的顺序性?... Rae消息队列2024-04-03651 阅读1 评论
RocketMQ使用docker容器启动服务,结果多个消费者的clientid一样,导致rocketmq的rebalance失效怎么办? RocketMQ使用docker容器启动服务,结果多个消费者的clientid一样,导致rocketmq的rebalance失效怎么办?... 帅平微服务2023-07-19702 阅读1 评论
热文RocketMQ系列(十)RocketMQ是如何做消息清理的 由于消息是存磁盘的,但是磁盘空间是有限的,所以对于磁盘上的消息是需要清理的。当出现以下几种情况下时就会触发消息清理:手动执行删除 默认每天凌晨4点会自动清理过期的文件 当磁盘空间占用率默认达到75%之后,会自动清理过... Rae消息中间件2023-01-111307 阅读0 评论
热文RocketMQ系列(九)RocketMQ是如何实现消息的顺序性的? 这里插入一个比较常见的一个面试,那么如何保证保证消息的顺序性。其实要想保证消息的顺序只要保证以下三点即可1、生产者将需要保证顺序的消息发送到同一个队列 2、消息队列在存储消息的时候按照顺序存储 3、消费者按照顺序消费... Rae消息中间件2023-01-111003 阅读0 评论
RocketMQ系列(八)RocketMQ是如何消费的? 上一篇文章我们介绍了RocketMQ是如何保证高可用的,这篇文章我们介绍下RocketMQ是如何消费的。在生产者成功发送消息到Broker,Broker在成功存储消息之后,消费者要消费消息了。消费者在启动的时候会从N... Rae消息中间件2023-01-11897 阅读0 评论
热文RocketMQ系列(七)RocketMQ是如何保证高可用的? 上一篇文章我们介绍了RocketMQ的消息存储,这一篇文章我们介绍下RocketMQ的高可用。在说高可用之前,先来完善一下前面的一些概念。在前面介绍概念的时候也说过,一个RokcetMQ中可以有很多个Broker实例... Rae消息中间件2023-01-111004 阅读0 评论
RocketMQ系列(六)消息是如何存储的? 上一篇我们介绍了RocketMQ消息是如何诞生与发送的,这一篇文章我们介绍下Rocketmq消息是如何存储的。说到存储,那肯定就是持久化到磁盘,那么从消息接收到最终落到磁盘里面会涉及到哪些内容呢?一、如何保证高性能读... Rae消息中间件2023-01-11887 阅读0 评论
RocketMQ系列(五)消息是如何诞生与发送的? 我们都知道,消息是由业务系统在运行过程产生的,当我们的业务系统产生了消息,我们就可以调用RocketMQ提供的API向RocketMQ发送消息,就像下面这样DefaultMQProducer producer = n... Rae消息中间件2023-01-11891 阅读0 评论