[TOC] 简介 kafka是一个分布式消息队列。具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息,消费者从队列里取消息进行业务逻辑。一般在架构设计中起到解...
[TOC] 简介 kafka是一个分布式消息队列。具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息,消费者从队列里取消息进行业务逻辑。一般在架构设计中起到解...
我这个文章是spark2.0的,新的版本可能key不一样,你去官网查查看
Spark JDBC系列--取数的四种方式本文旨在介绍 Spark 通过JDBC读取数据库数据的四种API 调用前准备 对于不同的数据库,需要在spark的环境中添加对应的driver包,如: Oracle: MyS...
摘要 本文以MySQL数据库为研究对象,讨论与数据库索引相关的一些话题。特别需要说明的是,MySQL支持诸多存储引擎,而各种存储引擎对索引的支持也各不相同,因此MySQL数据...
1. 概述 ConcurrentHashMap是JDK提供的一种线程安全的HashMap实现,JDK1.8对ConcurrentHashMap进行了大量优化,除了增加了函数式...
canal是阿里巴巴旗下的一款开源项目,纯Java开发。基于数据库增量日志解析,提供增量数据订阅&消费,目前主要支持了MySQL(也支持mariaDB)。 背景 早期,阿里巴...
原题可以在 LeetCode 上找到,地址:Median of Two Sorted Arrays,难度级别为困难。 不要被困难级别唬到,看完这篇文章,相信你也可以做出来。 ...
0 前言 在并发编程中,需要解决两个关键问题: 线程之间如何通信;线程之间如何同步; 线程通信是指线程之间以何种机制来交换信息。在命令式编程中,线程之间的通信机制有两种:共享...
0 前言 记得开始学习Java的时候,一遇到多线程情况就使用synchronized,相对于当时的我们来说synchronized是这么的神奇而又强大,那个时候我们赋予它一个...
作者: 一字马胡 转载标志 【2018-01-02】 更新日志 前言 本文是Spring源码分析系列的第三篇文章,前两篇文章分别分析总结了Spring bean的解析以及b...
0 介绍 使用 Instrumentation,使得开发者可以构建一个独立于应用程序的代理程序(Agent),用来监测和协助运行在 JVM 上的程序,甚至能够替换和修改某些类...
概述 这篇博文的起源在于阿里的公众号里面有一篇文章讲菜鸟的同学在造一个关于时间轮定时器的文章,然后在网上搜索资料发现其实在好多开源的软件里面已经有了,最后选择了kafka...
1.SPI-ServiceLoader 1.1简介 原文:"A simple service-provider loading facility."解释:可以加载指定接口的实...
1.ChaosBlade简介 ChaosBlade 是一款遵循混沌工程实验原理,提供丰富故障场景实现,帮助分布式系统提升容错性和可恢复性的混沌工程工具,可实现底层故障的注入,...