Callable、Future使用 针对线程Thread对象不具有返回值的功能，但是有请求需要线程返回值，所以需要用到Callable和Future来让线程具有返回值的功能。 Callable接口与线程密不可分，但是和Runnable有以下主要的区别是 Callable接口的call()方法可以有返回值，而Runnable接口的run()方法没有返回值。 Callable接口的call()方法可以声明抛出异常，而Runnable接口的run()方法不可以声明抛出异常。 执行完Callable接口中的任务后，返回值是通过Future接口进行获取。 ...

这一节我们来看下RocketMQ的延迟消息 1.发送延迟消息 public class Producer { public static void main(String[] args) throws Exception { // 实例化一个生产者来产生延时消息 DefaultMQProducer producer = new DefaultMQProducer("DELAY_P_G"); producer.setNamesrvAddr("127.0.0.1:9876"); // 启动生产者 producer.start(); fo...

引言 在这篇文章中，我们将使用一些示例，来学习 Java 中的装箱与拆箱操作。原始数据类型的处理是不同的，因此引入了包装类，其中有两个组件起着作用，即自动装箱和解箱。 为何需要原始类型与包装类？ Java 是基于面向对象设计的，因此，每创建一次包装类型就会放到堆里，然后通过栈中的地址来找寻堆中的对象。那么像经常使用的 int、double、float 等基础类型，每次都创建为对象会变的效率低下。因此就出现了基本类型，直接将变量值存在栈中。但是基本类型不具有对象性质，当我们使用集合的时候，又可以使用其包装类型。当然，我们每次使用的时候，例如往集合中添加基本类型，Java ...

一、前言 在阅读本篇文章之前，我先提问一下： mybatis映射文件、核心配置文件、properties配置文件、日志文件到底在这个框架中各自的功能是什么？它们在文件夹中的位置该如何设定？ resultMap、resultType有什么不同？什么时候要使用它们？ 遇到像模糊查询时，我们该如何正确操作？ {} 、${} 之间的区别是什么？各自使用的情景是什么？ mybatis缓存是什么？ 分步查询会不会？ ... 废话不多说，满满的干货，赶快来看看吧~ 二、基本介绍 一句...

Java 8新特性之一 Stream 的官方描述： Classes in the new java.util.stream package provide a Stream API to support functional-style operations on streams of elements. The Stream API is integrated into the Collections API, which enables bulk operations on collections, such as sequential or parallel ma...

java实现 二叉搜索树功能 概念 二叉搜索树也成二叉排序树，它有这么一个特点，某个节点，若其有两个子节点，则一定满足，左子节点值一定小于该节点值，右子节点值一定大于该节点值，对于非基本类型的比较，可以实现Comparator接口，在本文中为了方便，采用了int类型数据进行操作。 要想实现一颗二叉树，肯定得从它的增加说起，只有把树构建出来了，才能使用其他操作。 二叉搜索树构建 谈起二叉树的增加，肯定先得构建一个表示节点的类，该节点的类，有这么几个属性，节点的值，节点的父节点、左节点、右节点这四个属性，代码如下 static class Node{ Node p...

3 hashCode的内幕 tips：面试常问/常用/常出错 hashCode到底是什么？是不是对象的内存地址？ 1) 直接用内存地址？ 目标：通过一个Demo验证这个hasCode到底是不是内存地址 public native int hashCode(); com.hashcode.HashCodeTest package com.hashcode; import org.openjdk.jol.vm.VM; import java.util.ArrayList; import java.util.List; public class Has...

概述 Paxos算法是Lamport宗师提出的一种基于消息传递的分布式一致性算法，是目前公认的解决分布式一致性问题最有效的算法之一。本文的目的就是带领大家深入浅出理解Paxos算法，理解它的执行流程，然后通过一个例子来了解Paxos算法在分布式系统中起到的作用。如果有能力的同学可以直接拜读原文。 分布式一致性 分布式系统通常由异步网络连接的多个节点构成，每个节点有独立的计算和存储。通常来说，分布式一致性一般指的式数据的一致性。比如分布式存储系统，通常以多副本冗余的方式实现数据的可靠存储。同一份数据的多个副本必须保证一致，而数据的多个副本又存储在不同的节点中，这里的分布式一致性...

1. 什么是Raft？ Raft其实是一种分布式一致性算法(分布式共识算法)。核心还是和Paxos差不多但是更加便于理解和实现，Raft算法模块化的拆分以及相比Paxos更加简化的设计。实现Raft协议更加的简单，理解Raft算法也更加的容易。主要拆分成了多个模块： 领导人选举(Leader selection)： Raft集群启动，或者当存在的Leader节点发生故障，触发 Leader selection 。选举出来新的Leader 日志复制(Log replication)： Leader必须从客户端接收日志条目(Log entry),然后复制的其他的节点。...

Spring事务失效的各种场景 一、访问权限 Java的访问权限主要是：private、default、protected、public，它们的权限则是依次变大。 如果我们在开发的时候定义错误的访问权限，就会导致事务出现问题 @Service public class DemoService { @Transactional private void query(Demo demo) { } } 我们可以查看源码，可以明白，spring事务的实现AbstractFallbackTransactionAttributeSource类的computeTransa...

起因 在一个迭代的需求中，需要记录用户的行为，想着记录用户行为这部分业务逻辑可以修改为异步执行，就使用了CompletableFuture的runAsync()方法实现异步，本来本地环境自己测试也没报错，可是发到开发环境服务器上的时候却报错了。 报错伪代码 CompletableFuture.runAsync(()->{ //掉用user服务保存用户行为 userClient.saveUserBehavior(); }); 错误信息以及使用的环境 环境：jdk使用的是openjdk11，SpringCloud版本是2020.0.3 java.lang.Clas...

前言 有一天，我翻开源码横看竖看，满屏只看到四个字，我看不懂啊。 所以是不是曾和我一样迷失在毫无头绪的源码里，在各种类和方法里翻山越岭，却如同管中窥豹。是的话，要不今晚早点睡？ 呸，扯远了，写文章怎么能分神呢。 所以正当我苦恼的时候，我想起了一句话“给我一个支点我就可以撬动整个地球”，阿基米德说的。 咦，突然让我灵机一动，那撬动整个Spring源码的支点是什么呢？或者说Spring作者在开发Spring时的支点是什么呢？这么想让我开始觉得有点意思了。 如果尝试先从使用Spring的角度来看源码，好像事情也并没有那么错综复杂。 你是怎么使用Spr...

介绍 JSR-380是 J2EE 的一个规范，用于校验实体属性，它是JSR-303的升级版，在 Spring Boot 中可以基于它优雅实现参数校验。 示例 在没有使用JSR-380之前，我们一般都会将参数校验硬编码在controller类中，示例： public Result add(@RequestBody User user){ if(StringUtils.isBlank(user.getName())){ return Result.error("用户名不能为空"); } // ... } 而使用JSR-380只需要通过添加对应的注...

1.方法的重载 1.1.基本介绍 在同一个类中，允许多个重名方法的存在，但要求形参列表不一致。 比如： System.out.println(11)//输出整数 System.out.println("Javayyds")//输出字符串 System.out.println("1.1")//输出浮点型 1.2.重载的好处 减轻了对方法起名和记名的麻烦。 1.3.重载使用细节 方法名：必须相同 参数列表：必须不同（参数的类型、参数的个数、参数的顺序至少有一个不相同，参数名无要求） 返...