思路1：用分页查询的方式取先查询出要处理的总数据量 count，然后假设每批要处理100条，代码//获取可push的记录进行发送消息private void getData(){//查出总数据量long count = xxxMapper.countByExample(example);int pageSize = 100;long pageNum = count / pageSize;l

使用Collectors.collectingAndThen链式对List根据元素对象属性去重。

首先还是来看看下面这张图:Transaction Coordinator (TC)： 事务协调器，它是独立的中间件，需要独立部署运行，它维护全局事务的运行状态，接收TM指令发起全局事务的提交与回滚，负责与RM通信协调各各分支事务的提交或回滚。Transaction Manager ™： 事务管理器，TM需要嵌入应用程序中工作，它负责开启一个全局事务，并最终向TC发起全局提交或全局回滚的指令...

MyBatis执行SQL查询,比将结果映射为java对象mybatis利用jdbc的PreparedStatement查询，是如何知道对查询结果ResultSet rs利用rs.getInt 还是用rs.getDate的呢先从SQL查询的// RoutingStatementHandler类开始进入@Overridepublic <E> List<E> qu...

aspectj-autoproxy标签注册AspectJAutoProxyBeanDefinitionParserpublic class AopNamespaceHandler extends NamespaceHandlerSupport {public AopNamespaceHandler() {}public void init() {...

本文主要讲启动netty源码分析，前面会讲一下服务引用到netty启动部分的源码流程。服务引用的入口方法为 ReferenceBean 的 getObject 方法public Object getObject() throws Exception {return get();}然后到com.alibaba.dubbo.config.ReferenceConfig#get方法public sync

1、springboot注解@SpringBootApplication中的@EnableAutoConfiguration@EnableAutoConfiguration主要是通过AutoConfigurationImportSelector类来加载　　分析mybatis也就首先从MybatisAutoConfiguration类分析（该类有Configuration注解，属于配置类）首先进入M

1.从官网下载https://nodejs.org/en/download/2 将包上传到linux的/usr/local路径，解压安装包xz -dnode-v12.18.3-linux-x64.tartar -xvf node-v12.18.3-linux-x64.tar3 重命名mvnode-v12.18.3-linux-x64/ nodejs4.让npm和node命令全局生效vim /etc

目前java操作redis的客户端有jedis跟Lettuce。在springboot1.x系列中，其中使用的是jedis,但是到了springboot2.x其中使用的是Lettuce。 因为我们的版本是springboot2.x系列，所以今天使用的是Lettuce。关于jedis跟lettuce的区别：Lettuce 和 Jedis 的定位都是Redis的client，所以他们当然可以直接...

思路1：用分页查询的方式取先查询出要处理的总数据量 count，然后假设每批要处理100条，代码//获取可push的记录进行发送消息private void getData(){//查出总数据量long count = xxxMapper.countByExample(example);int pageSize = 100;long pageNum = count / pageSize;l