开源实现：https://github.com/keedio/flume-ng-sql-source 这里记录的是自己手动实现。 测试中要读取的表 记录表（必须），告诉 Flume 每次从哪开始读取 一、编写自定义 Source 1.添加 pom 依赖 2.编写类 MySQLSourceHelper ...
分类：
数据库 时间：
2019-09-29 19:58:38
阅读次数：
141
axios是一个基于Promise 用于浏览器和 nodejs 的 HTTP 客户端，它可以在浏览器和node环境下运行，在github上已经有六七万个星了，axios使用很方便，很多人在使用他,vue官方也推荐使用axios了，技术这东西还是随主流吧，大家都用肯定有它的特长所在。 axios现在最 ...
分类：
移动开发 时间：
2019-09-29 13:14:43
阅读次数：
108
Eureka 系列（02）客户端源码分析 [TOC] 在上一篇 "Eureka 系列（01）最简使用姿态" 中对 Eureka 的简单用法做了一个讲解，本节分析一下 EurekaClient 的实现 DiscoveryClient。本文的源码是基于 Eureka 1.9.8。 1）服务注册（发送注册 ...
分类：
其他好文 时间：
2019-09-29 09:49:24
阅读次数：
1017
Source 是负责接收数据到 Flume Agent 的组件。 Source 组件可以处理各种类型、各种格式的日志数据，包括 avro、thrift、exec、jms、spooling directory、netcat、sequence generator、syslog、http、legacy。 ...
分类：
Web程序 时间：
2019-09-28 23:44:45
阅读次数：
140
1、Local() 作用：为每个协程或线程创建一个独立的内存空间 储存格式： 代码 2、LocalStack() 作用：通过栈操作local中的列表，列表中可以储存对象 代码 3、上下文源码分析(request session) ...
分类：
其他好文 时间：
2019-09-28 23:13:27
阅读次数：
103
flume 三大组件 source 收集 channel 聚集 sink 输出 使用Flume关键就是写配置文件 A 配置source B 配置channel C 配置sink D 把以上3个组件串起来 1.通过IP端口 接收数据 启动agent flume-ng agent \ --name a1 ...
分类：
Web程序 时间：
2019-09-28 23:11:36
阅读次数：
122
这里会介绍：
1. Sentinel会使用多线程的方式实现一个类Reactor的IO模型
2. Sentinel会使用心跳检测来观察控制台是否正常 ...
分类：
其他好文 时间：
2019-09-28 00:56:27
阅读次数：
115
在我们XxlJobScheduler类中，会启动一个失败任务监控线程，本文就来分析JobFailMonitorHelper这个类 ...
分类：
其他好文 时间：
2019-09-27 15:03:16
阅读次数：
350
Flume-1 监控文件 /tmp/tomcat.log。 Flume-2 监控某一个端口的数据流。 Flume-1 与 Flume-2 将数据发送给 Flume-3，Flume-3 将最终数据打印到控制台。 一、创建配置文件 1.flume1-logger-flume.conf 配置 Source ...
分类：
Web程序 时间：
2019-09-27 01:54:48
阅读次数：
154
[toc] HashMap是什么? Map是Java常用的一种存储数据的Key Value结构, 键值对 HashMap是Map结构, 底层采用Hash算法存取Key值 HashMap: 基于哈希表的 Map 接口的实现. 1. 此实现提供所有可选的映射操作, 并允许使用 null 值和 null ...
分类：
编程语言 时间：
2019-09-26 00:36:22
阅读次数：
91
