CAT是一款基于JAVA的分布式监控系统,其全称为Central Application Tracking

一、CAT的简要介绍

1.CAT的主要组成部分

(1) 服务端

• cat-consumer : 实时分析从客户端提供的数据
• cat-home : 展示数据分析结果的控制端

(2) 客户端

• cat-client : 数据埋点

2.CAT支持的监控消息类型

(1).Transaction : 记录跨越系统

一、Sentinel是什么

1.什么是Sentinel

Sentinel是阿里巴巴公司开源的面向分布式环境的轻量级流量控制框架

2.主要功能

Sentinel是以流量为切入点，通过多个维度来保护服务和维持系统稳定性的工具

(1)流量控制

用于调整网络包的发送数据,Sentinel相当于一个调配器:

• 将随机的请求变成顺序的请求
• 将不同格式的请求格式化为统一的格式的请求

流量控制可以从以下几个角度来说明

一、消息系统模块说明

• common : 公共模块(一般放到maven私服中，供生产者和消费者加载)
• producer :　生产者服务(一般单独部署，依赖common包)
• consumer:　消费者服务(一般单独部署，依赖common包)

本文通过一个用户注册的案例来介绍spring与kafka客户端集成的技术实现

• 用户注册：
  • 插入数据库等操作
  • 发送用户注册消息(生产者)，其他相关事务在用户注册后，发

在java中操作kafka，可以通过kafka-clients或者使用spring-kafka来实现．

本文简要说明一下spring-kafka的使用，通过下面一张图概览spring-kafka的使用

一、生产者　

1.kafka生产者的初始化

• kafka生产者主要通过KafkaTemplate对象来进行消息方面的操作
  • KafkaTemplate对象又是通过ProducerFactory对象来构造

单元测试代码一般放在src/test目录下，与src/main结构基本一致

一、添加测试依赖包

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <sc

一、broker主要配置

1.broker自身属性的配置

2.连接的zookeeper相关配置

一张图概括kafka主要脚本的用法:

一、主题管理　

主题topic的管理主要通过kafka-topics.sh这个脚本进行操作

1.创建主题

./kafka-topics.sh --create --zookeeper <host:port> --topic <topicName> --partitions <partitionsNum> --replicati

一张图来概括新的日期时间API知识点

一、日期LocalDate

1.创建日期对象

(1)of:通过指定的年月日来构建日期对象

• of (int year, int month, int day)
  • year : 年(整型 -999,999,999至999,999,999)
  • month : 月(整型 1-12)
  • day : 日(1-31)
• of (int year, Month month, int day

Collectors是stream流处理最后一个环节collect的工具类，主要用于最后对汇集数据的处理，如将流处理结果存储为某种集合类型以及对结果进行分组、筛选、计算等操作.其主要功能如下：

本节内容还是以中奖记录对象来例：

/**
 * 中奖记录
 * @author shixinke
 * @date 2019-1-25
 */
class AwardRecord {
    /**
     * 记录I

在JAVA中实现对象的排序可以使用Comparable接口，也可以使用Comparator接口．

• Comparable : 需要自己实现比较的方法compareTo，是一个内部排序器
• Comparator : 可以使用其默认的方法和lambda表达式来实现排序，是一个外部排序器，更像一个工具接口

一、Comparable接口

• 表明实现的对象是一个可排序的类

1.一个需要排序的类，需要实现Compa