ActiveMQ中,我们可以通过配置prefetch(预取数量)来限制队列的并发消费数。 主要的JavaScr… 继续阅读 ActiveMQ如何限制消息的并发消费数?
分类: MQ
ActiveMQ如何监控和提醒主从切换不成功?
ActiveMQ主从复制集群中,主要对从节点需要监控以下几方面:一、Master 节点是否已挂掉 通过心跳检测… 继续阅读 ActiveMQ如何监控和提醒主从切换不成功?
Kafka整合 Redis 的步骤是什么?
Kafka整合Redis的主要步骤为: 1. 部署Kafka集群 按照之前的步骤部署一个Kafka集群。 2.… 继续阅读 Kafka整合 Redis 的步骤是什么?
Kafka整合 Elasticsearch 的步骤是什么?
Kafka整合Elasticsearch的主要步骤为: 1. 安装并启动 Kafka 集群 根据之前的步骤正确… 继续阅读 Kafka整合 Elasticsearch 的步骤是什么?
ActiveMQ如何定制持久化策略?
ActiveMQ默认采用KahaDB作为持久化存储,但是也允许我们定制持久化策略。一、基于文件方式持久化直接将… 继续阅读 ActiveMQ如何定制持久化策略?
Kafka使用Zookeeper来做什么?
Kafka使用Zookeeper主要做以下几件事情: 1. 注册和发现Kafka brokers Zookee… 继续阅读 Kafka使用Zookeeper来做什么?
Kafka集群如何部署?
Kafka集群的部署主要包括以下几个步骤: 安装Java环境Kafka 需要 Java 8 及以上版本,所以先… 继续阅读 Kafka集群如何部署?
【ActiveMQ】ActiveMQ如何监控和统计消息的延迟情况?
ActiveMQ主要提供以下几种方式监控和统计消息的延迟情况:一、管理控制台管理控制台可以实时查看各个队列的平… 继续阅读 【ActiveMQ】ActiveMQ如何监控和统计消息的延迟情况?
【Kafka】Kafka如何保证消息不丢失?
Kafka主要通过以下几个机制来保证消息不丢失: 1. 持久化消息 Kafka会将所有产生的消息持久化到磁盘上… 继续阅读 【Kafka】Kafka如何保证消息不丢失?
给用户发消息任务超出队列,能用哪些拒绝策略?有其他方法吗 ?
当给用户发消息的任务超出队列容量时,选择合适的拒绝策略是很重要的。以下是几种常见的拒绝策略及其适用场景: Ab… 继续阅读 给用户发消息任务超出队列,能用哪些拒绝策略?有其他方法吗 ?
ActiveMQ如何保障消息业务的原子性?
ActiveMQ主要通过消息本地事务和XA分布式事务,实现消息交换的原子性: 一、本地事务 ActiveMQ支… 继续阅读 ActiveMQ如何保障消息业务的原子性?
Kafka的消费队列的原理是什么?
Kafka实现发布-订阅模式主要如下: 1. 通过 Topic 生产者(Producer)生产的消息会发送到特… 继续阅读 Kafka的消费队列的原理是什么?
Kafka的发布-订阅模式如何实现?
Kafka实现发布-订阅模式的主要组件是: Producer 负责将消息发布到 Kafka cluster 中… 继续阅读 Kafka的发布-订阅模式如何实现?
ActiveMQ如何处理消息堆积和积压问题?
ActiveMQ在处理消息堆积和积压问题上主要考虑以下几方面: 一、限制内存占用 通过设置`’标签… 继续阅读 ActiveMQ如何处理消息堆积和积压问题?
Kafka的消费者组有什么作用?
Kafka的消费者组具有重要的作用: 1. 平摊负载 一个消费者组下面可以有多个消费者实例。这些消费者会平均分… 继续阅读 Kafka的消费者组有什么作用?
Kafka的分区和复制因子有什么作用?
Kafka的分区和复制因子有重要的作用: 分区(Partition) 提供水平扩展能力。随着分区的增加,Kaf… 继续阅读 Kafka的分区和复制因子有什么作用?
ActiveMQ如何保障消息传递的完整性?
ActiveMQ提供了以下几种保障消息完整性传递的方式: 一、持久化确认模式 将消息持久化到磁盘,必要时能进行… 继续阅读 ActiveMQ如何保障消息传递的完整性?
Kafka的数据模型是什么?
Kafka的数据模型主要包括以下几个部分: 1. Topic 最顶层的一个逻辑单元,可以理解为一个分区树。一个… 继续阅读 Kafka的数据模型是什么?
Kafka的特点有哪些?
Kafka是一个高性能、分布式、发布订阅模式的消息队列系统,广泛应用于大数据实时处理、日志收集、流处理等场景。… 继续阅读 Kafka的特点有哪些?
ActiveMQ的用户角色如何配置?
ActiveMQ允许我们创建不同的用户角色,并配置各自的访问权限。首先我们需要在<broker>中… 继续阅读 ActiveMQ的用户角色如何配置?