在业务开发中，一般都会定义全局通用的业务异常，然后通过拦截器对全局异常进行解析，返回给调用端对应的信息， 但是在某些场景（比如反射）下，抛出的业务异常会被吞掉，导致调用端收到懵逼的，统一的错误信息。   1 背景   今天有同事反馈，自定义的数据校验（会抛出全局自定义的业务异常），通过反射执行后，抛出的自定义业务异常没有被捕获到，一脸 o((⊙﹏⊙))o，这里用示例代码模拟下：   BusinessException 自定义的业务异常类  public class BusinessException extends Exception { private static final long s...

背景   这篇文章的主要核心原理都来自于这个开源项目dynamic-tp，可以说是对这个开源项目的源码分析，也是对这个开源项目中涉及到的技术点进行学习总结。   从这篇文章中能学到的技术点   从这篇文章中能学到的技术点，也就是从这个dynamic-tp开源项目中学习到的技术点（这里只列举了这个项目的冰山一角）：    利用Nacos作为配置中心，动态监听Nacos配置变更。  项目启动之初获取Nacos配置，将yml文件中配置的线程池注册到IOC容器中。这里在文章的最后再介绍，利用Spring提供的扩展点。  .yml文件映射到具体的对象中，对比是否有变更。  Spring提供的扩展点学习。...

1. 多线程的中创建方式    方式一：继承Thread方法  方式二：实现Runnable 接口  方式三：实现Callable接口     因为前面连个之前已经讲过了，所以这里主要强调的是第三种方式创建线程  Callable接口时JDK1.8之后新设置的一个接口，主要作用是在重写 call() 方法的时候可以返回参数   package Timer_; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.Futur...

对于数据量庞大且需要考虑有序性时，那么可以使用雪花算法，当然既然要使用高性能工具，肯定是需要付出代价的，代价就是需要维护多个系统组件来保证高效生成有序的唯一ID。 下面从概念到实践一一介绍：   分布式唯一ID     使用RocketMQ时，需要使用到分布式唯一ID    消息可能会发生重复，所以要在消费端做幂等性，为了达到业务的幂等性，生产者必须要有一个唯一ID。   需要满足以下条件:    同一业务场景要全局唯一  该ID必须是在消息的发送方进行生成发送到MQ  消费端根据该ID进行判断是否重复,确保幂等性    在哪里产生以及消费端进行判断做幂等性与该ID无关，此ID需要保证的特性:...

消息队列（Message Queue，简称 MQ）是构建分布式互联网应用的基础设施，通过 MQ 实现的松耦合架构设计可以提高系统可用性以及可扩展性，是适用于现代应用的最佳设计方案。   什么是RocketMQ  RocketMQ官方定义为一个统一的消息传递引擎,轻量级的数据处理平台。     Apache RocketMQ是分布式和低延迟消息和流处理平台,性能和可靠性高,trillion-level（万亿级）能力和灵活的可扩展性。它由四个部分组成: 消息生产者（Producer）：负责生产消息，一般由业务系统负责生产消息。一个消息生产者会把业务应用系统里产生的消息发送到broker服务器。Ro...

什么是 TreeSet   TreeSet 是一个具有唯一元素的二叉树的集合，又被翻译为 树集。Java 中的 TreeSet 类是 Java 集合框架的一部分，从 Java 6 开始，它实现了 NavigableSet 接口（这个接口增加了几个查找元素以及反向遍历的便利方法），从而扩展了 SortedSet 集合。      TreeSet 类与散列类十分相似，不过，它比普通的集合有所改进，树集是一个有序集合（sorted collection），该数据结构的元素按自然顺序排序。    SortedSet 接口提供了保持元素排序的功能。  Navigableset 接口提供了可以通过 Sor...

ReentrantReadWriteLock读写锁   在没有任何读写锁的时候才可以取得写入锁(悲观读取，容易写线程饥饿)，也就是说如果一直存在读操作，那么写锁一直在等待没有读的情况出现，这样我的写锁就永远也获取不到，就会造成等待获取写锁的线程饥饿。平时使用的场景并不多。读写锁维护了一对锁，一个读锁和一个写锁，通过分离读锁和写，使得并发性相比一般的排他锁有了很大提升。  private final Map<String, Data> map = new TreeMap<>(); private final ReentrantReadWriteLock lock = ne...

前言   在很久之前，我在面实习生的时候，就有人问过我synchronized的锁升级过程，我当时只是浅浅了解，后面其实了解了锁升级的流程。但其实我并不是很明白，究竟优化了哪里，究竟是针对哪种场景进行优化，我其实更想得到这个锁升级过程中的引入场景。尤其是看到JDK 15废弃并禁用了偏向锁之后，我其实在想为什么要移除这项技术，是JDK 有了更好的优化，还是这项技术不再适用于现在。这里直接说答案吧，答案就在JEP 374中。我本来想直接贴答案的，但是考虑到有的同学还不清楚synchronized的升级流程，这里还是先简单的讲一下锁升级的流程。   其实这也是一道面试常见的问题，但是常常是面试官问我...

什么是Undertow容器   Undertow 是一个采用 Java 开发的灵活的高性能Web服务器，提供包括阻塞和基于 NIO 的非堵塞机制。Undertow 是红帽公司的开源产品，是 Wildfly 默认的 Web 服务器。Undertow 提供一个基础的架构用来构建 Web 服务器，这是一个完全为嵌入式设计的项目，提供易用的构建器 API，完全向下兼容 Java EE Servlet 3.1 和低级非堵塞的处理器。   为什么使用Undertow容器    为什么要替换Undertow容器？    Tomcat默认的最大线程为200，线程数限制了请求调用的性能；在高并发场景下明显并发能...

这一讲主要对Java程序的运行方式和结构进行介绍，并介绍方便的编辑器软件。   Java程序运行方式   源代码：保存为.java文件，文件名和类名保持一致。   编译器编译源文件：如果.java文件没有错误（例如词法错误、语法错误），就会产生.class文件。编译出来的这个文件是由字节码组成的。   Java虚拟机（JVM）运行.class文件：JVM会将字节码转换成平台能够理解的形式来运行.class文件，得到或输出相应结果。当JVM启动执行程序时，会寻找指定的类，定位到类中的main方法，接着执行main方法中的每条指令。   Java程序结构   源文件中有类，类中由方法，方法中有具体...

原始整合方式     数据表  create database ssm character set utf8; use ssm; create table account( id int primary key auto_increment, name varchar(100), money double(7,2) );   创建 Maven 工程    导入 Maven 坐标  <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache...

集合概述    集合，长度可变的容器    1 ArrayList集合可变长度原理：     ArrayList集合：底层原理也是，数组；初始大小长度为10     1初始化一个长度为10的数组，数值依次存储，当数组存不下的时候； 2创建一个原数组1.5倍的新数组，将原数组内容拷贝到新数组，再将没存到的数据，存到 新数组中； 注意：【长度不变用数组，长度经常改变用集合】    2 ArrayList集合     ArrayList构造方1   public ArrayList();   泛型：<>   在类名之后加<>,可以使集合存储的数据类型，进行类型限制；  尖括号...

1.前言    对于大多数多种类型的逻辑代码，我们一般的做法一般是通过if来进行判断，然后再{}里进行逻辑代码的编写，如下述   package org.example.designpattern.strategy; public class LoginNoDesign { /** * 登录方法, 不使用策略模式时, 对于流程的扩展如新增一种登录方式只能添加if * * @param username 用户名 * @param password 密码 * @param type 登录方式 */ public void login(String username, String password...

案例来自《重学Java设计模式》   案例场景   本案例是模拟每次小客车摇号通知的场景，如下图（截自《重学Java设计模式》）      文件结构      完整代码   EventListener.java   这个接口定义了监听事件要执行的方法，后面创建的监听器都会实现这个接口并重写该方法     public interface EventListener < T > { /** * observed do * @param type */ void doEvent ( T type ) ; }  MessageEventListener.java   消息监听器，用于监听...