注：本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

一、什么是正则表达式

1.何为正则表达式

正则表达式就是一种使用模式匹配规则来实现字符串查找、匹配、替换、分割的技术，主要用来规则匹配和验证等。

2.正则表达式的组成

• (1)规则表达式：用于匹配的规则

• (2)模式修饰符：对于规则进行修饰，是一种附加功能

二、正则表达式的规则

基本可以分为两类：

• 普通字符：没有特殊含义的字符
• 特殊字符：具有特殊含义的字符，也叫元字符，用来描述规则的字符

三、JAV

一、注解的概念及作用

1.什么是注解

源代码中元数据的一种标记，注解本质上是一个继承自Annotation的类(一般通过反射的方式实现具体的功能)

2.注解的作用

• 生成文档，根据文档注解，可以生成java文档
• 追踪代码依赖性，实现替代配置文件功能(最主要的功能)
• 在编译时进行格式检查，告知编译器哪些代码需要检查

二、注解的分类

1.按来源分

(1)JDK注解

第一种：元注解

元注解就是用来定义注解的注解

• @

一、泛型及其作用

1.没有泛型的情况下，定义一个数组列表

package main.java.com.shixinke.java.demo.generic;
/**
 * 定义一个整型的数组列表
 */
class MyIntList {
    private Integer[] elements;
    private int size;
    public MyIntList(int capacity)

一、反射类的概念及作用

1.什么是反射类

动态获取类或者对象的信息(属性和方法)，以及动态操作对象的属性和方法的类，动态分析和使用类的信息的类

注：动态是指在java运行状态

2.反射类的作用

• 动态获取：动态获取类或对象的属性和方法
• 动态调用：动态调用对象的属性和方法

3.反射的使用场景

• 操作因访问权限限制的属性和方法；
• 实现自定义注解；
• 动态加载第三方jar包
• 按需加载类，节省编译和初始化时间；

二、反射

一、字符串类构造函数

1.通过一个字符串来构造字符串对象

String c = new String("book");

2.通过一个byte数组或char数组来构造一个字符串

byte[] bs = new byte[]{1, 2, 3};
String d = new String(bs);
System.out.println(d);   //

char[] cs = new char[]{'a'