socketserver模块使用与源码分析 前言 在前面的学习中我们其实已经可以通过socket模块来建立我们的服务端，并且还介绍了关于TCP协议的粘包问题。但是还有一个非常大的问题就是我们所编写的Server端是不支持并发性服务的，在我们之前的代码中只能加入一个通信循环来进行排队式的单窗口一对一服 ...
分类：
其他好文 时间：
2020-06-29 09:36:03
阅读次数：
54
#初始化过程 构造 bean 依赖注入（接下来才是初始化过程） 获取容器中所有的 BeanPostProcessor，执行其 postProcessBeforeInitialization 方法（@PostConstruct注解指定的初始化方法，就是在这一步由 CommonAnnotationBea ...
分类：
编程语言 时间：
2020-06-29 00:35:35
阅读次数：
81
一、概述 1.Flume是Apache提供的开源的、分布式的、可靠的日志收集系统 2.能够有效的收集、聚合、传输大量的日志数据 3.flume有2个版本：flume-og(flume09x)和flume-ng(flume1.x)，flume-og和flume-ng不兼容 二、基本概念 1.Event ...
分类：
Web程序 时间：
2020-06-28 15:19:31
阅读次数：
62
JDK1.8源码分析项目（中文注释）Github地址：https://github.com/yuanmabiji/jdk1.8-sourcecode-blogs1Future是什么？先举个例子，我们平时网购买东西，下单后会生成一个订单号，然后商家会根据这个订单号发货，发货后又有一个快递单号，然后快递公司就会根据这个快递单号将网购东西快递给我们。在这一过程中，这一系列的单号都是我们收货的重要凭证。因
分类：
编程语言 时间：
2020-06-28 11:10:20
阅读次数：
74
第一层Flume 从 source-> KAFKA .[kafka作为channel] 1.安装的 Flume是1.7的版本 安装略 日志文件分为两种一种是启动日志，一种是事件日志. 通过selector选择器把这两个日志分开，并且过滤一些空数据. 我们先写选择器吧. 1. 建立一个工程. mave ...
分类：
Web程序 时间：
2020-06-28 00:08:11
阅读次数：
135
一、简介 Apache Flume 是一个分布式，高可用的数据收集系统，可以从不同的数据源收集数据，经过聚合后发送到分布式计算框架或者存储系统中。Spark Straming 提供了以下两种方式用于 Flume 的整合。 二、推送式方法 在推送式方法 (Flume-style Push-based ...
分类：
Web程序 时间：
2020-06-27 00:19:37
阅读次数：
77
需求：采集8类日志数据，并且进入es展示： 方案制定：目前数据采集通用flume+kafka模式，所以采用原有模式，一类服务进入一个topic，然后通过logstash进行数据清洗，最后进入es进行展示。 flume采用tadir 读取数据源，memory 进行缓存，kafka进行sink a1.s ...
分类：
Web程序 时间：
2020-06-26 22:29:32
阅读次数：
81
一、整体说明 tomcat需要完成两件事情： 接受外部HTTP请求 加载servlet，并且把请求传给Servlet进行处理。 整体可以抽象为如下： 二、整体代码架构 在tomcat的代码中抽象了以下三个类： Server类，代表tomcat实例 Connector类，代表HTTP监听器（上图中的H ...
分类：
其他好文 时间：
2020-06-26 18:35:49
阅读次数：
54
Vuex作为Vue的核心无人不知无人不晓，都知道Vuex 是一个专为 Vue.js 应用程序开发的状态管理模式，也知道当我们的应用遇到多个组件共享状态时，单向数据流的简洁性很容易被破坏，多个视图依赖于同一状态，来自不同视图的行为需要变更同一状态的时候要用到vuex，可是vuex实现的原理是什么啊？一 ...
分类：
其他好文 时间：
2020-06-26 14:19:07
阅读次数：
89
JDK1.8源码分析项目（中文注释）Github地址： https://github.com/yuanmabiji/jdk1.8-sourcecode-blogs 1 Future是什么？ 先举个例子，我们平时网购买东西，下单后会生成一个订单号，然后商家会根据这个订单号发货，发货后又有一个快递单号， ...
分类：
编程语言 时间：
2020-06-26 12:52:42
阅读次数：
63
