Springboot实战rabbitmq消费者+死信队列 最近线上的rabbitmq消费者出现了消息积压的情况，因此收到了报警。果断上去查看，挤压的消息确实够多，很多数据都没有被及时的处理，所以第一时间检查了代码，一看消费者一直在消费同一条消息，也就是出现了死循环。对于根据... Rae 消息中间件 2024-04-09 268 阅读 0 评论
使用scala编写kafka的生产者和消费者案例 最近在演示spark相关的内容，所以这里单独出一个案例，使用scala编写一个kafka的生产者和消费者的代码案例，直接上代码：生产者代码示例：package com.kafka.produceri... Rae 消息中间件 2024-01-29 329 阅读 0 评论
Kafka常用命令（一）基础操作命令 在本文中，我们介绍下在kafka中常见的操作命令，下面直接开始：查看当前服务器中的所有topickafka-topics --zookeeper xxxxxx:2181 --list&n... Rae 消息中间件 2023-06-12 379 阅读 0 评论
RocketMQ系列（十）RocketMQ是如何做消息清理的 由于消息是存磁盘的，但是磁盘空间是有限的，所以对于磁盘上的消息是需要清理的。当出现以下几种情况下时就会触发消息清理：手动执行删除默认每天凌晨4点会自动清理过期的文件当磁盘空间占用率默认达到75%之后，会自动清... Rae 消息中间件 2023-01-11 698 阅读 0 评论
RocketMQ系列（九）RocketMQ是如何实现消息的顺序性的？ 这里插入一个比较常见的一个面试，那么如何保证保证消息的顺序性。其实要想保证消息的顺序只要保证以下三点即可1、生产者将需要保证顺序的消息发送到同一个队列2、消息队列在存储消息的时候按照顺序存储3、消费者按照顺序... Rae 消息中间件 2023-01-11 478 阅读 0 评论
RocketMQ系列（八）RocketMQ是如何消费的？ 上一篇文章我们介绍了RocketMQ是如何保证高可用的，这篇文章我们介绍下RocketMQ是如何消费的。在生产者成功发送消息到Broker，Broker在成功存储消息之后，消费者要消费消息了。消费者在启动的时候会从N... Rae 消息中间件 2023-01-11 365 阅读 0 评论
RocketMQ系列（七）RocketMQ是如何保证高可用的？ 上一篇文章我们介绍了RocketMQ的消息存储，这一篇文章我们介绍下RocketMQ的高可用。在说高可用之前，先来完善一下前面的一些概念。在前面介绍概念的时候也说过，一个RokcetMQ中可以有很多个Broker实例... Rae 消息中间件 2023-01-11 388 阅读 0 评论
RocketMQ系列（六）消息是如何存储的？ 上一篇我们介绍了RocketMQ消息是如何诞生与发送的，这一篇文章我们介绍下Rocketmq消息是如何存储的。说到存储，那肯定就是持久化到磁盘，那么从消息接收到最终落到磁盘里面会涉及到哪些内容呢？一、如何保证高性能读... Rae 消息中间件 2023-01-11 368 阅读 0 评论
RocketMQ系列（五）消息是如何诞生与发送的？ 我们都知道，消息是由业务系统在运行过程产生的，当我们的业务系统产生了消息，我们就可以调用RocketMQ提供的API向RocketMQ发送消息，就像下面这样DefaultMQProducer produce... Rae 消息中间件 2023-01-11 352 阅读 0 评论
RocketMQ系列（四）RocketMQ可视化UI dashboard安装 上一篇文章我们演示了安装rocketmq，安装完毕之后，我们可以通过可视化界面的方式查看rocketmq集群的情况。因此这里演示一下如何安装rocketmq的可视化UI dashboard。其实这个可视化UI就是一个... Rae 消息中间件 2023-01-10 857 阅读 0 评论
