一、什么是Stream类

• 原始的集合数据类似于数据的输入
• 流式处理是对输入数据进行处理
• 处理后的数据进行汇集类似于数据输出

Stream像一个流水线作业，主要分成流水线处理和最终的汇集聚合，其作用对象是集合数据

• 流式处理(stream相关方法)
• 数据汇集(collect方法)

二、Stream类主要作用

对集合数据进行以下处理：

• 查找
• 筛选过滤
• 计算
• 组合
• 排序
• 匹配

三、Stream类主要方法

• 定义一个供

一、什么是方法引用

1.什么是方法引用

• 直接访问类或者实例的已经存在的方法或者构造方法。
• 方法引用提供了一种引用而不执行方法的方式，它需要由兼容的函数式接口构成的目标类型上下文。
• 计算时，方法引用会创建函数式接口的一个实例

2.方法引用的格式

• 实例对象::方法名
• 类名::方法名

二、方法引用的形式

方法引用主要与stream流处理一起使用，实现数据的筛选过滤等

1.构造方法引用

形式为 ClassName::

一、Lambda表达式

1.什么是lambda表达式

lambda表达式是一种匿名函数表达式

2.lambda表达式语法

• 无参 : ()-> expression
• 有参 ：(parameters)-> {statement;}

/**
 * 定义一个标签tag类
 */
class Tag {
    private int tagId;
    private String tagName;
    

Java8是一个长期支持版，有很多的特性值得去学习和研究。其特性主要有：

• 1.lambda表达式
• 2.接口默认方法和静态方法
• 3.方法引用
• 4.Stream流处理
• 5.Optional
• 6.新的日期时间API

具体细节如下图：

一、Zookeeper集群环境搭建

请参考zookeeper集群搭建

二、kafka集群环境搭建

1.集群环境说明

注：以上3台服务器都是CentOS 7.x系统

2.在各节点上下载并安装kafka

wget http://mirro

注：本kafka系列文章是以2.x版本为例

一、kafka的概念和基本功能

1.什么是kafka

kafka是一个分布式的流处理平台，处理和管理数据流向的平台(消息队列只是其中一个功能)。它是由LinkedIn公司通过Scala语言开发，并捐献给Apache基金会的一个开源软件。

2.kafka的基本功能：

• 消息系统：有发布订阅功能的消息队列，此功能与ActiveMQ、RibbitMQ、Rocket

一、安装Zookeeper

请参考:zookeeper简单用法之zookeeper安装部署

二、集群配置

1.集群环境说明

注：以上3台服务器都是CentOS 7.x系统

2.三个节点分别建立日志和数据文件目录

注：zookeeper安

一、什么是JDBC

JDBC即Java DataBase Connective，是由JAVA提供的一组成平台无关的数据库操作标准。通过这个规范，各数据库服务商实现各自的驱动，用来管理和操作数据库。

二、使用JDBC操作数据库

1.JDBC操作数据库的主要步骤

• (1)加载数据库驱动
• (2)建立数据库连接
• (3)预备需要执行的SQL语句
• (4)执行SQL语句并获取结果，对结果进行处理
• (5)释放资源(关闭连接)

一、什么是异常

1.异常的概念

所谓异常就是没有达到程序预期的结果。

2.异常与错误

• 错误：虚拟机等相关的错误，开发人员无法在程序中做预处理
• 异常：开发人员可以根据不同的异常类型设定一些处理方案

3.java中的异常体系

• Error : 错误类
• Exception : 异常类(开发中重点关注的地方)

二、Java异常处理机制

1.异常捕获及处理

• try : 表示可能出现问题的代码块，也是被捕获的代码段(

一、什么是IO

1.IO概念

• I:input,即输入
• O:output,即输出

所谓IO就是数据流的从一个媒介到另外一个媒介的流动过程

• 应用程序将设备1中的内容读取出来存入到内存中
• 再将内存中的数据输出到设备2中

2.IO的分类

二、JAVA中的文件处理

文件操作主要以以下几个类：

• 文件本身:文件名等操作
  • File
• 文件内容：文件内容的读写
  • 字节流:对二进制文件
    • InputStream
    • OutputS