BlockingQueue也叫做阻塞队列，在某些情况下对BlockingQueue的访问可能会造成阻塞。被阻塞的情况主要有如下两种：当队列满了的时候进行入队列操作当队列空了的时候进行出队列操作阻塞队列一共有四套方法用来进行增、删、查，当每套方法对应的操作不能马上执行时会有不同的反应，下面这个表格就分类列出了这些方法：这4类方法有不同的行为1，Throws Exception如果操作不能立即被执行，那么将抛出异常2.Special Value如果操作不能被立即执行，那么将返回一个异常值（一般情况下是true/false）3.Blocks如果操作不能被立即执行，那么操作将会阻塞，直至可以执行。4T...阅读全文>>
常见的两种创建线程的方式。一种是直接继承Thread，另外一种就是实现Runnable接口。这两种方式都有一个缺陷就是：在执行完任务之后无法获取执行结果。从Java 1.5开始，就提供了Callable和Future，通过它们可以在任务执行完毕之后得到任务执行结果。Future模式的核心思想是能够让主线程将原来需要同步等待的这段时间用来做其他的事情。（因为可以异步获得执行结果，所以不用一直同步等待去获得执行结果）。上图简单描述了不使用Future和使用Future的区别，不使用Future模式，主线程在invoke完一些耗时逻辑之后需要等待，这个耗时逻辑在实际应用中可能是一次RPC调用，可能是...阅读全文>>
Selector提供选择执行已经就绪的任务的能力，使得多元 I/O 成为可能，就绪选择和多元执行使得单线程能够有效率地同时管理多个 I/O channel。C/C++许多年前就已经有 select()和 poll()这两个POSIX（可移植性操作系统接口）系统调用可供使用。许多os也提供相似的功能，但对Java 程序员来说，就绪选择功能直到 JDK 1.4 才成为可行方案。Selector的创建过程如下：// 1.创建Selector Selector selector = Selector.open(); // 2.将Channel注...阅读全文>>
AtomicInteger类是系统底层保护的int类型，通过提供执行方法的控制进行值的原子操作。AtomicInteger它不能当作Integer来使用。AtomicInteger与使用同步执行相同操作相比，使用它同样更快，更易读。在 JDK1.5 中新增了并发情况下使用的 Integer/Long 所对应的原子类AtomicInteger 和 AtomicLong。在并发的场景下，如果我们需要实现计数器，可以利用AtomicInteger和AtomicLong，这样一来，就可以避免加锁和复杂的代码逻辑，有了它们之后，我们只需要执行对应的封装好的方法，例如对这两个变量进行原子的增操作或原子的减...阅读全文>>
CountDownLatchCountDownLatch是一个同步工具类，它允许一个或多个线程等待其他线程一系列操作的完成。A synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads completes.我们来看两个示例@Test public void CountDownLatchTest1() throws Exception { // 这里只有...阅读全文>>
首先，你要了解SpringBoot配置文件加载顺序，加载位置（代码内，Nacos等），当然这不是这里要说的，这里我们就是约定配置文件在resources下，一般有一个主配置文件application.yml，但是当配置过多时，一个配置文件，将会非常臃肿。所以我们需要把配置文件拆分，一些不需要动的，公用的，核心的配置放到application.yml下，其他的可以有多种拆分方式，例如可以分开发环境、测试环境、正式环境在bootstrap.yml增加配置标记当前环境spring: profiles: active:&nbs...阅读全文>>
Quartz作为开源作业调度中的佼佼者，是作业调度的首选。但是集群环境中Quartz采用API的方式对任务进行管理，从而可以避免上述问题，但是同样存在以下问题：问题一：调用API的的方式操作任务，不人性化；问题二：需要持久化业务QuartzJobBean到底层数据表中，系统侵入性相当严重。问题三：调度逻辑和QuartzJobBean耦合在同一个项目中，这将导致一个问题，在调度任务数量逐渐增多，同时调度任务逻辑逐渐加重的情况下，此时调度系统的性能将大大受限于业务；问题四：quartz底层以“抢占式”获取DB锁并由抢占成功节点负责运行任务，会导致节点负载悬殊非常大；而XXL-JOB通过执行器实现“...阅读全文>>
Quartz作为开源作业调度中的佼佼者，是作业调度的首选。但是集群环境中Quartz采用API的方式对任务进行管理，从而可以避免上述问题，但是同样存在以下问题：问题一：调用API的的方式操作任务，不人性化；问题二：需要持久化业务QuartzJobBean到底层数据表中，系统侵入性相当严重。问题三：调度逻辑和QuartzJobBean耦合在同一个项目中，这将导致一个问题，在调度任务数量逐渐增多，同时调度任务逻辑逐渐加重的情况下，此时调度系统的性能将大大受限于业务；问题四：quartz底层以“抢占式”获取DB锁并由抢占成功节点负责运行任务，会导致节点负载悬殊非常大；而XXL-JOB通过执行器实现“...阅读全文>>
Spring-Kafka 提供消费重试的机制。当消息消费失败的时候，Spring-Kafka 会通过消费重试机制，重新投递该消息给 Consumer ，让 Consumer 重新消费消息 。默认情况下，Spring-Kafka 达到配置的重试次数时，【每条消息的失败重试时间，由配置的时间隔决定】Consumer 如果依然消费失败 ，那么该消息就会进入到死信队列。Spring-Kafka 封装了消费重试和死信队列， 将正常情况下无法被消费的消息称为死信消息（Dead-Letter Message），将存储死信消息的特殊队列称为死信队列（Dead-Letter Queue）。我们在应用中可以对死信...阅读全文>>
现如今又要写一个关于下午的业务，因此再次编写测试用例，总结了两种下载方式。首先介绍一个14年就写的文章，Http断点下载实简单讲解（http://www.javacui.com/java/98.html ）基于Spring的ResponseEntity/** * SpringMVC方式 */ @GetMapping("/downSpring") public ResponseEntity<byte[]> down() throws Exception { &n...阅读全文>>
