线上限流问题 问题 定向发券时，部分用户发券失败，原因是service-1调用service-2时被ingateway限流(http 596 status)，service-1执行fallback逻辑，抛出异常；活动发券用户1602+394+224*1左右，故批量时qps在 700左右，但是限流配置的是1k，故不应被限制 原因 inrouter的限流是单节点限流，比如配置限流策略是1000，存在17个inrouter节点，即每个节点的限流qps为58，当该节点qps超过58时，即会被限流响应598，上述问题时总qps为722，故单节点平均为 42，当某一节点倾斜量超过16时，超过的请求即会被限流，共限流29个请求 解决方案 暂时解决方案

xxl-job通过mysql 实现的分布式锁

作用 SPI全称Service Provider Interface，是Java提供的一套用来被第三方实现或者扩展的API，它可以用来启用框架扩展和替换组件。 使用 开发接口模块 public interface PayService { String pay(); } 开发实现模块 public class AliPayService implements PayService { @Override public String pay() { return "ali"; } } 添加service 在resouces下创建目录META-INF/services 在services添加文件com.xxx.PayService，

主-从Reactor网络模型 Main reactor thread 负责绑定监听端口 绑定端口后通过单线程acceptor建立tcp连接 建立tcp连接后通过epoll注策读事件 sub-reactor dispatch 一个四核 CPU服务器，我们可以设置 sub-reactor 为 4 负责监听tcp连接读写事件 当acceptor建立连接后，交由sub-reactor中的一个处理 收到tcp读事件后，交给工作线程处理任务 与单reactor线程相比（即读写事件监听线程和acceptor线程为同一线程），单reactor 线程既分发连接建立，又分发已建立连接的 I/O，有点忙不过来，在实战中的表现可能就是客户端连接成功率偏低。 threadpool 任务任务线程池 由于处理任务比较耗时，故将任务处理线程与tcp

什么是 I/O 多路复用 把标准输入、套接字等都看做 I/O 的一路，多路复用的意思，就是在任何一路 I/O 有“事件”发生的情况下，通知应用程序去处理相应的 I/O 事件。这样就可以同时监听多个 I/O 事件。 select 介绍 int select(int maxfd, fd_set *readset,

JIT概述 即时编译是一项用来提升应用程序运行效率的技术。通常而言，代码会先被 Java 虚拟机解释执行，之后反复执行的热点代码则会被即时编译成为机器码，直接运行在底层硬件之上。 从 Java 8 开始，Java 虚拟机默认采用分层编译的方式。它将执行分为五个层次，分为为 0 层解释执行，1 层执行没有 profiling 的 C1 代码，2 层执行部分 profiling 的 C1 代码，3 层执行全部 profiling

PriorityQueue 案例 package com.kevin.container; import java.util.PriorityQueue; import java.util.Random; public class PriorityQueueCase { public static void main(String[] args) { PriorityQueue priorityQueue = new PriorityQueue(); int count = 10; for (int i

java线程池实现继承关系 Executor==>ExecutorService-->AbstractExecutorService==>ThreadPoolExecutor Executor-接口 execute，执行某个Runnable实现类 ExecutorService-接口，较Executor提供了更多的功能 submit，执行Callable实现类，返回值通过Future返回 AbstractExecutorService-线程池抽象类 实现了submit方法 在执行submit方法前会将Callable转为FutureTask类，然后调用execute方法执行 FutureTask是Runnable的实现类 线程池基本都继承该抽象类 线程池实现类 ThreadPoolExecutor 实现了execute方法，在该方法中判断核心线程数 如果小于核心线程数，则通过addWorker新增核心线程执行该command 如果小于核心线程数，则将command添加至任务队列中 如果添加队列失败，则继续通过addWorker新增非核心线程 如果新增线程失败，

作用 计算机中一个任务一般是由一个线程来处理的，如果此时出现了一个非常耗时的大任务，比如对一个大的ArrayList每个元素进行+1操作，如果是普通的ThreadPoolExecutor就会出现线程池中只有一个线程正在处理这个大任务而其他线程却空闲着，这会导致CPU负载不均衡，空闲的处理器无法帮助工作。ForkJoinPool就是用来解决这种问题的,将一个大任务拆分成多个小任务后，使用fork可以将小任务分发给其他线程同时处理，使用join可以将多个线程处理的结果进行汇总；这实际上就是分治思想的并行版本 Java8中的parallelStream API就是基于ForkJoinPool实现的 ForkJoinPool的线程使用的是 Thread子类ForkJoinWorkerThread 实例 我们在提交任务时，一般不会直接继承ForkJoinTask，只要继承它的子类即可，框架提供了两种子类： RecursiveAction:用于没有返回结果的任务(类似Runnable) RecursiveTask:用于有返回结果的任务(类似Callable) public class ForJoinPollExecutor { public static

Thread.sleep(time) 该方法必须传入指定的时间，线程将进入休眠状态，通过jstack输出线程快照的话此时该线程的状态应该是TIMED_WAITING，表示休眠一段时间。 该方法会抛出InterruptedException异常，这是受检查异常，调用者必须处理。 通过sleep方法进入休眠的线程不会释放持有的锁，因此，在持有锁的时候调用该方法需要谨慎。 Object.wait() 方法 java的每个对象都隐式的继承了Object类。因此每个类都有自己的wait()方法。我们通过object.wait()方法也可以让线程进入休眠。wait()有3个重载方法: public final void wait() throws InterruptedException; public final

问题 public class PatternTest { public static void main(String[] args) { Set<Person> set = new HashSet<>(); Person p1 = new Person(1,"张三"); set.add(p1); Person p2 = new