关于RocketMQ的详细图表,包含了Producer、Consumer、Broker和NameServer等关键组件,展示了消息流动的过程。
ZMQ(ZeroMQ)是一种高性能的异步消息传递库,它可以在不同的进程和机器之间进行消息传递。它提供了多种传输协议、通信模式和编程语言支持,并且非常易于使用。...
Apache ActiveMQ,作为一款开源的消息中间件,广泛应用于Java平台,为分布式系统提供了高效、可靠的消息传递服务。它实现了Java消息服务(JMS)规范,支持多种消息协议,如AMQP、MQTT等。本文旨在快速概述ActiveMQ的核心功能、常见...
我知道,很多大佬看不起外包,觉得外包一无是处。但实际上,家庭出身、教育资源、学习天赋,决定了一部分小伙伴只能通过外包的形式先上岸。
幂等来源于数学概念,幂等元素被重复运算多次,依旧等于自己,即f(f(x)) = f(x); 程序世界里对于幂等,有一个很常见的描述是:对于相同的请求应该返回相同的结果,所以查询类接口是天然的幂等性接口。但是这里有个悖论,如果一个查...
比如,我们的kafka,每一条消息都有一个offset,唯一标识这个条消息,默认情况下,消费者在消费完消息之后,然后在提交这个offset,消费者更才会认为消息被消费了,但是,我说的是但是,在消费这个提交offset此刻,我们的消费者重启了...
prepare:将消息(消息上带有事务标识)投递到一个名为RMS_SYS_TRANS_HALF_TOPIC的topic中, 而不是投递到真正的topic中。
Consumer Group:消费者组,消费者组内每个消费者负责消费不同分区的数据,提高消费能力。逻辑上的一个订阅者。
append的方式写文件,会根据大小自动生成新的文件,rabbitmq启动时会创建两个进程,一个负责持久化消息的存储,另一个负责非持久化消息的存储(内存不够时)...
ActiveMQ:JMS规范,支持事务、支持XA协议,没有生产大规模支撑场景、官方维护越来越少