【转载】03.Quartz触发器
【转载】03.Quartz触发器概述我们先回顾下Quartz API核心接口Scheduler：(调度器)与scheduler交互的主要API；Job：(作业)你通过scheduler执行任务，你的任务类需要实现的接口；JobDetail：(作业实例)定义Job的实例；Trigger：(触发器)触发Job的执行；JobBuilder：定义和创建JobDetail实例的接口;TriggerBuilder：定义和创建Trigger实例的接口；类似于 Job，Trigger 也非常容易使用，但是它包含了大量的自定义选项，你需要了解它们才能完全使用 Quartz。并且，Trigger 本身有很多...
02.Quartz入门案例
02.Quartz入门案例前言Quartz官方文档还是比较详细的，大家也可以直接参考官网提供的入门案例：http://www.quartz-scheduler.org/documentation/2.3.2-SNAPSHOT/quick-start-guide.html一、开发步骤引入Maven依赖，本次使用的是创建Job，被执行的内容。必须有一个实现了Job接口的类作为参数，实现该接口就是为了后面调用其实现的execute()方法。和线程的run方法类似(恰巧，线程实现Runnable接口，也叫任务task)；创建trigger。时间触发了事情的执行；创建sheduler。一定要有谁来...
01.Quartz介绍
01.Quartz介绍一、Quartz概述Quartz是开源任务调度框架，它提供了强大的任务调度机制。Quartz允许开发人员灵活的定义触发器的调度时间表，并可对触发器和任务进行关联映射。Quartz提供了调度运行环境的持久化机制，可以保存并恢复调度现场，即使系统因故障关闭，任务调度现场数据并不会丢失。此外，Quartz还提供了组件式的侦听器、各种插件、线程池等功能。官网地址：http://www.quartz-scheduler.org/二、Quart特点简单易用，调度功能强大支持丰富多样的调度方法，可以满足各种常规及特殊需求灵活性作为Spring默认的调度框架，支持任务和调度的多种组...
05.Kafka架构和工作流程
05.Kafka架构和工作流程一、基础架构说明生产者Producer A、Producer B用来生产消息（消息既数据）Kafka集群(Kafka Cluster)Kafka Cluster是用来暂存消息；Broker 1、Broker 2、Broker 3启动了Kafka进程的三台服务器，组成了一个Kafka集群；Topic A、Topic B是Kafka当中的主题,对Kafka中的消息做一个分类，目的是为了生产者和消费者在生产和消费消息时不会产生混乱；Partition 0、Partition 1分区目的是提高Topic的负载能力，提高并发Leader针对当前分区的Leader，生产...
04.Kafka安装教程
04.Kafka安装教程前言本次安装的是目前最新版2.8.0，单机版安装，安装环境CentOS7.X。一、准备阶段安装JDK环境，要求最好是JDK1.8以上版本安装Zookeeper环境，详情可以参考：CentOS7 Zookeeper安装教程二、下载Kafka2.1 下载地址https://kafka.apache.org/downloads2.2 下载Kafka版本本次下载的是最新版Kafka_2.12-2.8.0.tgz，直接点击下载即可。下载完成后直接上传到服务器即可。也可以通过如下命令直接在服务器端下载[root@hadoopserver sources]# wget http...
03.Kafka的版本号
03.Kafka的版本号前言版本命名规则：四位版本号：MajorVer.MinorVer.ReleaseVer.BuildVer (如 0.7.0.8)MajorVer 表示主版本号，当前还在开发阶段，为 0。MinorVer 表示副版本号，ReleaseVer 表示发布版本号，目前是 7.0。BuildVer 表示构建编号，以后每次构建都会自动加一，以标识每一个具体的版本。三位版本号：Major.Minor.Patch（如2.1.3）Major表示大版本，通常是一些重大改变，因此彼此之间功能可能会不兼容，目前为2Minor表示小版本，通常是一些新功能的增加，目前为1Patch表示修订版...
【转载】Spring Boot在启动时进行配置文件加解密
Spring Boot Application事件和监听器寻找到application.yml的读取的操作。从spring.factories 中查看到# Application Listeners org.springframework.context.ApplicationListener=\ org.springframework.boot.context.config.ConfigFileApplicationListener,\ConfigFileApplicationListener 该对象对application.yml进行读取操作ConfigFileApplication...
CentOS7.X安装Scala2.12.10教程
CentOS7.X安装Scala2.12.10教程前言如果需要研究Spark或者Kafka都需要安装Scala环境。本次安装的Scala版本是2.12.10。一、安装步骤1.1 下载软件[root@hadoopserver sources]# wget https://downloads.lightbend.com/scala/2.12.10/scala-2.12.10.tgz1.2 拷贝并解压# 将scala安装包拷贝到/usr/local目录下 [root@hadoopserver sources]# cp scala-2.12.10.tgz /usr/local/ # 解压安装包 ...
02.Kafka常用命令
02.Kafka常用命令一、Broker1.1 启动Kafkabin/kafka-server-start.sh --daemon config/server.properties-–daemon：以守护进程的方式启动1.2 查询进程jps -l1.3 停止Kafkabin/kafka-server-stop.sh config/server.properties二、Topic2.1 创建Topicbin/kafka-topics.sh --zookeeper localhost:2181 --create --topic frist --partitions 2 --replicati...
【转载】01.初识Kafka
【转载】01.初识Kafka一、什么是KafkaKafka 是由 Linkedin 公司开发的，它是一个分布式的，支持多分区、多副本，基于 Zookeeper 的分布式消息流平台，它同时也是一款开源的基于发布订阅模式的消息引擎系统。二、Kafka的基本术语消息：Kafka 中的数据单元被称为消息，也被称为记录，可以把它看作数据库表中某一行的记录。批次：为了提高效率， 消息会分批次写入 Kafka，批次就代指的是一组消息。主题：消息的种类称为主题（Topic）,可以说一个主题代表了一类消息。相当于是对消息进行分类。主题就像是数据库中的表。分区：主题可以被分为若干个分区（partition）...