因为我们项目用的是Springboot 2.0以上的，所以跟Springboot 1.x的会有一些不同。 pom <dependency> <groupId>com.github.tobato</groupId> <artifactId>fastdfs-client</artifactId> <versi...

FastDFS是一个分布式的文件系统，他可以把上传到某一台服务器的文件分发复制到其他节点的文件服务器上做高可用。 FastDFS 上传文件交互过程： 1. client 询问 tracker 上传到的 storage，不需...

RDD是一个抽象，会记录一些信息，他并不是一个真正的集合，但可以像集合一样操作，降低了开发难度。 RDD的算子分为2类，一种是Transformation(lazy不会立即执行，即便有错误也不会发现)，一类...

昨天虽然试用了一下唯品会的“土星”，但是我实在没想明白他的Job该怎么用Spring来托管，所以没有使用。今天来说一下当当的Elastic-Job. 安装管理平台 先说一下Elastic-Job的管理平台跟Java的...

唯品会分布式调度Saturn的开发文档见：https://vipshop.github.io/Saturn/#/zh-cn/3.0/quickstart 这里面说要安装node.js 8.7.0+跟npm 5.4.2+ 但其实node.js 8.7.0就已经包含了npm 5.4.2,首先...

有一些Controller要算一些东西，可能会耗时较长，我们以休眠2秒来模拟这个过程。 代码如下 public class Dog implements Serializable { private String name; private int age; public Stri...

先说明，这次我们用的还不是Spark streaming，而是从hadoop hdfs拿取文件，经过计算，再把结果放回hadoop hdfs. 首先我们需要在之前的工程文件下修改我们的pom（具体参考IDEA全程搭建第一个S...

因为Spring Cloud Feign是基于Http Restful的调用，在高并发下的性能不够理想（虽然他是基于Ribbon以及带有熔断机制，可以防止雪崩），成为性能瓶颈，所以我们今天对Feign进行Dubbo的RPC改造...

既然要搭建maven工程，当然我们要在Project里面选择的是Maven而不是Scala.在Create from archetype打上勾，选择scala-archetype-simple. 然后一路next 全部加载完成之后，修改scala版本号，添...

我们都知道线程间的通信可以使用BlockingQueue，那么为什么BlockingQueue可以进行线程间的通信呢？其实就在于BlockingQueue的锁机制。重入锁ReentrantLock带有一个Condition的条件，可以进行...

所有的锁都是悲观的,他们总是假设每一次的临界区操作会产生冲突,如果有多个线程同时需要访问临界区资源,就宁可牺牲性能让线程进行等待,所以说锁会阻塞线程执行.而无锁是一种乐观的策略,它会假...

如果你下载已经打包好的mycat 1.6.5压缩包.tar.gz是永远也连接不了mysql 8的,我们需要的是mycat 1.6.5的源代码Mycat-Server-1.6.zip的源代码,这个可以自行去下载.下载完之后,第一次加载需要加...

要讲一致性Hash原理,先从一般性Hash讲起,其实Hash的本质就是一个长度可变的数组,那为什么Hash的时间复杂度是O(1),而其他类型的数据结构查找都是要遍历来,遍历去,即便是树,二叉树,也是要经过几...

将500W个单词放进一个数据结构进行存储,然后进行快速比对,判断一个单词是不是这个500W单词之中的;来了一个单词前缀，给出500w个单词中有多少个单词是该前缀. 1、这个需求首先需要设计好数据结...

一般在生产环境中,我们都不会直接new一个Thread,然后再去start(),因为这么做会不断频繁的创建线程,销毁线程,过大的线程会耗尽CPU和内存资源,大量的垃圾回收,也会给GC带来压力,延长GC停顿时间...

秒杀系统是大家面试的时候问的最多的东西,我们写一个最简单的单机秒杀样例（非Web） 我们是用一个无锁多线程的例子来模拟一个千人秒杀10件商品。 public class SecKill { //商品数量 privat...

Springboot配置RedisCLuster集群跟单机的玩法有很多不一样. 资源文件 redis: cache: clusterNodes: 192.168.5.182:7111,192.168.5.182:7112,192.168.5.182:7113,192.168.5.129:7114,192.168....

1、线程的等待和通知 首先wait()和notify(),notifyAll()方法一定是一般对象方法，他们并不属于线程对象方法，一定是跟synchronized（监视器锁）结伴出现的。wait()方法执行时会释放获取的监视...

/** * Created by Administrator on 2018/9/27. * 在Scala中的Object是一个单例对象,没办法new * object中定义的成员变量和方法都是静态的 */ object ScalaStatic { val name: String = "li...

接之前一篇<手写zookeeper来模拟dubbo的注册/发现>,使用一致性Hash来进行查找需要寻找的服务. Hash处理接口 public interface HashFunc { public Long hash(Object key); } 一致性Hash类 pu...