数据流概念    数据流是什么？   数据流是一串连续不断的数据的有序集合。打个比方：它就像是流水，只要前面不断地有水供应，就会形成连续不断地水流。数据写入程序可以是逐段地向数据流管道中写入数据，这些数据段会根据进入管道的先后顺序形成一条长长的数据流。    注：但是，对数据读取对程序来讲，是看不出数据流写入时的分段情况的，每次可以读取其中任意长度的数据，但只能先读前面的再读取后面的。而且不管将数据分段写入多少次，它还是作为一个整体一次写入，且读取效果一致。   计算机中的数据存储位置    外存：U盘、计算机硬盘等  内存：一般是主机中的内存  缓存：CPU内部缓存 这三者的存储量一般是依次...

在我们业务开发的过程中，难免会碰到对外进行调用的情况，诸如在金融场景中，我们需要去推送还款计划的信息、查询还款结果等   三方的接口，对于我们来说其实类似一个“黑盒”，我们不知道这个盒子里面到底做了什么事，但是为了不影响盒子出现的异常影响我们业务正常的进行，所以我们需要针对不同的异常进行一个重试或者其他策略的进行   类比到我们框架中，诸如 RocketMQ 针对于发送失败的消息，也会将消息放到指定的队列，然后进行重试发送，其实简而言之重试，就是为了去保障我们业务的可用性、容错性、一致性   那么，针对于异常重试，可能新来的小杨同学会觉得，异常重试不是很简单，我判断一下三方回来的异常，进行 f...

三大组件   Logback 构建在三个主要的类上：Logger，Appender 和 Layouts。这三个不同类型的组件一起作用能够让开发者根据消息的类型以及日志的级别来打印日志。   Logger 类作为 logback-classic 模块的一部分。Appender 与 Layouts 接口作为 logback-core 的一部分。作为一个通用的模块，logback-core 没有 logger 的概念。   Appender 与 Layout   有选择的启用或者禁用日志的输出只是 logger 的一部分功能。logback 允许日志在多个地方进行输出。站在 logback 的角度来...

RocketMQ Binder集成   RocketMQ也是根据Spring Cloud Stream的规范做了相应的自己的实现，RocketMQ 由于对应的Binder类实现，可以说是集成了消息发送，消息订阅。为了方便大家去阅读源码，我简单的跟大家说一下。   集成消息发送   RocketMQMessageChannelBinder类根据规范完成RocketMQMessageHandler的创建和初始化，RocketMQMessageHandler 是消息处理器MessageHandler的具体实现，其主要作用是转化消息格式并且发送消息，此类中持有RocketMQTemplate对象，Ro...

RocketMQ5.0用新开发的 DLedger Controller 模式增强了以前的 DLedger 模式，下面就来从设计聊一下 DLedger Controller 模式是如何来实现Broker的主备自动切换。我们从以下几个方面来分析：    RocketMQ5.0 整体的架构改动  DLedger Controller如何实现Broker选主(主备自动切换关键)  参与Broker选主的扩容和缩容(哪些Broker有资格参加选主)    Tips: RocketMQ 源码版本5.0.0    1. RocketMQ5.0 主备自动切换架构      相比之前的高可用架构，增加了一个DL...

前言   今天想着给自己的微服务项目添加一个熔断的功能，正好项目内远程调用是用的feign，那就直接用hystrix好了，也比较方便。   然后呢，我以为比较简单的东西，却一直不生效，资料查了个遍，硬是弄了我一上午+一下午的时间，所以记录一下，给大家避坑。   当前环境   如果你的环境跟我差的有点多，那这篇文章可能对你的帮助不大。    JDK8  SpringBoot2.6.6   openfeign3.1.2 （是我写这篇文章时比较新的版本了）        不生效的原因   原因主要有二     配置文件   网上很多教程都是给的旧版本的配置文件，都是feign.hystrix.ena...

TCC模式   TCC(Try Confirm Cancel)同样也是两阶段提交：    一阶段prepare行为   两阶段commit或rollback行为        和AT模式不同之处在于解决了AT基于支持本地ACID事务的关系型数据库的缺点，因为真实业务中可能不使用mysql之类的ACID关系型数据库，就算使用也很可能使用缓存如redis。   TCC模式不依赖于底层数据资源的事务支持：    一阶段prepare行为：调用自定义的prepare逻辑。  二阶段commit行为：调用自定义的commit逻辑。  二阶段rollback行为：调用自定义的rollback逻辑。   注...

前言   在 Java 语言中，除了原始数据类型的变量，其他所有都是所谓的引用类型，指向各种不同的对象，理解引用对于掌握 Java 对象生命周期和 JVM 内部相关机制非常有帮助。   本篇博文的重点是，强引用、软引用、弱引用、幻象引用有什么区别？具体使用场景是什么？   概述   不同的引用类型，主要体现的是对象不同的可达性（reachable）状态和对垃圾收集的影响。   强引用（“Strong” Reference），就是我们最常见的普通对象引用，只要还有强引用指向一个对象，就能表明对象还“活着”，垃圾收集器不会碰这种对象。对于一个普通的对象，如果没有其他的引用关系，只要超过了引用的作用...

异常处理   在java语言中，很机智的将异常作为对象来处理，而且定义一个基类java.lang.Throwable作为所有异常类的父类。在这许多类中一般分为两大类： 错误类(Error)和异常类（Expception）。     如图：         注：Error是程序无法处理的错误，如OutOfMemoryError等。当这些异常发生时，Java虚拟机一般会终止线程。而Exception是程序本身可以处理的异常，这种异常分为两大类：运行时异常和非运行时异常。   运行时异常和非运行时异常   这两种异常是有非常大的区别的，也叫做不检查异常(Unchecked Exception)和检查...

一 . 前言   这一篇来看看 SpringIOC 里面的一个细节点 , 来简单看看 BeanDefinition 这个对象 , 以及有没有办法对其进行定制.   二. BeanDefinition 的体系   2.1 体系概览      这里面需要关注的几个类分别为 :    BeanDefinition 接口 : 顶层接口 , 抽象了Bean加载的方法  AbstractBeanDefinition : 提供了多数方法的默认实现  RootBeanDefinition : Spring BeanFactory 运行时统一的 BeanDefinition 视图  GenericBeanDef...

需求场景    开发中经常会设计到excel的处理，需求场景如下所示：   1、将用户信息导出为excel表格（导出数据）   2、将Excel表中的信息录入到数据库中（导入数据）   操作Excel目前比较流行的就是 Apache POI 和 阿里巴巴开源的 EasyExcel ，当然还有EasyPoi工具。不过EasyPoi的易用性和性能介于前面两者之间，我们这里就暂不进一步深入了。 下面我们对前面两种工具分别进行介绍和实践：   Apache POI介绍   Apache POI 官网：poi.apache.org/         EasyExcel介绍   EasyExcel 官网地...

Null的原罪   众所周知，几乎所有的程序员当看到出现NPE（NullPointerException)都会异常头痛，因为有太多的原因会导致NPE的出现，排查需要耗费大量的时间，其原因是因为有null的存在。 Null的设计估计是计算机编程语言设计史上被诟病最多的一个了，其主要原因是Null存在二义性，即可以理解为“空”，也可以理解为“无效值”， 进而导致后续的程序很难正确处理，甚至还有忘记赋值后导致为null的情况。总之，一个程序总会因为各种各样的原因，导致出现了NPE问题。为了解决NPE问题，要么在程序中写很多的判空保护逻辑，要么就是后续排查会耗费大量精力，不管是哪种方式，都是一种不够经...

【JAVA】并发包中的 ConcurrentLinkedQueue 和 LinkedBlockingQueue 有什么区别？   前言   今天介绍一下线程安全队列。Java 标准库提供了非常多的线程安全队列，很容易混淆。   本篇重点是，并发包中的 ConcurrentLinkedQueue 和 LinkedBlockingQueue 有什么区别？   概述   有时候我们把并发包下面的所有容器都习惯叫作并发容器，但是严格来讲，类似 ConcurrentLinkedQueue 这种 “Concurrent..” 容器，才是真正代表并发。   关于问题中它们的区别：    Concurrent...