刘亚洲_社区达人页

2023年10月

• 10.11 14:33:40
  发表了文章 2023-10-11 14:33:40

  LiteFlow学习三之业务编排处理之外

  LiteFlow学习三之业务编排处理之外
• 10.11 14:32:21
  发表了文章 2023-10-11 14:32:21

  liteflow学习二

  liteflow学习二
• 10.11 14:31:42
  发表了文章 2023-10-11 14:31:42

  liteflow学习一

  liteflow学习一
• 10.11 14:30:51
  发表了文章 2023-10-11 14:30:51

  rayin使用与学习

  rayin使用与学习
• 10.11 14:29:55
  发表了文章 2023-10-11 14:29:55

  Spring读书笔记

  Spring读书笔记
• 10.11 14:29:20
  发表了文章 2023-10-11 14:29:20

  pipeline设计模式使用

  pipeline设计模式使用
• 10.11 14:28:34
  发表了文章 2023-10-11 14:28:34

  Eventbridge学习

  Eventbridge学习
• 10.11 14:27:07
  发表了文章 2023-10-11 14:27:07

  如何设计一个灵活的审批流程

  如何设计一个灵活的审批流程
• 10.11 14:26:28
  发表了文章 2023-10-11 14:26:28

  Seata的TCC模式学习整理

  Seata的TCC模式学习整理

2023年08月

• 08.02 13:37:26
  发表了文章 2023-08-02 13:37:26

  Seata中的TCC模式学习一

  Seata中的TCC模式学习一
• 08.02 13:36:29
  发表了文章 2023-08-02 13:36:29

  RocketMQ中相关Table记录

  RocketMQ中相关Table记录
• 08.02 13:35:45
  发表了文章 2023-08-02 13:35:45

  Austin消息中心

  Austin消息中心
• 08.02 13:34:47
  发表了文章 2023-08-02 13:34:47

  Cat学习

  Cat学习
• 08.02 13:33:34
  发表了文章 2023-08-02 13:33:34

  ageiport使用

  ageiport使用

  
• 08.02 13:32:31
  发表了文章 2023-08-02 13:32:31

  Nepxion Aquarius中Lock实现思路学习

  Nepxion Aquarius中Lock实现思路学习
• 08.02 13:31:34
  发表了文章 2023-08-02 13:31:34

  eventMesh源码学习

  eventMesh源码学习

2023年05月

• 05.11 15:31:01
  发表了文章 2023-05-11 15:31:01

  rocketmq中可视化和池化

  rocketmq获取默认的MQAdminExt时候，需要进行对象的获取，主要在rocketmq可视化中，方便使用，池化作为一个循环利用的过程，其类似于我们常用的数据库连接池一样，节省启动的成本。同时MQAdminExt是作为二次开发的一个主要使用的类。

  
• 05.11 15:26:21
  发表了文章 2023-05-11 15:26:21

  Rocketmq整合Spring中的推消费和litepull消费

  RocketMQ整合Spring中推拉模式的相关配置介绍和遇到推拉配置出现的问题的解决
• 05.11 15:21:43
  发表了文章 2023-05-11 15:21:43

  innodb逻辑存储结构整理

  从innodb存储引擎的逻辑存储来看，所有数据都被逻辑地存放在一个空间中，称之为表空间tablespace，表空间又由段segment、区extent、页page组成。
• 05.11 15:20:00
  发表了文章 2023-05-11 15:20:00

  CacheCloud中Task任务执行过程

  CacheCloud中Task任务执行过程实质是先将task进行堆积到taskQueue中，然后进行统一多线程进行处理。
• 05.11 15:15:06
  发表了文章 2023-05-11 15:15:06

  CacheCloud学习

  CacheCloud作为一款可视化方便管理redis的开源软件，可以方便redis集群的管理、开发、监控、运维管理，下面就CacheCloud的代码进行一些整理和学习

2023年03月

• 03.24 10:52:25
  发表了文章 2023-03-24 10:52:25

  Mysql文件

  Mysql文件包括：参数文件、日志文件、socket文件、pid文件、mysql表结构文件、存储引擎文件、参数文件、日志文件，通过了解mysql的文件相关组成，我们可以知道mysql的组成。

  
• 03.24 10:46:07
  发表了文章 2023-03-24 10:46:07

  神奇的魔数i

  接触复数是在高中的时候，那个时候不知道为啥要学习复数，而在大学依然在工程数学中依然能看到需要学习复变函数，那个时候是因为物探、测井的专业课需要用到数学物理方程，迷迷糊糊的看了，学习了一下。但是现在想想，确实挺有用的，因为数字信号分析与处理、地震波动力学、地震资料处理、测井都需要它。现在想想物探测井方向挺有趣的，但需要有深厚的数学功底。地球科学是一门很大的学问。言归正传，我们来了解欧拉公式和魔数i。

  
• 03.24 10:44:34
  发表了文章 2023-03-24 10:44:34

  Innodb体系架构学习整理

  InnoDB存储引擎最早由Innobase Oy公司开发，被包括在mysql数据库所有的二进制发行版本中，从mysql5.5版本开始默认的表存储引擎。其中Heikki Tuuri是InnoDB存储引擎的创始人。 InnoDB架构体系包含后台线程、内存、checkpoint技术，其中后台线程包含主线程、io处理线程、回收分配undo线程、页清理线程；内存包括缓冲池、重做日志缓冲、额外缓冲池；checkpoint技术包含 Sharp Checkpoint、FuzzyCheckpoint,数据库运行时，通常会和FuzzyCheckpoint打交道，通常会根据检查点age来处理

  

2023年02月

• 02.20 10:57:55
  发表了文章 2023-02-20 10:57:55

  CompletableFuture学习整理

  整理的原因是在Sentinel源码中，我们可以看到很多关于CompletableFuture的thenCompose的源码。同时在业务系统里面也看到别人写过类似的代码。因此整理了一下关于CompletableFuture使用的相关类型和特性，在处理复杂耗时业务时可以选择组合使用。

  
• 02.20 10:55:40
  发表了文章 2023-02-20 10:55:40

  Sentinel学习二

  如果我们不对Sentinel的异常提示做自定义，那么此时的提示是非常不详细的。如果做了自定义，就可以看到下面自定义的提示。sentinel提供了@SentinelResource注解帮助我们来实现自定义的熔断限流后的自定义方法处理，可以根据sentinel的aop可以看到处理的example，从而更为清晰的认识sentinel强大的功能。

  
• 02.09 13:53:05
  发表了文章 2023-02-09 13:53:05

  RocketMQ-Spring学习

  们可以它的一系列动作操作，会首先将相关配置MessageConverterConfiguration、ListenerContainerConfiguration、ExtProducerResetConfiguration、ExtConsumerResetConfiguration、RocketMQTransactionConfiguration、RocketMQListenerConfiguration进行导入。在自动注入前处理事务配置RocketMQTransactionConfiguration，在自动注入后处理消息转换器配置MessageConverterConfiguration。

  
• 02.02 21:31:03
  发表了文章 2023-02-02 21:31:03

  Sentinel的SPI和责任链模式学习

  通常spi可以配合责任链模式、策略模式使用。此时spi，类似于一个上下文的过程，拿到所有的实现class。 与之类似的还有：SpringUtil.getBeans或者ApplicationContext.getBeansOfType。在一些固定的场景下，处理业务的流程过程通常比较明确，第一步做什么，第二步做什么，第三步做什么的时候，这个时候就可以使用责任链模式在处理。也即存在固定的模式的时候，就可以使用。同时在Netty、Sentinel中有重要使用场景，其过程是一个pipeline流水线的过程。

  

2023年01月

• 01.31 17:32:45
  发表了文章 2023-01-31 17:32:45

  xxl-sso单点登录

  ### 一、如何实现一个简单的认证中心？ ​ 我们知道单点登录系统：出名的有[apereo](https://github.com/apereo)的cas和OAuth2、JWT等。通常认证有两个方案： ​ 一个方案是基于token，另一个方案是基于cookie的。基于xxl-sso,我们可以学习到实现的基本是基于过滤器的增强，从而实现重定向。我之前的公司使用的是基于[apereo](https://github.com/apereo)的cas进行的二次开发配合统一授权系统使用。cas的单点登录的登录涉及到三个概念：

  
• 01.31 17:27:41
  发表了文章 2023-01-31 17:27:41

  xxl-conf配置中心

  ### 一、实现一个轻量级简单的配置中心，同时不考虑使用zk？ 1.由于我们使用的配置中心需要兼容多套环境，因此需要多环境 2.需要有权限控制 3.需要对配置的信息，能够实时响应 4.如果配置信息存储在数据库，为了减轻数据库的压力，可以进行持久化到磁盘文件中 当时这里会有一个问题需要考虑，如果持久化到磁盘，需要考虑如果配置发生了改变，需要能够实时同步到磁盘文件中，因此此时需要考虑一个线程进行实时同步。 5.对应配置信息发生增、删、改，能够实时更新和修改

  

2022年12月

• 12.14 03:38:30
  发表了文章 2022-12-14 03:38:30

  Mysql事务实现原理

  1）BinLog是Mysql本身就有的，不管使用哪种引擎，都会存在BinLog，而Redo Log是InnoDB引擎特有的。 2）BinLog是一种逻辑日志，记录的是对数据库的所有修改操作，而RedoLog是一种物理日志，记录的是每个数据页的修改。 3）BinLog具有幂等性，而Redo Log不具有幂等性。 4）BinLog开启事务时，会将每次提交的事务一次性写入内存缓冲区，如果未开启事务，则每次成功执行插入、更新和删除语句时，就会将对应的事务信息写入内存缓冲区修改数据，而Redo Log是在数据准备之前将数据写入缓冲区的Redo Log中，然后在缓冲区中修改数据。而且在提交事务时，先将Re

  
• 12.14 03:37:26
  发表了文章 2022-12-14 03:37:26

  pmq再学习三

  前面我们已经了解了在做好基础数据的准备工作后，启动测试的时候，会做一个注册消费组的工作，完成后，我们就可以执行生产者发消息操作了。发消息的操作是：发送消息完成后，由于其采用的拉模式，我们可以看到消息在经过发送，存储到数据库之后，会做一个通知拉取数据操作，然后执行拉取。拉取完成后，进行响应。此时会进行消费操作，而这个过程的处理关键是handleData操作，从代码中，我们可以看到其是执行的线程操作是一个batchExcute批量执行操作，可以看到其里面有一个重要方法：threadExcute方法，从而进一步看到我们想看到的方法doMessageReceived

  
• 12.14 03:36:26
  发表了文章 2022-12-14 03:36:26

  pmq再学习二

  首先启动的过程中，会去获取消费组中的配置信息，拿到消费组中的配置信息后，执行注册消费组操作，而执行注册消费组操作中，会首先注册消费者，然后执行消费组操作，然后执行启动消费者轮询服务，执行mq检查服务启动，mq提交服务启动。完成后，执行监控服务配置操作。 这里面最为重要的是启动长轮询服务操作。因为长轮询服务涉及到执行重平衡操作和执行更新元数据操作。更新元数据操作涉及到更新队列元数据操作，此时不可避免的涉及到对偏移量的更新操作。

  
• 12.14 03:34:38
  发表了文章 2022-12-14 03:34:38

  pmq再学习一

  这个过程首先是创建主题，有了主题，创建消费组，然后基于消费组这个大前提，执行订阅操作，订阅需要进行消费的主题信息，然后在订阅的基础上，进行队列的分配。在这个过程中会执行元数据的变更和重平衡操作。而这些可以从审计日志中获取打印日志中可以看到很清楚。 下一篇，我们来看生产者和消费者的细节。生产者和消费者在执行操作前会执行一个操作init初始化操作，而这个初始化操作会将信息注册到将信息注册到MqClient中，因为只有将其进行统一管理的时候，在创建客户端对象的时候才会方便管理，同时方便调用，此时会启动心跳服务，此时少不了还有一个重要的操作就是注册消费组，同时需要关注一个点就是长轮询操作。

  
• 12.14 03:32:10
  发表了文章 2022-12-14 03:32:10

  递归算法使用

  通常递归算法可以将一个问题的重复调用进行分解，将其分解成一个多次调用，最终完成筛选或者需要的数据。比如我们常见的斐波那契数列就是这样的： 0、1、1、2、3、5、8、13、21、34这样的递归数据，可以通过此来总结出它的数学公式规律：F(n) = F(n-1) + F(n-2)的这个过程就是是借助上面的F(0)和F(1)的结果来进行递推的，这个过程在数学上是一个数列的递推公式，在高中我们学过的数列上。我还记得当时求解递推公式可以使用函数方程，而函数方程的思想想想其实是借助了微分方程逆推得到积分方程的过程,或者说是采用不动点法可以实现这一求解的过程。这个过程，在我看到高等数学的时候才明白，现在想

  
• 12.14 03:30:24
  发表了文章 2022-12-14 03:30:24

  Netty的使用

  一个好的通信框架是怎样的？同时如何使用netty？ 一个好的通信框架，必然是支持双工通信的，同时它能够对半包黏包进行处理，方便高效的编解码、序列化，拥有心跳超时机制，同时支持大量连接并发，方便调用。而这个通信的过程，我始终是觉得它的起源是三次握手和四次挥手。它们影响着消息中间件和通信框架以及SOA框架的发展。netty最简单的是它的EchoServer和EchoClient，两者有同时有自己对应的处理器EchoServerHandler、EchoClientHandler。

  
• 12.14 03:28:21
  发表了文章 2022-12-14 03:28:21

  基于Saas主键表生成主键id

  首先需要对当前的id进行拦截操作，也即使用aop的切面Aspect对切点进行拦截，在进行新增的时候进行拦截： 也就是说在进行主键的生成时，我们拦截好需要生成的主键，此时就可以对其进行新增操作了，而首要的就是拿到它的primaryKey。由于进行新增操作，通常分为两种情况： 通过字节码拿到声明的方法getId，如果此时存在id，则说明此时的操作是更新操作，因此直接返回。如果当前通过字节码拿到的声明方法getTenant，通过租户方法拿到租户id。拿到租户id后，就可以进行主键id获取了。

  
• 12.14 03:25:54
  发表了文章 2022-12-14 03:25:54

  互联互通数据推送

  需求是基于治疗数据，推送给平台，使用xml对数据进行组装，同时进行加密，里面包含所有的治疗数据与pdf，而生成是在完成治疗后进行数据的推送。这个过程是实时的，因此就需要考虑性能的问题，同时不能影响主流程。因此使用异步进行数据的推送，同时对生成的pdf需要进行加密，放入xml中。而提前的数据信息使用并行流的方式对数据进行组装。这里主要解决推送过程的方式。下面是最近的需求和解决的思路和方式。

  
• 12.14 03:23:20
  发表了文章 2022-12-14 03:23:20

  如何实现一个自定义的starter

  SpringFactoriesLoader加载器加载指定ClassLoader下面的所有的META-INF/spring.factories文件，并将文件解析内容存在Map<string,list>中。然后通过loadFactoryNames传递过来的class的名称从map中获取该类的配置列表。通过Set集合进行去重操作。执行过滤组件操作，而这些操作都是在AutoConfigurationImportFilter接口下的组件实现的，也即FilterSpringBootCondition实现抽象类的。下面有OnBeanCondition、OnClassCondition、OnWebApplic

  
• 12.14 03:21:08
  发表了文章 2022-12-14 03:21:08

  基于数组和链表实现队列

  创建大数组实现对象：里面包含的信息公共初始化： 初始化页工厂：索引页工厂、数据页工厂、元数据页工厂,初始化数组索引、初始化数据页索引，通过队列前置索引页工厂获取索引页，获取队列front索引buffer,获取front,也即索引。这个实现和kafka是类似的，也即需要有相关页信息 入队列：进行入队操作是一个追加的操作，首先判断容量是否够，不够，则进行扩容操作。通过缓存拿到映射页实现，然后通过映射页。再通过锁，仅锁定创建页，索引用完后进行移除操作，映射页面实现，使用双向校验，如果为空，则创建页索引对象,通过索引拿到文件名称，然后通过读写通道进行读写操作。使用fileChannal调用映射方法获取

  
• 12.14 03:17:19
  发表了文章 2022-12-14 03:17:19

  LRU实现基于map和双向链表实现

  如果我们遇到的缓存比较大时，此时又需要考虑怎样的缓存设计呢？ 此时由于缓存的消息或者信息比较大时，同时呈现成批量时，可以基于消息，考虑使用文件存储的方式进行，此时可以考虑NIO的处理方式，使用FileChannel和MappedByteBuffer或者堆外内存的方式，此时基于块状消息处理，使用缓冲区或者使用通道。此时的处理不经过用户态，因此性能上也是比较高的。 当然基于LinkedHashMap也可以实现LRU缓存设计。LinkedHashMap本身就是基于HashMap+双向链表实现的。

  
• 12.14 03:14:27
  发表了文章 2022-12-14 03:14:27

  单向链表

  在做缓存设计的时候，可以用到链表的数据结构来做缓存设计。主体结构采用map，而存储的节点、数据采用双向链表。这里介绍单向链表，因为如果搞懂了单向链表，其实双向链表更好理解。 数据结构中的链表分为单向链表、双向链表、循环链表。单向链表的数据结构中通常会存在数据域和节点域： 如图1：单向链表的数据结构

  
• 12.14 03:11:36
  发表了文章 2022-12-14 03:11:36

  Mybatis中sql拦截增强-AOP+interceptor实现分页和排序

  基于interceptor可以实现sql的完整打印，除了实现打印之外。其实还可以实现分页和排序，下面的分页和排序基于aop+mybatis的interceptor实现。其本质还是对mappedStament的boundSql进行增强。 下面的项目来源于github,通过这个我们可以很好的学习mybatis中插件interceptor的使用。

  
• 12.14 03:10:12
  发表了文章 2022-12-14 03:10:12

  pmq学习一-一些典型的使用和套路

  pmq是信也科技开源的一款消息中间件，虽然没有RocketMQ和Kafka出名，但是里面的代码还是有值得我们学习的地方的。 pmq的源码里面很多套路还是值得学习的，说实话，这些都是可以用到项目里面的。下面的代码来源于pmq。 首先安装好maven、mysql，对下载下拉的包进行打包： 如果遇到时区问题，则可以调整时区问题。 1.MqBootstrapListener 观察者模式的使用

  
• 12.14 03:09:07
  发表了文章 2022-12-14 03:09:07

  Netty流程学习

  连接完成之后，不能无所事事，此时应该会执行业务处理。也即此时可以看到上面的NettyServerHandler。因此可以看到dubbo的线程模型： 配置 Dubbo 中的线程模型 如果事件处理的逻辑能迅速完成，并且不会发起新的 IO 请求，比如只是在内存中记个标识，则直接在 IO 线程上处理更快，因为减少了线程池调度。 但如果事件处理逻辑较慢，或者需要发起新的 IO 请求，比如需要查询数据库，则必须派发到线程池，否则 IO 线程阻塞，将导致不能接收其它请求。 如果用 IO 线程处理事件，又在事件处理过程中发起新的 IO 请求，比如在连接事件中发起登录请求，会报“可能引发死锁”异常，但不会真死锁

  
• 12.14 03:07:09
  发表了文章 2022-12-14 03:07:09

  Netty流程学习一-netty启动服务

  问题：我们的线程：openSelector在什么时候创建的。 在创建NioEventLoop的时候，创建openSelector。 什么时候创建severSocketChannel、初始化serverSocketChannel，同时给serverSocketChannel从bossGroup中选择一个NioEventLoop 创建serverSocketChannel是在initAndRegister的时候，通过泛型+放射+工厂的方式创建serverSocketChannel。 而初始化则是设置channelOptions的相关参数信息、设置属性信息，同时通过channel的pipeline方

  
• 12.14 03:06:00
  发表了文章 2022-12-14 03:06:00

  dubbo生产者暴露服务流程

  在这个过程中，url是我们需要进行关注的，此时我们可以看到基本上都是以url为主题进行组装操作。将所有需要放入的输入进行放入，同时最终会以观察者模式，实现配置的实时更新。低版本的dubbo则是以实现InitializingBean，重写AfterPropertiesSet方法。之所以改成基于ApplicationEvent，是因为可以进行更新，这是ApplicationEvent的优势。 同时通过对bubbo的学习，可以看到Netty的使用。

  
• 12.14 03:03:28
  发表了文章 2022-12-14 03:03:28

  设计模式之设计原则

  1.单一职责原则 单一职责原则:类的职责单一，不能将太多的职责放在一个类中，该原则是实现高内聚、低耦合的指导方针 比如：进行登录操作需要经过用户请求、参数校验、查找用户、连接数据库、操作数据库等这些操作 开闭原则：一个软件应当对扩展开发、对修改关闭。即在不修改源代码的情况下改变对象的行为 比如：我们现在需要查看报表，但是由于之前没有预留接口，导致没法进行扩展，出现需要修改原来的代码的情况： 里氏代换原则：在软件系统中，一个可以接收基类(父类)对象的地方必然可以接收一个子类对象。其属于开闭原则的实现

  
• 12.14 03:01:15
  发表了文章 2022-12-14 03:01:15

  Kafka流程流转-服务端

  kafka分为客户端和服务端，通常我们知道broker是服务端，而生产者和消费者作为客户端。因此在服务端就必定需要解决并发和网络IO的问题。因此不可避免需要用到SocketChannel和ServerSocketChannel，可以看到kafka就使用了ServerSocketChannel,采用Netty来解决这个问题，这里socketServer采用了1个Acceptor，多个Processor。同时将请求发送到请求通道RequestChannel中。而我们知道RequestChannel中有一个请求队列和多个响应队列，通常响应队列是3个，这个参数是在kafka的配置中配置的。通过kafk

  
• 12.14 02:59:33
  发表了文章 2022-12-14 02:59:33

  kafka学习六-生产延迟操作

  这里思考问题，什么时候会用到延迟组件，同时哪些时候会用到延迟组件，同时为什么要用延迟组件？ 从kafkaApi中，我们可以知道具体的逻辑实现都是在这里实现的： DelayedOperation调用过程 同时基于时间轮进行时间过期的检测操作。 也即从这里我们可以看到DelayedProduce是协助副本管理器完成相应的延迟操作的，而副本管理器则主要是完成将生产者发送的消息写入到leader副本、管理follwer副本与leader副本之间的同步以及副本角色之间的转换。在上面的生产延迟中，我们可以看到在消息写入leader副本时需要DelayedProdue的协助。同时我们也可以看到：当生产请求的