前言 从网上看到的另一句话，webrtc中的信号槽像是变种的观察者模式，当有信号发送的时候，信号发送者通过遍历自己的所有connect的信号槽，然后执行他们的回调；起初会有为什么需要信号槽 信号槽与普通的函数回调有什么区别的疑问, 个人认为信号槽是一种面向对象的回调，当回调涉及到对象，需要考虑到执行 ...
分类：
Web程序 时间：
2020-01-14 09:48:26
阅读次数：
94
创建a2.conf文件并且编写 Sources 类型是exec 配置文件如下 启动集群 启动flume 产生临时文件 ...tmp 关闭临时文件 再次写入文本，会再次产生一个临时文件。截图左边是一个内容输入和时间对照 从时间上看出大概是30s会关闭这个文件。 在hdfs 上查看内容 以上根据自己的理 ...
分类：
Web程序 时间：
2020-01-10 16:01:33
阅读次数：
111
系统架构介绍 整个实时监控系统的架构是先由 Flume 收集服务器产生的日志 Log 和前端埋点数据, 然后实时把这些信息发送到 Kafka 分布式发布订阅消息系统，接着由 Spark Streaming 消费 Kafka 中的消息，同时消费记录由 Zookeeper 集群统一管理，这样即使 Kaf ...
分类：
其他好文 时间：
2020-01-07 11:44:25
阅读次数：
100
Flume采集的控制台提示：The channel is full or unexpected failure. The source will try again after 1000 ms 这个是因为当前被采集的文件过大，深层的原因是文件采集的速度和sink的速度没有匹配好。所以应该可以通过增大 ...
分类：
其他好文 时间：
2019-12-28 22:41:20
阅读次数：
335
1）Source中使用拦截器 kafka_key.sources.sources1.interceptors = i1kafka_key.sources.sources1.interceptors.i1.type = com.bigdata.flume.MyInterceptor$Builder k ...
分类：
Web程序 时间：
2019-12-28 22:35:37
阅读次数：
181
CountDownLatch是JUC包中提供的线程同步工具，使用CountDownLatch可以实现一个或多个线程等待直到一组操作在其他线程中被执行完成。
分类：
其他好文 时间：
2019-12-26 16:21:43
阅读次数：
99
分析客户端代码 通过jeb打开apk获知，核心通信包使用的是mtop sdk，普通抓包工具charles、findler无法捕获相应包的根本原因在于，其采用了网络加载速度表现更卓越的SPDY协议，因此，需要阻止其使用该协议，才能抓包。 代码实现 只需让sdk的全局配置中执行下面这行代码即可： 抓包效 ...
分类：
移动开发 时间：
2019-12-24 11:50:16
阅读次数：
380
Flume和 Sqoop Sqoop简介 Sqoop是一种旨在有效地在Apache Hadoop和诸如关系数据库等结构化数据存储之间传输大量数据的工具 原理: 将导入或导出命令翻译成Mapreduce程序来实现。 在翻译出的Mapreduce中主要是对InputFormat和OutputFormat ...
分类：
Web程序 时间：
2019-12-21 22:39:42
阅读次数：
187
说明： 操作系统：CentOS 5.X 64位 MySQL版本：mysql 5.5.35 MySQL配置文件：/etc/my.cnf MySQL 数据库存放目录：/data/mysql 实现目的：开启MySQL慢查询日志功能，安装使用MySQL慢查询分析mysqlsla 具体操作： 一、开启MySQ ...
分类：
数据库 时间：
2019-12-21 18:28:54
阅读次数：
114
大数据由一系列技术组成，那他们之间的关系是怎么组成的ne，请看下图： hadoop主要做了文件存储系统和提供了一个相对比较弱的mr处理数据的方案 hive是在mr和文件存储系统上面做的升级。 sprak+hbase+hadoop主要解决的是hadoop实时处理数据比较弱的问题 ...
分类：
Web程序 时间：
2019-12-08 10:27:19
阅读次数：
116
