使用Redisson提供的RDelayedQueue接口。好处: 性能好,基于redis。 支持分布式服务。 不需要轮询。 RedissonDe...
假设初始跳表结构为: 一、查询过程 假如要查找 50。步骤 1:从顶层开始从最高层(Level 3)的 HEAD 开始。 在这一层中,我们发现下...
kafka如何保证顺序消费 想要顺序消费的业务消息使用相同的key。这些具有相同key的消息会被发往同一个分区,kafka能保证同一个分区内的消...
这篇文章讲的很详细很好:一文搞懂 kafka consumer 与 broker 交互机制与原理[https://www.automq.com/...
raft算法保证集群元数据的一致性。 保证cap中的cp,当发生严重的网络分区后,放弃可用性。 raft算法流程:所有跟随者(follower)...
前提:kafka使用默认的配置。 生产者初始化:生产者初始化后,向集群中任一broker请求元数据(配置、主题、分区leader等),并将元数据...
三次握手 tcp三次握手目的是确认双方的初始序列号(ISN,Initial Sequence Number)。 序列号按字节累加。其作用是: 数...
脏读 (Dirty Read):脏读发生在一个事务读取了另一个事务尚未提交的数据。如果那个事务回滚,读取的数据就会变得不准确或错误。例如,事务 ...
Java能使得线程阻塞的基础工具(其余能阻塞线程的方法都是基于它们的)有4种: synchronized关键字控制对资源的同步访问,如果另一个线...