一、Kafka概述1.Kafka是一个分布式流媒体平台，它有三个关键功能：(1)发布和订阅记录流，类似于消息队列或企业消息传递系统；(2)以容错的持久方式存储记录流；(3)记录发送时处理流。2.Kafka通常应用的两大类应用(1)构建在系统或应用程序之间的可靠获取数据的实时流数据管道；(2)构建转换或响应数据流的实施

学前知道Java的IO使用“流”的概念来表示。IO流涉及到数据源和目的地。流，是从源“流向”目的的数据流。Java将各种数据源和目标之间数据的传输统一抽象为流，通过对流对象的操作来完成I/O功能。输入输出实际都是对内存而言的。数据源可以是键盘、文件、应用程序、鼠标、网络连接。

Stream流Java8API添加了一种新的机制——Stream（流）。Stream和IO流不是一回事。流式思想：像生产流水线一样，一个操作接一个操作。使用Stream流的步骤：数据源→转换成流→操作1→操作2→……数据源（source）：可以是集合、数组等。St

IO流框架!IO框架(https://oscimg.oschina.net/oscnet/d6baa9ffd0adc3ecffd9fef90e48936437f.png)IO流概述IO即输入与输出,Java把不同来源和目标的数据抽象为流,在此基础上对流进行数据操作IO流分类按流向分：

    GB28181国检有一向内容是实时播放摄像机流，经过一番努力，搞定这个功能，现分享心得：首先需要了解流程，说简答点就是视频流从哪里来到什么地方去，下图描述了视频流推流，转发的基本过程:信令交互成功以后，摄像机（媒体流发送者）推送流到媒体服务器，媒体服务器在指定的端口接收到视频流后，转发给流媒体接收者（例如某台PC的某个空闲端口）。 

Java流操作有关的类或接口：!(http://static.oschina.net/uploads/img/201408/07180414_8pxV.png)Java流类图结构：!(http://static.oschina.net/uploads/img/201408/07180414_5xgf.jpg)流的概念和作用

节前略闲，看了java8并行流，写个了wordCount。本以为易如反掌，结果却折腾了一下午!在本文中wordcount是指以空格作为词的分割符号，统计一个语句中出现的词数如何用java8并行流写WordCount，我开始的想法是先写个串行流的workcount，之后stream.parallel()将流并行化。串行流的wordCout，也

工作流引擎  个人觉得直接理解工作流引擎概念有点难度，我们可以先通过了解工作流引擎的职责再反过来理解工作流引擎，工作流引擎一般都做两件事情：1.定义流程，也就是给我们提供某种规范来定义规则，以及如何定义一个流程的这种规范，同事我们可以根据工作流引擎提供的相关概念来定义更为复杂的流程，这就是工作流引擎做的第一件事叫做定义流程。2

事件JS与HTML的交互是通过事件实现的而事件指的就是：文档或浏览器窗口特定的交互瞬间可以通过侦听器来预定事件，以便在事件发生时执行相应的代码这种模式也是设计模式中的观察者模式事件流有了事件，也就有了事件流的概念事件流故名思意：也就是事件的流向，所以事件流描述的是从页面中接收事件的顺序虽然事件流描述的都是事件的流