dubbo中可以适配其它的rpc协议和注册中心,对于有些企业自定义rpc的(我厂目前就是这样,用的非常难受),也可以将其适配到dubbo dubbo中的SPI 先从dubbo...
dubbo中可以适配其它的rpc协议和注册中心,对于有些企业自定义rpc的(我厂目前就是这样,用的非常难受),也可以将其适配到dubbo dubbo中的SPI 先从dubbo...
calcite是一个动态数据管理框架,它提供了SQL解析与校验,SQL优化,jdbc接口等能力,并且能够支持对不同数据源的适配以及对SQL语法的扩展等,目前被广泛用于Spar...
可靠消息与分布式事务 1 概述 前面的文章https://zhuanlan.zhihu.com/p/92866118讲述了Seata对分布式事务的支持,当生产环境中没有sea...
分布式事务DTP模型 DTP模型是Distributed Transaction Processing的缩写,DTP是一套分布式事务的规范,不同的厂商针对此规范提供实现。DT...
RocketMQ消息存储 1 CommitLog 要想知道RocketMQ如何存储消息,我们先看看CommitLog。在RocketMQ中,所有topic的消息都存储在一个称...
RocketMQ事务消息接口介绍 当我们在业务逻辑中发送消息时,消息与业务的事务之间难以保证一致性,如果业务代码出现异常,如果已发送的消息无法回滚,则很会出现数据不一致的情况...
基本原理 RocketMQ的broker会被划分成master和slave两种角色,只有master能接受producer所发送的消息,消息的replication示意图如下...
总体代码 我们可以通过阅读RocketMQ的消息存储代码来了解RocketMQ的消息存储格式,消息的存储入口是DefaultMessageStore,我们可以通过Defaul...
RocketMQ的push模式 我们都知道RocketMQ在消费端有push和pull两种模式,pull模式需要我们手动调用consumer拉消息,而push模式则只需要我们...
Consumer的负载均衡 RocketMQ在消费端的负载均衡如下图所示,各个partition均匀分布在各个consumer上,如下图所示: 所有consumer依次消费每...
Serverless的概念 Serverless是说开发的应用不再需要关心服务器,将应用程序需要的资源当作是一种服务,这使得应用owner能快速的进行应用的迭代,运维变得非常...
Pulsar基本架构 Pulsar采用存储计算分离的架构,pulsar使用了bookkeeper做消息的存储,bookkeeper保证了消息存储的可靠性和高效性,bookke...
Apache Bookkeeper简介 Apache bookkeeper是一个分布式,可扩展,容错(多副本),低延迟的存储系统,其提供了高性能,高吞吐的存储能力。Bookk...
Mybatis在工程中的槽点 工程中的mapper文件往往非常大,动则上千行,最近经常听见周围的同学们吐槽难以维护,还不如写Java代码。 最近就在思考这样一个问题,既然ma...
布隆过滤器 是一个很长的二进制向量和一系列随机映射函数。布隆过滤器可以用于检索一个元素是否在一个集合中。它的优点是空间效率和查询时间都比一般的算法要好的多,缺点是有一定的误识...
文中代码地址:https://github.com/gaohanghbut/groovy-configuration 起因 Springboot支持yml和propertie...
需求与背景 需求 需求比较明确,有个表相对来说比较大,有800多万行的数据,现在需要按天对其做count/sum操作,需要能实时得到结果,需要支持门店、大区、全国等范围的查询...
为什么有时候要避免使用ArrayList 在工程中,经常能看到类似如下代码: final List list1 = ...;final List list2 = ...;...