在项目里面实现分布式事务，我们常用的一般有集中模式，分别是：AT模式，TCC模式，Saga模式。下面分别介绍下对应的业务场景。一、AT模式AT模式其实就是一个二阶段提交的模型，使用AT模式的时候，分布式数据库中，我们...

之前我们讲解了使用tiny_id获取唯一id的方法，这篇我们介绍下使用雪花算法生成唯一id。不多说，直接上代码package com.gy.bigdatainterfacept.sync.utils; /** * T...

在大型的项目中，我们一般都知道不能直接使用数据库的自增id，所以衍生了很多唯一id的生成方案，例如：生成uuid，或者现在流行的雪花算法id，还有数据库发号id等模式。由于我们线上的接口平台每日上百万，千万的数据采集...

大家在做java开发的时候，线上运行出问题的话，我们会经常涉及到jvm的调试。这篇文章列举下常用的jvm调优所涉及到的参数信息。具体如下：堆设置 -Xms :初始堆大小 -Xmx :最大堆大小 -XX:NewSize...

最近项目上的业务有这样的需求，需要把mysql做一份异地多活，主要防止数据库出现异常稻城线上业务挂掉，所以需要做一个mysql备份，方便切换。所以在这里我们肯定考虑的第一方案就是cdc同步。我们都知道cdc同步mys...

承接上篇《Flink学习系列（八）flink的transform介绍》。之前的文章我们已经介绍过了flink的一些简单应用，从这篇开始，我们会开始介绍一些flink的进阶知识点。本篇我们介绍下flink的cdc操作。...

承接上篇《Flink学习系列（六）介绍下flink的sink》。这篇我们自定义的实现一个mysql的sink。这里我们还是使用之前的user表。1）、创建一个mysqlsink类package com.big.dat...

承接上篇《Flink学习系列（五）如何自定义实现一个flink的connector》。前几篇文章我们介绍了flink的datasource。我们介绍过flink是一个分布式计算处理框架。他重在的是计算。但是他又需要依...

承接上篇《Flink学习系列（四）flink的datasource之自定义mysql的connector》。我们在实际的生产业务中，有时候我们读取的数据源是没有现成的connector连接器的，那么我们又需要读取到对...

承接上一篇《Flink学习系列（二）flink是什么》。这篇文章我们讲解下flink的Datasource。一、什么是flink的datasource我们在前面介绍了flink是一个分布式的数据处理框架，那么既然是一...

承接上篇《Flink学习系列（一）wordcount》。我们先写了一个demo，运行了一下flink程序，然后我们看到了flink运行起来是一个什么样子。这篇文章我们就介绍下flink具体是什么。一、flink是什么...

在学习flink的时候，大家一般会先去查下资料了解下flink是一个什么东西。但是对于我的了解来说，我一般会先看看这项技术是一个什么东西，能实现什么效果，然后再逐渐推进对应的学习上。由于我这边已经了解Flink了，所...