java分布式项目之使用雪花算法生成唯一id
之前我们讲解了使用tiny_id获取唯一id的方法,这篇我们介绍下使用雪花算法生成唯一id。不多说,直接上代码package com.gy.bigdatainterfacept.sync.utils; /** * T...
之前我们讲解了使用tiny_id获取唯一id的方法,这篇我们介绍下使用雪花算法生成唯一id。不多说,直接上代码package com.gy.bigdatainterfacept.sync.utils; /** * T...
在前面我们提到分布式事务他有很多种,但是在实际工作中,我们使用分布式事务框架比较多的就是TCC这种模式,因为使用此框架,各重要的流程和步骤对开发者都是透明的。开发者可以完全自定义对应的步骤。所以本篇文章主要介绍Hmi...
在大型的项目中,我们一般都知道不能直接使用数据库的自增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的mysqlsink》。我们介绍了flink是一个分布式计算框架。在之前我们介绍了flink的datasource和flink的sink。目前还剩下的就是fl...
承接上篇《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的datasource介绍》。我们介绍了一些常见的flink的datasource,由于像mysql这种没有线程的connector使用,所以我们需要自定义去实现一个mys...
承接上一篇《Flink学习系列(二)flink是什么》。这篇文章我们讲解下flink的Datasource。一、什么是flink的datasource我们在前面介绍了flink是一个分布式的数据处理框架,那么既然是一...
承接上篇《Flink学习系列(一)wordcount》。我们先写了一个demo,运行了一下flink程序,然后我们看到了flink运行起来是一个什么样子。这篇文章我们就介绍下flink具体是什么。一、flink是什么...
在学习flink的时候,大家一般会先去查下资料了解下flink是一个什么东西。但是对于我的了解来说,我一般会先看看这项技术是一个什么东西,能实现什么效果,然后再逐渐推进对应的学习上。由于我这边已经了解Flink了,所...
这里写一个kafka生产者的代码示例,方便后期拿来即可使用。1、pom.xml中引入kafka的依赖
Copyright2025智汇技术版权所有. 安全运行天
智汇技术,IT学习的宝藏之地!汇聚专业教程与实战分享,让技术学习不再孤单。无论你是编程小白还是资深开发者,这里都有你想要的知识盛宴。点击智汇技术,探索IT技术学习最新文章,与万千技术爱好者共成长,让技能升级触手可及!
蜀ICP备2024054923号-1 运行时长:0.192秒查询信息:11 次
