在使用mybatis进行数据批量新增的时候，有时候数据过大时需要进行分批处理。这个时候就需要一些特殊的处理了，不多说，直接上代码public void saveTemp(List<AddressBookDepartmentAllSyncTemp> allSyncTemps) {baseMapper.deleteTempTable();i...

在使用mybatis进行数据批量新增的时候，有时候数据过大时需要进行分批处理。这个时候就需要一些特殊的处理了，不多说，直接上代码public void saveTemp(List<AddressBookDepartmentAllSyncTemp> allSyncTemps) {baseMapper.deleteTempTable();i...

序本文主要研究下spring.cloud.gateway.default-filters配置{"sourceType": "org.springframework.cloud.gateway.config.GatewayProperties","name": "spring.cloud.gateway.default-filte

在最近的项目中需要在一个微服务里面同时连接俩个数据库一个mysql 一个oracle，当时心里在想不就是多数据源嘛 简单！唰唰的就写好了配置如下spring:datasource:druid:first:driver-class-name: com.mysql.cj.jdbc.Driverpassword: ${spring....

最近因为项目需要所以需要使用kafka 所以自己最近也实践了下。下面为大家简单介绍下在windows下的安装使用因为它是基于zookepper的使用也要安装zookepper1.安装ZookeeperKafka的运行依赖于Zookeeper，所以在运行Kafka之前我们需要安装并运行Zookeeper1.1 下载安装文件： http://mirror.bit.edu.cn/apache...

问题：为什么使用消息队列啊？消息队列有什么优点和缺点啊？kafka、activemq、rabbitmq、rocketmq都有什么区别以及适合哪些场景？1.为什么使用消息队列啊？通用回答是：我们公司有个什么业务场景，这个业务场景有个什么技术挑战，如果不用MQ可能会很麻烦，但是你现在用了MQ之后带给了你很多的好处。比较核心的有3个业务场景：解耦、异步、削峰解耦：现场画个图来说明一下，...

因为项目的原因需要用到POI来操作Excel 文档，以前都是直接使用POI来操作的，但是最近听到easypoi的存在，所以自己简单的尝试了下！ 别说，他还真的挺好用的Easypoi介绍Easypoi 为谁而开发不太熟悉poi的不想写太多重复太多的只是简单的导入导出的喜欢使用模板的都可以使用easypoiEasypoi的目标是什么 Easypoi的目标不是替代poi,而...

一、FlinkX简介FlinkX是一个基于Flink的批流统一的数据同步工具，既可以采集静态的数据，比如MySQL，HDFS等，也可以采集实时变化的数据，比如MySQL binlog，Kafka等。FlinkX目前包含下面这些特性：● 大部分插件支持并发读写数据，可以大幅度提高读写速度；● 部分插件支持失败恢复的功能，可以从失败的位置恢复任务，节约运行时间；失败恢复● 关系数据库的Reader插件

Flink是新一代的流处理计算引擎。通过轻量级的checkpoint，Flink可以在高吞吐量的情况下保证exactly-once(这需要数据源能够提供回溯消费的能力)。Flink支持众多的source(从中读取数据)和sink（向其写入数据），列表如下：Kafka作为目前非常流行的消息中间件，它不仅能够提供极大的吞吐量，还能够配合Flink在消费端达到exactly-once。本文将详细介绍如何