加载中
Flink简单项目整体流程

项目概述 CDN热门分发网络,日志数据分析,日志数据内容包括 aliyun CN E [17/Jul/2018:17:07:50 +0800] 223.104.18.110 v2.go2yd.com 17168 接入的数据类型就是日志 离线:Flume==>HDFS 实时...

RocksDB Java操作

RocksDB其实是一种嵌入式的K:V数据库,系统无需安装,之前本人的安装RocksDB安装 ,其实多此一举。由于RocksDB是C++开发的,它的Java API大多其实只是对C++ API的一种调用。 RocksDB的底层数...

2021/01/30 09:50
3.1K
RocksDB安装

对于裸机来说,先得安装C++的编译工具 yum -y install gcc gcc-c++ 下载cmake wget https://cmake.org/files/v3.9/cmake-3.9.2.tar.gz tar -xzvf cmake-3.9.2.tar.gz cd cmake-3.9.2 ./conf...

Springboot2整合Kafka

依赖 org.springframework.kafka spring-kafka 配置 spring: kafka: bootstrap-servers: 外网ip:9092 prod......

Flink技术整理

首先先拉取Flink的样例代码 mvn archetype:generate \ -DarchetypeGroupId=org.apache.flink \ -DarchetypeArtifactId=flink-quickstart-java ......

单机区块链实现

区块链就是一串或者是一系列区块的集合,类似于链表的概念,每个区块都指向于后面一个区块,然后顺序的连接在一起。在区块链中的每一个区块都存放了很多很有价值的信息,主要包括三个部分:自...

2020/12/23 00:11
1.3K
使用栈的记忆化搜索来加速子集和算法

所谓子集和就是在一个数组中找出它的子集,使得该子集的和等于某个固定值。 一般我们都是使用递归加回溯的方式来处理的,代码如下(此处我们只找出一组满足的条件即可) public class SubSet {...

2020/12/01 20:53
5.1K
分布式共识机制

C/S模式 我们先从最简单的两台计算机开始,一台是服务器,一台是客户端,即C/S模式。客户端希望操作服务器节点上的数据。 既然客户端想要操作服务器上的数据,就必然需要进行网络通信,发送命...

2020/11/08 04:03
715
线性代数整理

向量 线性代数是从研究一个数拓展到一组数 一组数的基本表示方法——向量(Vector) 向量是线性代数研究的基本元素 一组数的作用:最基本的出发点:表示方向 在二维空间中,不同的方向表示不同...

2020/10/30 03:49
5.9K
Neo4j Cypher语法整理

查询John的朋友的朋友 添加5个人名节点,名字分别为 CREATE (:People{name:"John"}) CREATE (:People{name:"Joe"}) CREATE (:People{name:"Sara"}) CREATE (:People{name:"Steve"}) CREATE (...

2020/10/20 00:55
4.7K
第一个Springboot Neo4j代码

pom <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-neo4j</artifactId> </dependency> <dependency> <groupId>org.projectlombok</group...

Spring的任务调度处理

Spring封装了JDK的任务调度线程池和任务调用,并使用标签就可以开启一个任务调用。 先进行一个Spring的任务调度线程池的配置,此时是多线程执行任务,如果不配置则默认为单线程串行执行任务。...

2020/10/14 06:34
906
最小堆与索引堆

我们先来完成一个最小堆,采用JDK的ArrayList作为底层数据结构。关于堆的概念请参考数据结构整理 中最大堆的部分 接口 public interface Heap<T> { int getSize(); boolean isEmpty(); void ...

2020/10/08 13:25
642
Springboot整合Redis缓存机制

先放几个必要的依赖吧 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springfram...

Spring的异步线程处理

Spring封装了JDK的线程池和线程调用,并使用标签就可以开启多线程调用。 先进行一个Spring的线程池配置 @Configuration @EnableAsync public class ThreadPoolConfig implements AsyncConfig...

2020/09/21 16:47
840
Nacos配置中心动态获取数组配置

有的时候我们需要动态获取一系列的配置项,假设我们在nacos配置中心的配置如下,nacos配置中心的其他设置请参考Nacos搭建流程 skill: name: - 爆炸 - 冲刺 在SpringCloud代码中编写配置文件呢...

Raft分布式一致性算法整理

CAP定理 Consistency:一致性 Availability:可用性 Partition-tolerance:分区容错性 CAP定理指出,在异步网络模型中,不存在一个系统可以同时满足上述3个属性。换句话说,分布式系统必须舍弃其...

2020/07/07 23:39
2.5K
负载均衡算法实现

负载均衡的目的是将请求按照某种策略分布到多台机器上,使得系统能够实现横向扩展。 现在我们来简单实现这些算法,首先我们要有一个服务提供者类。 /** * 服务提供者 */ @AllArgsConstructor...

amp
2020/07/05 03:06
841
自己实现一个RPC框架

RPC框架称为远程调用框架,其实现的核心原理就是消费者端使用动态代理来代理一个接口的方法(基于JDK的动态代理,当然如果使用CGLib可以直接使用无接口类的方法),通过加入网络传输编程,传输...

2020/06/10 05:21
4.1W
Spring状态机

有限状态机简称就是状态机,因为一般的状态机的状态都是离散和可举的,即为有限,所以后面的介绍都不加有限二字。状态机表示有限个状态以及在这些状态之间的转移和动作等行为的数学模型。通俗...

没有更多内容

加载失败,请刷新页面

返回顶部
顶部