ActiveMQ 支持多种传输协议,主要包括: TCP:默认的传输协议,使用端口 61616。 NIO:基于 … 继续阅读 ActiveMQ支持哪些传输协议?
分类: MQ
Kafka中如何实现数据的顺序性?
Kafka 中的数据顺序性主要通过以下机制实现: 分区内顺序:Kafka 保证同一个分区内的消息是有序的。消费… 继续阅读 Kafka中如何实现数据的顺序性?
RocketMQ的Broker和NameServer之间的通信协议是什么?
RocketMQ的Broker和NameServer之间使用TCP协议进行通信,交换的消息格式为RocketM… 继续阅读 RocketMQ的Broker和NameServer之间的通信协议是什么?
ActiveMQ中如何实现消息的过滤和选择?
ActiveMQ提供了消息选择器(Message Selector)的功能,可以根据消息的属性值来选择需要消费… 继续阅读 ActiveMQ中如何实现消息的过滤和选择?
什么是ActiveMQ?它是如何工作的?
ActiveMQ 是 Apache 出品的开源消息中间件,它实现了 JMS 规范,支持集群,故障转移,高可用等… 继续阅读 什么是ActiveMQ?它是如何工作的?
RabbitMQ中如何实现高并发下的消息发送和接收?
RabbitMQ 可以实现高并发下的消息发送与接收。 主要通过以下方式: 生产者启用 Publisher Co… 继续阅读 RabbitMQ中如何实现高并发下的消息发送和接收?
ActiveMQ与JMS的关系是什么?
ActiveMQ 实现了 JMS(Java Message Service)规范,它们的关系如下: JMS 是… 继续阅读 ActiveMQ与JMS的关系是什么?
Kafka中的分区再均衡(Rebalance)是什么?有什么作用?
Kafka 中的分区再均衡(Partition Rebalance)是指分区在集群中的分布发生变化的过程。再均… 继续阅读 Kafka中的分区再均衡(Rebalance)是什么?有什么作用?
RocketMQ的消息事务机制是如何实现的?
RocketMQ的事务消息机制通过本地事务和消息事务两阶段来实现。 本地事务:生产者发送事务消息前,需要首先执… 继续阅读 RocketMQ的消息事务机制是如何实现的?
RabbitMQ中如何实现异步RPC调用?
RabbitMQ 可以实现异步 RPC 调用的效果。 工作原理是: 1. 客户端作为 RPC 请求的发起者,将… 继续阅读 RabbitMQ中如何实现异步RPC调用?
Kafka中的主题(Topic)是什么?有什么作用?
Kafka 中的主题(Topic)是消息流的逻辑名称。每个主题都会拥有多个分区并分布在多个 Broker 上。… 继续阅读 Kafka中的主题(Topic)是什么?有什么作用?
RocketMQ的Broker如何处理消息堆积问题?
RocketMQ的Broker通过以下几种机制处理消息堆积问题: 临时存储:当消息发送速度大于消费速度时,Br… 继续阅读 RocketMQ的Broker如何处理消息堆积问题?
ActiveMQ中如何实现消息的定时发送和消费?代码详细演示
ActiveMQ提供了基于时间的调度机制,可以用来定时发送消息或者定时执行任务。这个机制的基本原理是在消息头中… 继续阅读 ActiveMQ中如何实现消息的定时发送和消费?代码详细演示
RabbitMQ中如何实现多消费者同时消费同一队列中的消息?
RabbitMQ 支持多个消费者同时消费同一个队列中的消息。工作原理是: 生产者发布消息到队列中。 多个消费者… 继续阅读 RabbitMQ中如何实现多消费者同时消费同一队列中的消息?
ActiveMQ 中的死信处理有哪些实现方式?
ActiveMQ 中的死信处理主要有以下几种方式实现: 在目标队列或主题配置死信转发地址:消费者无法消费的消息… 继续阅读 ActiveMQ 中的死信处理有哪些实现方式?
Kafka中的控制器(Controller)是什么?有什么作用?
Kafka 中的控制器(Controller)是一个特殊的 Broker 节点,用于管理 Kafka 集群中的… 继续阅读 Kafka中的控制器(Controller)是什么?有什么作用?
RocketMQ的消息推送性能如何优化?
RocketMQ消息推送性能优化主要从以下几个方面进行: 生产者批量发送:生产者可以将多条消息批量发送到Bro… 继续阅读 RocketMQ的消息推送性能如何优化?
RabbitMQ中如何实现消息的顺序消费?
RabbitMQ 本身不保证消息的顺序消费,但我们可以通过以下方式实现消息的顺序消费: 使用 RabbitMQ… 继续阅读 RabbitMQ中如何实现消息的顺序消费?
ActiveMQ 中如何实现消息的优先级?
ActiveMQ 中消息的优先级主要通过以下几种方式实现:1、 设置消息的 JMSPriority 属性:生产… 继续阅读 ActiveMQ 中如何实现消息的优先级?
RocketMQ的高可用架构是如何实现的?
RocketMQ的高可用架构主要由以下几个组件实现: Broker:Broker是RocketMQ的消息存储和… 继续阅读 RocketMQ的高可用架构是如何实现的?